client

Documentation

Index

• Constants
• func ContextBizId(ctx context.Context) (uint64, bool)
• func ContextGroup(ctx context.Context) (string, bool)
• func ContextReqType(ctx context.Context) (uint8, bool)
• func ContextWithBizId(ctx context.Context, bizId uint64) context.Context
• func ContextWithGroup(ctx context.Context, group string) context.Context
• func ContextWithReqType(ctx context.Context, reqType uint8) context.Context
• type Manager
  • func (m *Manager[T]) Close(serviceName string) error
  • func (m *Manager[T]) CloseAll() error
  • func (m *Manager[T]) Get(serviceName string) (T, error)
• type ManagerBuilder
  • func NewManagerBuilder[T any](rb resolver.Builder, bb balancer.Builder, ...) *ManagerBuilder[T]
  • func (b *ManagerBuilder[T]) BalancerBuilder(bb balancer.Builder) *ManagerBuilder[T]
  • func (b *ManagerBuilder[T]) Build() *Manager[T]
  • func (b *ManagerBuilder[T]) Creator(creator func(conn *grpc.ClientConn) T) *ManagerBuilder[T]
  • func (b *ManagerBuilder[T]) Insecure() *ManagerBuilder[T]
  • func (b *ManagerBuilder[T]) KeepAlive(params keepalive.ClientParameters) *ManagerBuilder[T]
  • func (b *ManagerBuilder[T]) ResolverBuilder(rb resolver.Builder) *ManagerBuilder[T]

Constants

const (
	AttrNameWeight      = "attr_weight"
	AttrNameReadWeight  = "attr_read_weight"
	AttrNameWriteWeight = "attr_write_weight"
	AttrNameGroup       = "attr_group"
	AttrNameNode        = "attr_node"
)

Functions

func ContextBizId

func ContextBizId(ctx context.Context) (uint64, bool)

ContextBizId 从 context.Context 获取 business id

func ContextGroup

func ContextGroup(ctx context.Context) (string, bool)

func ContextReqType

func ContextReqType(ctx context.Context) (uint8, bool)

ContextReqType 从 context.Context 获取 request type

func ContextWithBizId

func ContextWithBizId(ctx context.Context, bizId uint64) context.Context

ContextWithBizId 在 context.Context 内写入 business id

func ContextWithGroup

func ContextWithGroup(ctx context.Context, group string) context.Context

ContextWithGroup 在 context.Context 内写入 group 信息

func ContextWithReqType

func ContextWithReqType(ctx context.Context, reqType uint8) context.Context

ContextWithReqType 在 context.Context 内写入 request type 信息 read request = 0 write request = 1

Types

type Manager

type Manager[T any] struct {
	// contains filtered or unexported fields
}

Manager grpc 客户端管理器

func (*Manager[T]) Close

func (m *Manager[T]) Close(serviceName string) error

Close 关闭指定服务连接

func (*Manager[T]) CloseAll

func (m *Manager[T]) CloseAll() error

CloseAll 关闭所有连接

func (*Manager[T]) Get

func (m *Manager[T]) Get(serviceName string) (T, error)

type ManagerBuilder

type ManagerBuilder[T any] struct {
	// contains filtered or unexported fields
}

ManagerBuilder grpc 客户端管理器 builder

func NewManagerBuilder

func NewManagerBuilder[T any](rb resolver.Builder, bb balancer.Builder, creator func(conn *grpc.ClientConn) T) *ManagerBuilder[T]

func (*ManagerBuilder[T]) BalancerBuilder

func (b *ManagerBuilder[T]) BalancerBuilder(bb balancer.Builder) *ManagerBuilder[T]

func (*ManagerBuilder[T]) Build

func (b *ManagerBuilder[T]) Build() *Manager[T]

func (*ManagerBuilder[T]) Creator

func (b *ManagerBuilder[T]) Creator(creator func(conn *grpc.ClientConn) T) *ManagerBuilder[T]

func (*ManagerBuilder[T]) Insecure

func (b *ManagerBuilder[T]) Insecure() *ManagerBuilder[T]

func (*ManagerBuilder[T]) KeepAlive

func (b *ManagerBuilder[T]) KeepAlive(params keepalive.ClientParameters) *ManagerBuilder[T]

func (*ManagerBuilder[T]) ResolverBuilder

func (b *ManagerBuilder[T]) ResolverBuilder(rb resolver.Builder) *ManagerBuilder[T]