postgres

Documentation

Index

• type Option
  • func WithLogger(l loglib.Logger) Option
• type Store
  • func NewSubscriptionStore(ctx context.Context, url string, opts ...Option) (*Store, error)
  • func (s *Store) CreateSubscription(ctx context.Context, subscription *subscription.Subscription) error
  • func (s *Store) DeleteSubscription(ctx context.Context, subscription *subscription.Subscription) error
  • func (s *Store) GetSubscriptions(ctx context.Context, action, schema, table string) ([]*subscription.Subscription, error)

Types

type Option

type Option func(*Store)

func WithLogger

func WithLogger(l loglib.Logger) Option

type Store

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

func NewSubscriptionStore

func NewSubscriptionStore(ctx context.Context, url string, opts ...Option) (*Store, error)

func (*Store) CreateSubscription

func (s *Store) CreateSubscription(ctx context.Context, subscription *subscription.Subscription) error

func (*Store) DeleteSubscription

func (s *Store) DeleteSubscription(ctx context.Context, subscription *subscription.Subscription) error

func (*Store) GetSubscriptions

func (s *Store) GetSubscriptions(ctx context.Context, action, schema, table string) ([]*subscription.Subscription, error)