envelope

Dec 24, 2021

Changes in this version

+ type DefaultTimeSource struct

+ func (DefaultTimeSource) GetCurrentTimestamp() time.Time

+ type Envelope struct

+ AgentID string

+ Msg []byte

+ ReceiveID []byte

+ ToUserName string

+ type Processor struct

+ 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 interface

+ func WithEntropySource(e io.Reader) ProcessorOption

+ func WithTimeSource(t TimeSource) ProcessorOption

+ type TimeSource interface

+ GetCurrentTimestamp func() time.Time