event

Documentation

Index

• type IEvent
• type MetaBuilder
• type Publisher
  • func NewPublisher(conn stan.Conn, logger log.Logger) *Publisher
  • func (p *Publisher) Store(domain, model, eventType, subject, eventSource string, f endpoint.Endpoint, ...) endpoint.Endpoint
• type Subscriber
  • func NewSubscriber(conn stan.Conn, subject string, group string, durable string, startAt string, ...) *Subscriber
  • func (s *Subscriber) Subscribe() *stan.Subscription

Types

type IEvent

type IEvent interface {
	Store(
		domain, model, eventType, subject, eventSource string,
		f endpoint.Endpoint,
		metaBuilder MetaBuilder,
	) endpoint.Endpoint
	Subscribe() *stan.Subscription
}

IEvent ...

type MetaBuilder

type MetaBuilder func(data interface{}) interface{}

MetaBuilder wraping and building meta data before send it to nats

type Publisher

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

Publisher wraps a URL and provides a method that implements endpoint.Endpoint.

func NewPublisher

func NewPublisher(conn stan.Conn, logger log.Logger) *Publisher

NewPublisher to create new Publisher

func (*Publisher) Store

func (p *Publisher) Store(domain, model, eventType, subject, eventSource string, f endpoint.Endpoint, metabuilder MetaBuilder) endpoint.Endpoint

Store for publish event (begin and commit) to nats and data wrapping as a middleware

type Subscriber

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

Subscriber wraps subscription to topic a URL and provides a method that implements endpoint.Endpoint.

func NewSubscriber

func NewSubscriber(conn stan.Conn, subject string, group string, durable string, startAt string, logger log.Logger, handler stan.MsgHandler) *Subscriber

NewSubscriber to create new Subscriber

func (*Subscriber) Subscribe

func (s *Subscriber) Subscribe() *stan.Subscription

Subscribe to subscribe topic to nats