sqlsubscriptionstore

Documentation

Index

• type SubscriptionStore
  • func New(db pool.Pool) (*SubscriptionStore, error)
  • func (s *SubscriptionStore) GetAllSubscriptions(ctx context.Context) ([]*pb.Subscription, error)
  • func (s *SubscriptionStore) GetSubscription(ctx context.Context, name string, revision string) (*pb.Subscription, error)
  • func (s *SubscriptionStore) InsertSubscriptions(ctx context.Context, subs []*pb.Subscription) error

Types

type SubscriptionStore

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

SubscriptionStore implements the subscription.Store interface using an SQL database.

func New

func New(db pool.Pool) (*SubscriptionStore, error)

New returns a new *SubscriptionStore.

func (*SubscriptionStore) GetAllSubscriptions

func (s *SubscriptionStore) GetAllSubscriptions(ctx context.Context) ([]*pb.Subscription, error)

GetAllSubscriptions implements the subscription.Store interface. This function queries the db to fetch all the subscriptions.

func (*SubscriptionStore) GetSubscription

func (s *SubscriptionStore) GetSubscription(ctx context.Context, name string, revision string) (*pb.Subscription, error)

GetSubscription implements the subscription.Store interface.

func (*SubscriptionStore) InsertSubscriptions

func (s *SubscriptionStore) InsertSubscriptions(ctx context.Context, subs []*pb.Subscription) error

InsertSubscriptions implements the subscription.Store interface.