client

Documentation

Index

• func NewGRPCClient(ctx context.Context, dialFn func(context.Context) (*grpc.ClientConn, error)) (*grpcClient, error)
• func NewHTTPClient(log *zap.Logger, serverAddr string, gitCommit string, appVersion string) *httpClient
• type Client
• type Stream
• type Subscribe2Stream

Functions

func NewGRPCClient

func NewGRPCClient(ctx context.Context, dialFn func(context.Context) (*grpc.ClientConn, error)) (*grpcClient, error)

func NewHTTPClient

func NewHTTPClient(log *zap.Logger, serverAddr string, gitCommit string, appVersion string) *httpClient

Types

type Client

type Client interface {
	Publish(context.Context, *messagev1.PublishRequest) (*messagev1.PublishResponse, error)
	Subscribe(context.Context, *messagev1.SubscribeRequest) (Stream, error)
	Subscribe2(context.Context, *messagev1.SubscribeRequest) (Subscribe2Stream, error)
	SubscribeAll(context.Context) (Stream, error)
	Query(context.Context, *messagev1.QueryRequest) (*messagev1.QueryResponse, error)
	BatchQuery(ctx context.Context, req *messagev1.BatchQueryRequest) (*messagev1.BatchQueryResponse, error)
	Close() error
}

type Stream

type Stream interface {
	// Next returns io.EOF when the stream ends or is closed from either side.
	Next(ctx context.Context) (*messagev1.Envelope, error)
	// Closing the stream terminates the subscription.
	Close() error
}

Stream is an abstraction of the subscribe response stream

type Subscribe2Stream

type Subscribe2Stream interface {
	Send(req *messagev1.SubscribeRequest) error
	Stream
}