udp

Documentation

Index

• func WithUDPDirectorReuse(reuse bool) GenericApplier[*UDPDirector]
• type UDPActor
  • func NewUDPActor(localLog zerolog.Logger, director *UDPDirector, peer string) *UDPActor
  • func (a *UDPActor) HandleError(err error)
  • func (a *UDPActor) Indication(args Args, kwArgs KWArgs) error
  • func (a *UDPActor) Response(args Args, kwArgs KWArgs) error
  • func (d *UDPActor) Serialize() ([]byte, error)
  • func (d *UDPActor) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error
  • func (d *UDPActor) String() string
• type UDPDirector
  • func NewUDPDirector(localLog zerolog.Logger, address AddressTuple[string, uint16], ...) (*UDPDirector, error)
  • func (d *UDPDirector) ActorError(actor *UDPActor, err error)
  • func (d *UDPDirector) AddActor(actor *UDPActor)
  • func (d *UDPDirector) Close() error
  • func (d *UDPDirector) DelActor(actor *UDPActor)
  • func (d *UDPDirector) GetActor(address Address) *UDPActor
  • func (d *UDPDirector) Indication(args Args, kwArgs KWArgs) error
  • func (d *UDPDirector) Serialize() ([]byte, error)
  • func (d *UDPDirector) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error
  • func (d *UDPDirector) String() string

Functions

func WithUDPDirectorReuse

func WithUDPDirectorReuse(reuse bool) GenericApplier[*UDPDirector]

Types

type UDPActor

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

func NewUDPActor

func NewUDPActor(localLog zerolog.Logger, director *UDPDirector, peer string) *UDPActor

func (*UDPActor) HandleError

func (a *UDPActor) HandleError(err error)

func (*UDPActor) Indication

func (a *UDPActor) Indication(args Args, kwArgs KWArgs) error

func (*UDPActor) Response

func (a *UDPActor) Response(args Args, kwArgs KWArgs) error

func (*UDPActor) Serialize

func (d *UDPActor) Serialize() ([]byte, error)

func (*UDPActor) SerializeWithWriteBuffer

func (d *UDPActor) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*UDPActor) String

func (d *UDPActor) String() string

type UDPDirector

type UDPDirector struct {
	ServerContract
	ServiceAccessPointContract
	// contains filtered or unexported fields
}

func NewUDPDirector

func NewUDPDirector(localLog zerolog.Logger, address AddressTuple[string, uint16], options ...Option) (*UDPDirector, error)

func (*UDPDirector) ActorError

func (d *UDPDirector) ActorError(actor *UDPActor, err error)

func (*UDPDirector) AddActor

func (d *UDPDirector) AddActor(actor *UDPActor)

AddActor adds an actor when a new one is connected

func (*UDPDirector) Close

func (d *UDPDirector) Close() error

func (*UDPDirector) DelActor

func (d *UDPDirector) DelActor(actor *UDPActor)

DelActor removes an actor when the socket is closed.

func (*UDPDirector) GetActor

func (d *UDPDirector) GetActor(address Address) *UDPActor

func (*UDPDirector) Indication

func (d *UDPDirector) Indication(args Args, kwArgs KWArgs) error

Indication Client requests are queued for delivery.

func (*UDPDirector) Serialize

func (d *UDPDirector) Serialize() ([]byte, error)

func (*UDPDirector) SerializeWithWriteBuffer

func (d *UDPDirector) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error

func (*UDPDirector) String

func (d *UDPDirector) String() string