envelope

Documentation

Index

• type DefaultTimeSource
  • func (DefaultTimeSource) GetCurrentTimestamp() time.Time
• type Envelope
• type Processor
  • func NewProcessor(token string, encodingAESKey string, opts ...ProcessorOption) (*Processor, error)
  • func (p *Processor) HandleIncomingMsg(url *url.URL, body []byte) (Envelope, error)
  • func (p *Processor) MakeOutgoingEnvelope(msg []byte) ([]byte, error)
• type ProcessorOption
  • func WithEntropySource(e io.Reader) ProcessorOption
  • func WithTimeSource(t TimeSource) ProcessorOption
• type TimeSource

Types

type DefaultTimeSource

type DefaultTimeSource struct{}

func (DefaultTimeSource) GetCurrentTimestamp

func (DefaultTimeSource) GetCurrentTimestamp() time.Time

type Envelope

type Envelope struct {
	ToUserName string
	AgentID    string
	Msg        []byte
	ReceiveID  []byte
}

type Processor

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

func NewProcessor

func NewProcessor(
	token string,
	encodingAESKey string,
	opts ...ProcessorOption,
) (*Processor, error)

func (*Processor) HandleIncomingMsg

func (p *Processor) HandleIncomingMsg(
	url *url.URL,
	body []byte,
) (Envelope, error)

func (*Processor) MakeOutgoingEnvelope

func (p *Processor) MakeOutgoingEnvelope(msg []byte) ([]byte, error)

type ProcessorOption

type ProcessorOption interface {
	// contains filtered or unexported methods
}

func WithEntropySource

func WithEntropySource(e io.Reader) ProcessorOption

func WithTimeSource

func WithTimeSource(t TimeSource) ProcessorOption

type TimeSource

type TimeSource interface {
	GetCurrentTimestamp() time.Time
}