client

Documentation

Index

• func Close(client any)
• func CloseAwait(client any)
• func GetConn(serviceName string, multiplex bool) (con client.Interface, err error)
• func GetConsumers() []string
• type ErrCon
  • func (c ErrCon) Invoke(ctx context.Context, method string, args any, reply any, ...) error
  • func (c ErrCon) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, ...) (grpc.ClientStream, error)
• type GenerateFun
  • func Auto[t any](fun func(cc grpc.ClientConnInterface) t) GenerateFun[t]
  • func NewClient[t any](serviceName string, fun func(cc grpc.ClientConnInterface) t) GenerateFun[t]

Functions

func Close

func Close(client any)

关闭复用客户端

func CloseAwait

func CloseAwait(client any)

关闭复用客户端，等待所有请求结束后再关闭

func GetConn

func GetConn(serviceName string, multiplex bool) (con client.Interface, err error)

func GetConsumers

func GetConsumers() []string

Types

type ErrCon

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

func (ErrCon) Invoke

func (c ErrCon) Invoke(ctx context.Context, method string, args any, reply any, opts ...grpc.CallOption) error

func (ErrCon) NewStream

func (c ErrCon) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)

type GenerateFun

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

func Auto

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

func NewClient

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