worker

Documentation

Index

• type Recv
  • func NewRecv(logger zerolog.Logger, cfg *config.Client, serverPort uint16, ...) *Recv
  • func (w *Recv) Run(ctx context.Context) error
• type Send
  • func NewSend(logger zerolog.Logger, cfg *config.Client, serverPort uint16, ...) *Send
  • func (w *Send) Run(ctx context.Context) error

Types

type Recv

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

func NewRecv

func NewRecv(logger zerolog.Logger, cfg *config.Client, serverPort uint16, session io.Writer) *Recv

func (*Recv) Run

func (w *Recv) Run(ctx context.Context) error

type Send

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

func NewSend

func NewSend(logger zerolog.Logger, cfg *config.Client, serverPort uint16, sessionReader <-chan *pool.Packet) *Send

func (*Send) Run

func (w *Send) Run(ctx context.Context) error