tokenstore

Documentation

Index

• Variables
• type DBLite
• type Storage
  • func NewStorage(db sqrlx.Transactor) (*Storage, error)
  • func (s *Storage) ClientTokenToRequest(ctx context.Context, token string) (*messaging_j5pb.RequestMetadata, error)
  • func (s *Storage) PublishEvent(ctx context.Context, msg o5msg.Message) error
  • func (s *Storage) RequestToClientToken(ctx context.Context, req *messaging_j5pb.RequestMetadata) (string, error)

Variables

var RequestTokenNotFound = errors.New("request token not found")

Types

type DBLite

type DBLite interface {
	PublishEvent(context.Context, o5msg.Message) error
	RequestToClientToken(context.Context, *messaging_j5pb.RequestMetadata) (string, error)
	ClientTokenToRequest(context.Context, string) (*messaging_j5pb.RequestMetadata, error)
}

type Storage

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

func NewStorage

func NewStorage(db sqrlx.Transactor) (*Storage, error)

func (*Storage) ClientTokenToRequest

func (s *Storage) ClientTokenToRequest(ctx context.Context, token string) (*messaging_j5pb.RequestMetadata, error)

func (*Storage) PublishEvent

func (s *Storage) PublishEvent(ctx context.Context, msg o5msg.Message) error

func (*Storage) RequestToClientToken

func (s *Storage) RequestToClientToken(ctx context.Context, req *messaging_j5pb.RequestMetadata) (string, error)