client

Documentation

Index

• func ClientAuto[t any](fun func(cc grpc.ClientConnInterface) t) func() t
• func GetConn(serviceName string) (grpc.ClientConnInterface, error)
• func NewClient[t any](serviceName string, fun func(cc grpc.ClientConnInterface) t) func() t
• type ClientConn
  • 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 context.Context, method string, args, reply interface{}, ...) error
  • func (cc *ClientConn) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, ...) (grpc.ClientStream, error)
  • func (cc *ClientConn) ResetConnectBackoff()
  • func (cc *ClientConn) Target() string
  • func (cc *ClientConn) WaitForStateChange(ctx context.Context, sourceState connectivity.State) bool

Functions

func ClientAuto

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

func GetConn

func GetConn(serviceName string) (grpc.ClientConnInterface, error)

func NewClient

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

Types

type ClientConn

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

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 context.Context, method string, args, reply interface{}, opts ...grpc.CallOption) error

func (*ClientConn) NewStream

func (cc *ClientConn) NewStream(ctx context.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 context.Context, sourceState connectivity.State) bool