sub

Documentation

Index

• type Subscriber
  • func NewSubscriber(conn *nats.Conn, sc SubscriberSource, log *slog.Logger, timeout time.Duration) *Subscriber
  • func (s *Subscriber) Subscribe() error
• type SubscriberChangedEvent
• type SubscriberDeleter
• type SubscriberSaver
• type SubscriberSource

Types

type Subscriber

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

func NewSubscriber

func NewSubscriber(
	conn *nats.Conn,
	sc SubscriberSource,
	log *slog.Logger,
	timeout time.Duration,
) *Subscriber

func (*Subscriber) Subscribe

func (s *Subscriber) Subscribe() error

type SubscriberChangedEvent

type SubscriberChangedEvent struct {
	ID      int    `json:"id"`
	Type    string `json:"type"`
	Payload string `json:"payload"`
}

type SubscriberDeleter

type SubscriberDeleter interface {
	Delete(ctx context.Context, sub subscriber.Subscriber) error
}

type SubscriberSaver

type SubscriberSaver interface {
	Save(ctx context.Context, sub subscriber.Subscriber) error
}

type SubscriberSource

type SubscriberSource interface {
	SubscriberSaver
	SubscriberDeleter
}