discovery

Documentation

Index

• Variables
• type Conn
• type KeyValue
• type SvcDiscoveryRegistry
• type WatchKey
• type WatchKeyHandler

Variables

var ErrNotSupportedKeyValue = errors.New("discovery data not supported key value")

Types

type Conn

type Conn interface {
	GetConn(ctx context.Context, serviceName string, opts ...grpc.DialOption) (grpc.ClientConnInterface, error)
	GetConns(ctx context.Context, serviceName string, opts ...grpc.DialOption) ([]grpc.ClientConnInterface, error)
	IsSelfNode(cc grpc.ClientConnInterface) bool
}

type KeyValue

type KeyValue interface {
	SetKey(ctx context.Context, key string, value []byte) error
	GetKey(ctx context.Context, key string) ([]byte, error)
	WatchKey(ctx context.Context, key string, fn WatchKeyHandler) error
}

type SvcDiscoveryRegistry

type SvcDiscoveryRegistry interface {
	Conn
	KeyValue
	AddOption(opts ...grpc.DialOption)
	Register(ctx context.Context, serviceName, host string, port int, opts ...grpc.DialOption) error
	Close()
	GetUserIdHashGatewayHost(ctx context.Context, userId string) (string, error)
}

type WatchKey

type WatchKey struct {
	Value []byte
}

type WatchKeyHandler

type WatchKeyHandler func(data *WatchKey) error