services

Documentation

Index

• Variables
• type Message
• type NATSService
  • func NewNATSService() (*NATSService, error)
  • func (s *NATSService) Close()
  • func (s *NATSService) ReceiveMessages(ctx context.Context, publicIdentityKey []byte) ([]Message, error)
  • func (s *NATSService) Register(ctx context.Context, publicIdentityKey []byte, identityKeys [][]byte) error
  • func (s *NATSService) SendMessage(ctx context.Context, fromPublicIdentityKey []byte, toPublicIdentityKey []byte, ...) error

Variables

var ErrWrongMessageIndex = fmt.Errorf("wrong message index")

Types

type Message

type Message struct {
	FromPublicIdentityKey []byte `json:"from_public_identity_key"`
	Data                  []byte `json:"data"`
	CreatedAt             int64  `json:"created_at"`
}

type NATSService

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

func NewNATSService

func NewNATSService() (*NATSService, error)

func (*NATSService) Close

func (s *NATSService) Close()

func (*NATSService) ReceiveMessages

func (s *NATSService) ReceiveMessages(ctx context.Context, publicIdentityKey []byte) ([]Message, error)

func (*NATSService) Register

func (s *NATSService) Register(ctx context.Context, publicIdentityKey []byte, identityKeys [][]byte) error

func (*NATSService) SendMessage

func (s *NATSService) SendMessage(ctx context.Context, fromPublicIdentityKey []byte, toPublicIdentityKey []byte, data []byte, messageIndex uint64) error