dispatcher

Documentation

Index

• type Dispatcher
  • func NewDispatcher(ctx context.Context, meter metric.Meter) (*Dispatcher, error)
  • func (d *Dispatcher) ListenForMessages(ctx context.Context, id string, ...)
  • func (d *Dispatcher) SendMessage(ctx context.Context, msg *proto.EncryptedMessage) (*proto.EncryptedMessage, error)

Types

type Dispatcher

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

func NewDispatcher

func NewDispatcher(ctx context.Context, meter metric.Meter) (*Dispatcher, error)

func (*Dispatcher) ListenForMessages

func (d *Dispatcher) ListenForMessages(ctx context.Context, id string, messageHandler func(context.Context, *proto.EncryptedMessage))

func (*Dispatcher) SendMessage

func (d *Dispatcher) SendMessage(ctx context.Context, msg *proto.EncryptedMessage) (*proto.EncryptedMessage, error)