subscriber

Documentation

Index

• Variables
• type NatsSubscriber
  • func NewNatsSubscriber(tableName string, sc stan.Conn, db *pg.DB) *NatsSubscriber
  • func (n *NatsSubscriber) Close() error
  • func (n *NatsSubscriber) ReSendSubscriptionEvents() error
  • func (n *NatsSubscriber) Subscribe(subject string, f Subscriber, threads uint64, chanLength uint64, ...) error
• type Subscriber

Variables

var ErrOnlyOneSubscriberAllowed = fmt.Errorf("only one subscriber allowed")

Types

type NatsSubscriber

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

func NewNatsSubscriber

func NewNatsSubscriber(tableName string, sc stan.Conn, db *pg.DB) *NatsSubscriber

func (*NatsSubscriber) Close

func (n *NatsSubscriber) Close() error

func (*NatsSubscriber) ReSendSubscriptionEvents

func (n *NatsSubscriber) ReSendSubscriptionEvents() error

func (*NatsSubscriber) Subscribe

func (n *NatsSubscriber) Subscribe(subject string, f Subscriber, threads uint64, chanLength uint64, ef func(error)) error

type Subscriber

type Subscriber func(ch <-chan uint64)