selector

Documentation

Index

• func Init()
• func Sel(ctx context.Context, method string, shardKeyValue any) (context.Context, *grpc.ClientConn, error)
• type CacheKey
• type HashRing
  • func (p *HashRing[K]) Select(ctx context.Context, key K, method string) (*grpc.ClientConn, error)
• type Mod
  • func (p *Mod[K]) Select(ctx context.Context, key K, method string) (*grpc.ClientConn, error)

Functions

func Init

func Init()

Init initializes the selectors for different key types.

func Sel

func Sel(ctx context.Context, method string, shardKeyValue any) (context.Context, *grpc.ClientConn, error)

Types

type CacheKey

type CacheKey[K util.IKey] struct {
	// contains filtered or unexported fields
}

CacheKey 缓存键

type HashRing

type HashRing[K util.IKey] struct {
	// contains filtered or unexported fields
}

func (*HashRing[K]) Select

func (p *HashRing[K]) Select(ctx context.Context, key K, method string) (*grpc.ClientConn, error)

type Mod

type Mod[K util.IKey] struct {
	// contains filtered or unexported fields
}

func (*Mod[K]) Select

func (p *Mod[K]) Select(ctx context.Context, key K, method string) (*grpc.ClientConn, error)