rpc

type SessionToken struct {
	Token                string   `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type WebProxyRpcClient interface {
	CreateSession(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*SessionToken, error)
	OpenChannel(ctx context.Context, in *rpc.OpenChannelRequest, opts ...grpc.CallOption) (*rpc.OpenChannelResponse, error)
	SubscribeMessages(ctx context.Context, in *rpc.AuthReq, opts ...grpc.CallOption) (WebProxyRpc_SubscribeMessagesClient, error)
	SendMessage(ctx context.Context, in *rpc.CelerMsg, opts ...grpc.CallOption) (*empty.Empty, error)
}

type WebProxyRpcServer interface {
	CreateSession(context.Context, *empty.Empty) (*SessionToken, error)
	OpenChannel(context.Context, *rpc.OpenChannelRequest) (*rpc.OpenChannelResponse, error)
	SubscribeMessages(*rpc.AuthReq, WebProxyRpc_SubscribeMessagesServer) error
	SendMessage(context.Context, *rpc.CelerMsg) (*empty.Empty, error)
}

type WebProxyRpc_SubscribeMessagesClient interface {
	Recv() (*rpc.CelerMsg, error)
	grpc.ClientStream
}

type WebProxyRpc_SubscribeMessagesServer interface {
	Send(*rpc.CelerMsg) error
	grpc.ServerStream
}