subscription

Documentation

Index

• type Client
  • func NewClient(ctx context.Context, dst Destination) (Client, error)
• type Destination

Types

type Client

type Client interface {
	// Add adds a subscription
	Add(ctx context.Context, subscription *subapi.Subscription) error

	// Remove removes a subscription
	Remove(ctx context.Context, subscription *subapi.Subscription) error

	// Get returns a subscription based on a given subscription ID
	Get(ctx context.Context, id subapi.ID) (*subapi.Subscription, error)

	// List returns the list of existing subscriptions
	List(ctx context.Context) ([]subapi.Subscription, error)

	// Watch watches the subscription changes
	Watch(ctx context.Context, ch chan<- subapi.Event) error
}

Client subscription client interface

func NewClient

func NewClient(ctx context.Context, dst Destination) (Client, error)

NewClient creates a new subscribe service client

type Destination

type Destination struct {
	// Addrs a slice of addresses by which a subscription service may be reached.
	Addrs []string
}

Destination determines subscription service endpoint