pubsub

Documentation

Index

• func NewService(secureStore securestore.SecureStorage) (ports.SecurePubSub, error)
• type Subscription
  • func NewSubscription(event, endpoint, secret string) (*Subscription, error)
  • func NewSubscriptionFromBytes(buf []byte) (*Subscription, error)
  • func (h *Subscription) Id() string
  • func (h *Subscription) IsSecured() bool
  • func (h *Subscription) NotifyAt() string
  • func (h *Subscription) Serialize() []byte
  • func (h *Subscription) Topic() string

Functions

func NewService

func NewService(
	secureStore securestore.SecureStorage,
) (ports.SecurePubSub, error)

Types

type Subscription

type Subscription struct {
	ID       string `json:"id"`
	Event    string `json:"event"`
	Endpoint string `json:"endpoint"`
	Secret   string `json:"secret"`
}

func NewSubscription

func NewSubscription(event, endpoint, secret string) (*Subscription, error)

func NewSubscriptionFromBytes

func NewSubscriptionFromBytes(buf []byte) (*Subscription, error)

func (*Subscription) Id

func (h *Subscription) Id() string

func (*Subscription) IsSecured

func (h *Subscription) IsSecured() bool

func (*Subscription) NotifyAt

func (h *Subscription) NotifyAt() string

func (*Subscription) Serialize

func (h *Subscription) Serialize() []byte

func (*Subscription) Topic

func (h *Subscription) Topic() string