termination

Documentation

Index

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

Types

type Client

type Client interface {
	io.Closer

	// Stream opens a stream
	Stream(ctx context.Context, ch chan<- e2tapi.StreamResponse) (chan<- e2tapi.StreamRequest, error)

	Control(ctx context.Context, request *e2tapi.ControlRequest) (*e2tapi.ControlResponse, error)
}

Client is an E2 subscription service client interface

func NewClient

func NewClient(conn *grpc.ClientConn) Client

NewClient creates a new subscribe task service client