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 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
}

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