hstreamrpc

Documentation

Index

• func UnaryClientInterceptor(ctx context.Context, method string, req, reply interface{}, ...) error
• type ReqType
  • func (t ReqType) String() string
• type Request
• type Response
  • func Call(ctx context.Context, cli hstreampb.HStreamApiClient, req *Request) (*Response, error)

Functions

func UnaryClientInterceptor

func UnaryClientInterceptor(ctx context.Context, method string, req, reply interface{},
	cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error

Types

type ReqType

type ReqType uint16

ReqType represents the concrete rpc request type in Request.

const (
	CreateStream ReqType = 1 + iota
	DeleteStream
	ListStreams
	LookupShard
	ListShards
	Append

	CreateSubscription ReqType = 256 + iota
	ListSubscriptions
	CheckSubscriptionExist
	DeleteSubscription
	LookupSubscription
	StreamingFetch

	DescribeCluster ReqType = 512 + iota

	AdminRequest ReqType = 1024 + iota

	PerStreamStats ReqType = 2048 + iota
	PerStreamStatsAll

	CreateShardReader ReqType = 3072 + iota
	LookupShardReader
	ReadShard
	DeleteShardReader

	GetStatsRequest ReqType = 4096 + iota
)

func (ReqType) String

func (t ReqType) String() string

type Request

type Request struct {
	Type ReqType
	Req  interface{}
}

Request is a wrapper for all rpc requests.

type Response

type Response struct {
	Resp interface{}
}

Response is a wrapper for all rpc responses.

func Call

func Call(ctx context.Context, cli hstreampb.HStreamApiClient, req *Request) (*Response, error)

Call send rpc to server and wait for response.