Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Bus ¶
Bus implements a publisher/subscriber using Go channels. This implementation works only on a single node, i.e. handlers are not distributed. In order to distribute the load across a cluster, a persistent message queue (such as RabbitMQ or Kafka) should instead be used.
type Config ¶
type Config struct { TLSConfig *tls.Config CMD *cobra.Command CSLVCStore credentialstatus.CSLVCStore ProfileService profileService KMSRegistry kmsRegistry Crypto vcCrypto Tracer trace.Tracer IsTraceEnabled bool DocumentLoader ld.DocumentLoader }
Config holds the configuration for the publisher/subscriber.
type Publisher ¶
type Publisher struct {
// contains filtered or unexported fields
}
func NewEventPublisher ¶
func NewEventPublisher(pub eventPublisher) *Publisher
NewEventPublisher creates event publisher.
type Subscriber ¶
Subscriber implements an event subscriber.
func NewEventSubscriber ¶
func NewEventSubscriber(sub eventSubscriber, topic string, handler eventHandler) (*Subscriber, error)
NewEventSubscriber returns a new subscriber.
Click to show internal directories.
Click to hide internal directories.