vcpubsub

Documentation

Index

• type Publisher
  • func NewPublisher(pubSub pubSub) *Publisher
  • func (h *Publisher) Publish(ctx context.Context, anchorLinkset *linkset.Linkset) error
• type Subscriber
  • func NewSubscriber(pubSub pubSub, processor anchorProcessor, subscriberPoolSize int) (*Subscriber, error)

Types

type Publisher

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

Publisher implements a publisher that publishes witnessed verifiable credentials to a message queue.

func NewPublisher

func NewPublisher(pubSub pubSub) *Publisher

NewPublisher returns a new verifiable credential publisher.

func (*Publisher) Publish

func (h *Publisher) Publish(ctx context.Context, anchorLinkset *linkset.Linkset) error

Publish publishes a verifiable credential to a message queue for processing.

type Subscriber

type Subscriber struct {
	*lifecycle.Lifecycle
	// contains filtered or unexported fields
}

Subscriber implements a subscriber that processes witnessed verifiable credentials from a message queue.

func NewSubscriber

func NewSubscriber(pubSub pubSub, processor anchorProcessor, subscriberPoolSize int) (*Subscriber, error)

NewSubscriber returns a new verifiable credential subscriber.