client

Documentation

Index

• func Close(client any)
• type ClientConn
  • func GetConn(serviceName string, multiplex bool) (*ClientConn, error)
  • func (cc *ClientConn) Close() error
  • func (cc *ClientConn) Connect()
  • func (cc *ClientConn) GetMethodConfig(method string) grpc.MethodConfig
  • func (cc *ClientConn) GetState() connectivity.State
  • func (cc *ClientConn) Invoke(ctx goContext.Context, method string, args, reply interface{}, ...) error
  • func (cc *ClientConn) NewStream(ctx goContext.Context, desc *grpc.StreamDesc, method string, ...) (grpc.ClientStream, error)
  • func (cc *ClientConn) ResetConnectBackoff()
  • func (cc *ClientConn) Target() string
  • func (cc *ClientConn) WaitForStateChange(ctx goContext.Context, sourceState connectivity.State) bool
• type ClientGenerateFun
  • func ClientAuto[t any](fun func(cc grpc.ClientConnInterface) t) ClientGenerateFun[t]
  • func NewClient[t any](serviceName string, fun func(cc grpc.ClientConnInterface) t) ClientGenerateFun[t]

Functions

func Close

func Close(client any)

Types

type ClientConn

type ClientConn struct {
	// contains filtered or unexported fields
}

func GetConn

func GetConn(serviceName string, multiplex bool) (*ClientConn, error)

func (*ClientConn) Close

func (cc *ClientConn) Close() error

func (*ClientConn) Connect

func (cc *ClientConn) Connect()

func (*ClientConn) GetMethodConfig

func (cc *ClientConn) GetMethodConfig(method string) grpc.MethodConfig

func (*ClientConn) GetState

func (cc *ClientConn) GetState() connectivity.State

func (*ClientConn) Invoke

func (cc *ClientConn) Invoke(ctx goContext.Context, method string, args, reply interface{}, opts ...grpc.CallOption) error

func (*ClientConn) NewStream

func (cc *ClientConn) NewStream(ctx goContext.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)

func (*ClientConn) ResetConnectBackoff

func (cc *ClientConn) ResetConnectBackoff()

func (*ClientConn) Target

func (cc *ClientConn) Target() string

func (*ClientConn) WaitForStateChange

func (cc *ClientConn) WaitForStateChange(ctx goContext.Context, sourceState connectivity.State) bool

type ClientGenerateFun

type ClientGenerateFun[t any] func(isMultiplex ...bool) t

func ClientAuto

func ClientAuto[t any](fun func(cc grpc.ClientConnInterface) t) ClientGenerateFun[t]

func NewClient

func NewClient[t any](serviceName string, fun func(cc grpc.ClientConnInterface) t) ClientGenerateFun[t]