pkg

Documentation

Index

• func MustMarshalAny(pb proto.Message) *any.Any
• type DiscoveryClient
  • func InitServiceDiscoveryClient(configPath string) *DiscoveryClient
  • func (c *DiscoveryClient) GetEnvoyConfig() (EnvoyDKVConfig, error)
• type EnvoyDKVConfig
  • func (conf EnvoyDKVConfig) ComputeAndSetSnapshot(snapVer uint, snapCache cache.SnapshotCache) error

Functions

func MustMarshalAny

func MustMarshalAny(pb proto.Message) *any.Any

MustMarshalAny marshals a protobuf into an any.Any type, panicking if that operation fails.

Types

type DiscoveryClient

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

func InitServiceDiscoveryClient

func InitServiceDiscoveryClient(configPath string) *DiscoveryClient

InitServiceDiscoveryClient Create a connection to DKV Service discovery client which provides a view of entire cluster Cluster comprises of all databases and shards (vBuckets) which are registering to this service discovery group

func (*DiscoveryClient) GetEnvoyConfig

func (c *DiscoveryClient) GetEnvoyConfig() (EnvoyDKVConfig, error)

type EnvoyDKVConfig

type EnvoyDKVConfig map[string]interface{}

func (EnvoyDKVConfig) ComputeAndSetSnapshot

func (conf EnvoyDKVConfig) ComputeAndSetSnapshot(snapVer uint, snapCache cache.SnapshotCache) error