gc

Documentation

Index

• func IsKnownPacket(packet *gc.GCPacket) bool
• func UnmarshalPacket(packet *gc.GCPacket, message proto.Message) error
• type Dispatcher
  • func NewDispatcher(options DispatcherOptions) *Dispatcher
  • func (p *Dispatcher) ChildSpec() oversight.ChildProcessSpecification
  • func (p *Dispatcher) HandleGCPacket(packet *gc.GCPacket)
  • func (p *Dispatcher) Start(ctx context.Context) (err error)
• type DispatcherOptions
• type IncomingMessage
  • func NewIncomingMessage(msgType d2pb.EDOTAGCMsg) *IncomingMessage
  • func (m *IncomingMessage) UnmarshalPacket(packet *gc.GCPacket) error

Functions

func IsKnownPacket

func IsKnownPacket(packet *gc.GCPacket) bool

func UnmarshalPacket

func UnmarshalPacket(packet *gc.GCPacket, message proto.Message) error

Types

type Dispatcher

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

func NewDispatcher

func NewDispatcher(options DispatcherOptions) *Dispatcher

func (*Dispatcher) ChildSpec

func (p *Dispatcher) ChildSpec() oversight.ChildProcessSpecification

func (*Dispatcher) HandleGCPacket

func (p *Dispatcher) HandleGCPacket(packet *gc.GCPacket)

HandleGCPacket implements the steam.GCPacketHandler interface.

It runs in the steam client goroutine.

It's not possible to de-register this handler once registered, so the owner must be long lived.

func (*Dispatcher) Start

func (p *Dispatcher) Start(ctx context.Context) (err error)

type DispatcherOptions

type DispatcherOptions struct {
	Log             *nslog.Logger
	Bus             *nsbus.Bus
	ShutdownTimeout time.Duration
}

type IncomingMessage

type IncomingMessage struct {
	Type     d2pb.EDOTAGCMsg
	Message  proto.Message
	BusTopic string
}

func NewIncomingMessage

func NewIncomingMessage(msgType d2pb.EDOTAGCMsg) *IncomingMessage

func (*IncomingMessage) UnmarshalPacket

func (m *IncomingMessage) UnmarshalPacket(packet *gc.GCPacket) error