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 Option
  • func WithHeader(name, value string) Option
• type Stream

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, opts ...Option) *httpClient

Types

type Client

type Client interface {
	Publish(context.Context, *messagev1.PublishRequest) (*messagev1.PublishResponse, error)
	Subscribe(context.Context, *messagev1.SubscribeRequest) (Stream, 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 Option

type Option func(*httpClient)

func WithHeader

func WithHeader(name, value string) Option

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