comm

package

v1.0.1 Latest Latest Go to latest Published: Feb 16, 2026 License: GPL-3.0 Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/1f349/melon-backup

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type Client
- func NewClient(conf conf.ConfigYAML) (*Client, error)
type FinishPacket
- func (p *FinishPacket) ReadFrom(r io.Reader) (n int64, err error)
- func (p *FinishPacket) WriteTo(w io.Writer) (n int64, err error)
type IngesterPacket
- func (p *IngesterPacket) ReadFrom(r io.Reader) (n int64, err error)
- func (p *IngesterPacket) WriteTo(w io.Writer) (n int64, err error)
type Listener
- func NewListener(conf conf.ConfigYAML) (*Listener, error)
- func (l *Listener) Accept() (*Client, error)
- func (l *Listener) Close()
type Packet
- func (p *Packet) ReadFrom(r io.Reader) (n int64, err error)
- func (p *Packet) WriteTo(w io.Writer) (n int64, err error)
type PacketType
type SenderPacket
- func (p *SenderPacket) ReadFrom(r io.Reader) (n int64, err error)
- func (p *SenderPacket) WriteTo(w io.Writer) (n int64, err error)
type ServiceList
- func (s *ServiceList) ReadFrom(r io.Reader) (n int64, err error)
- func (s *ServiceList) WriteTo(w io.Writer) (n int64, err error)

Constants ¶

This section is empty.

Variables ¶

View Source

var ConnectionClosed = PacketType(4)

View Source

var ConnectionData = PacketType(5)

View Source

var ConnectionKeepAlive = PacketType(254)

View Source

var ConnectionReset = PacketType(3)

View Source

var ConnectionSendStartRequest = PacketType(6)

View Source

var ConnectionStartRequest = PacketType(1)

View Source

var ConnectionStarted = PacketType(2)

View Source

var Finish = PacketType(128)

View Source

var Ingester = PacketType(255)

View Source

var Sender = PacketType(0)

Functions ¶

This section is empty.

Types ¶

type Client ¶

type Client struct {
	SenderData *SenderPacket
	// contains filtered or unexported fields
}

func NewClient ¶

func NewClient(conf conf.ConfigYAML) (*Client, error)

func (*Client) ActivateForPureConnection ¶

func (c *Client) ActivateForPureConnection() net.Conn

func (*Client) ActivateWithPacketProcessing ¶

func (c *Client) ActivateWithPacketProcessing()

func (*Client) Close ¶

func (c *Client) Close()

func (*Client) ReceivePacket ¶

func (c *Client) ReceivePacket() *Packet

func (*Client) SendPacket ¶

func (c *Client) SendPacket(p *Packet)

type FinishPacket ¶

type FinishPacket struct{}

func (*FinishPacket) ReadFrom ¶

func (p *FinishPacket) ReadFrom(r io.Reader) (n int64, err error)

func (*FinishPacket) WriteTo ¶

func (p *FinishPacket) WriteTo(w io.Writer) (n int64, err error)

type IngesterPacket ¶

type IngesterPacket struct {
	Mode int
}

func (*IngesterPacket) ReadFrom ¶

func (p *IngesterPacket) ReadFrom(r io.Reader) (n int64, err error)

func (*IngesterPacket) WriteTo ¶

func (p *IngesterPacket) WriteTo(w io.Writer) (n int64, err error)

type Listener ¶

type Listener struct {
	// contains filtered or unexported fields
}

func NewListener ¶

func NewListener(conf conf.ConfigYAML) (*Listener, error)

func (*Listener) Accept ¶

func (l *Listener) Accept() (*Client, error)

func (*Listener) Close ¶

func (l *Listener) Close()

type Packet ¶

type Packet struct {
	Type         PacketType
	ConnectionID int
	Data         []byte
}

func (*Packet) ReadFrom ¶

func (p *Packet) ReadFrom(r io.Reader) (n int64, err error)

func (*Packet) WriteTo ¶

func (p *Packet) WriteTo(w io.Writer) (n int64, err error)

type PacketType ¶

type PacketType byte

type SenderPacket ¶

type SenderPacket struct {
	Mode                   int
	Services               *ServiceList
	RequestReboot          bool
	RequestServiceStop     bool
	RequestServiceRestart  bool
	RequestServiceStartNew bool
}

func (*SenderPacket) ReadFrom ¶

func (p *SenderPacket) ReadFrom(r io.Reader) (n int64, err error)

func (*SenderPacket) WriteTo ¶

func (p *SenderPacket) WriteTo(w io.Writer) (n int64, err error)

type ServiceList ¶

type ServiceList struct {
	List []string
}

func (*ServiceList) ReadFrom ¶

func (s *ServiceList) ReadFrom(r io.Reader) (n int64, err error)

func (*ServiceList) WriteTo ¶

func (s *ServiceList) WriteTo(w io.Writer) (n int64, err error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL