subscription

Documentation

Index

• type Client
  • func NewClient(conn *grpc.ClientConn) Client
• type Context

Types

type Client

type Client interface {
	io.Closer

	// 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 is an E2 subscription service client interface

func NewClient

func NewClient(conn *grpc.ClientConn) Client

NewClient creates a new subscribe service client

type Context

type Context interface {
	io.Closer

	// ID returns the subscription identifier
	ID() subapi.ID

	// Err returns the subscription error channel
	Err() <-chan error
}

Context is a subscription context