genericclient

Documentation

Overview

Package genericclient ...

Index

• func StreamingServiceInfo(g generic.Generic) *serviceinfo.ServiceInfo
• type BidirectionalStreaming
  • func NewBidirectionalStreaming(ctx context.Context, genericCli Client, method string, ...) (BidirectionalStreaming, error)
• type Client
  • func NewClient(destService string, g generic.Generic, opts ...client.Option) (Client, error)
  • func NewClientWithServiceInfo(destService string, g generic.Generic, svcInfo *serviceinfo.ServiceInfo, ...) (Client, error)
  • func NewStreamingClient(destService string, g generic.Generic, opts ...client.Option) (Client, error)
  • func NewStreamingClientWithServiceInfo(destService string, g generic.Generic, svcInfo *serviceinfo.ServiceInfo, ...) (Client, error)
• type ClientStreaming
  • func NewClientStreaming(ctx context.Context, genericCli Client, method string, ...) (ClientStreaming, error)
• type ServerStreaming
  • func NewServerStreaming(ctx context.Context, genericCli Client, method string, req interface{}, ...) (ServerStreaming, error)

Functions

func StreamingServiceInfo

func StreamingServiceInfo(g generic.Generic) *serviceinfo.ServiceInfo

Types

type BidirectionalStreaming

type BidirectionalStreaming interface {
	streaming.Stream
	Send(req interface{}) error
	Recv() (resp interface{}, err error)
}

func NewBidirectionalStreaming

func NewBidirectionalStreaming(ctx context.Context, genericCli Client, method string, callOpts ...callopt.Option) (BidirectionalStreaming, error)

type Client

type Client interface {
	generic.Closer

	// GenericCall generic call
	GenericCall(ctx context.Context, method string, request interface{}, callOptions ...callopt.Option) (response interface{}, err error)
}

Client generic client

func NewClient

func NewClient(destService string, g generic.Generic, opts ...client.Option) (Client, error)

NewClient create a generic client

func NewClientWithServiceInfo

func NewClientWithServiceInfo(destService string, g generic.Generic, svcInfo *serviceinfo.ServiceInfo, opts ...client.Option) (Client, error)

NewClientWithServiceInfo create a generic client with serviceInfo

func NewStreamingClient

func NewStreamingClient(destService string, g generic.Generic, opts ...client.Option) (Client, error)

func NewStreamingClientWithServiceInfo

func NewStreamingClientWithServiceInfo(destService string, g generic.Generic, svcInfo *serviceinfo.ServiceInfo, opts ...client.Option) (Client, error)

type ClientStreaming

type ClientStreaming interface {
	streaming.Stream
	Send(req interface{}) error
	CloseAndRecv() (resp interface{}, err error)
}

func NewClientStreaming

func NewClientStreaming(ctx context.Context, genericCli Client, method string, callOpts ...callopt.Option) (ClientStreaming, error)

type ServerStreaming

type ServerStreaming interface {
	streaming.Stream
	Recv() (resp interface{}, err error)
}

func NewServerStreaming

func NewServerStreaming(ctx context.Context, genericCli Client, method string, req interface{}, callOpts ...callopt.Option) (ServerStreaming, error)