util

Documentation

Index

• Constants
• func CreateRequestId() string
• func GetBoolEnvar(key string, defaultValue bool) (bool, error)
• func GetHttpClient() (*http.Client, error)
• func GetHttpClientFromTLSOptions(tlsOptions *TLSOptions) *http.Client
• func GetIntEnvar(key string, defaultValue int) (int, error)
• func GetKafkaConsumerName(modelName, prefix string, maxConsumers int) string
• func GetOrignalModelNameAndVersion(versionedModel string) (string, uint32, error)
• func GetPinnedModelVersion() uint32
• func GetVersionedModelName(model string, version uint32) string
• func Hash(s string) (uint32, error)
• func XXHash(key string) string
• type LoadBalancer
• type RingLoadBalancer
  • func NewRingLoadBalancer(replicationFactor int) *RingLoadBalancer
  • func (lb *RingLoadBalancer) AddServer(serverName string)
  • func (lb *RingLoadBalancer) GetServersForKey(key string) []string
  • func (lb *RingLoadBalancer) RemoveServer(serverName string)
• type TLSOptions
  • func CreateTLSClientOptions() (*TLSOptions, error)
  • func CreateUpstreamDataplaneServerTLSOptions() (TLSOptions, error)

Constants

const (
	GrpcRetryBackoffMillisecs         = 100
	EnvoyUpdateDefaultBatchWaitMillis = 250 * time.Millisecond
)

const RequestIdHeader = "x-request-id"

const RequestIdHeaderCanonical = "X-Request-Id"

Functions

func CreateRequestId

func CreateRequestId() string

func GetBoolEnvar

func GetBoolEnvar(key string, defaultValue bool) (bool, error)

func GetHttpClient

func GetHttpClient() (*http.Client, error)

func GetHttpClientFromTLSOptions

func GetHttpClientFromTLSOptions(tlsOptions *TLSOptions) *http.Client

func GetIntEnvar

func GetIntEnvar(key string, defaultValue int) (int, error)

func GetKafkaConsumerName

func GetKafkaConsumerName(modelName, prefix string, maxConsumers int) string

func GetOrignalModelNameAndVersion

func GetOrignalModelNameAndVersion(versionedModel string) (string, uint32, error)

func GetPinnedModelVersion

func GetPinnedModelVersion() uint32

func GetVersionedModelName

func GetVersionedModelName(model string, version uint32) string

func Hash

func Hash(s string) (uint32, error)

func XXHash

func XXHash(key string) string

Types

type LoadBalancer

type LoadBalancer interface {
	AddServer(serverName string)
	RemoveServer(serverName string)
	GetServersForKey(key string) []string
}

type RingLoadBalancer

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

func NewRingLoadBalancer

func NewRingLoadBalancer(replicationFactor int) *RingLoadBalancer

func (*RingLoadBalancer) AddServer

func (lb *RingLoadBalancer) AddServer(serverName string)

func (*RingLoadBalancer) GetServersForKey

func (lb *RingLoadBalancer) GetServersForKey(key string) []string

func (*RingLoadBalancer) RemoveServer

func (lb *RingLoadBalancer) RemoveServer(serverName string)

type TLSOptions

type TLSOptions struct {
	TLS  bool
	Cert *seldontls.CertificateStore
}

func CreateTLSClientOptions

func CreateTLSClientOptions() (*TLSOptions, error)

func CreateUpstreamDataplaneServerTLSOptions

func CreateUpstreamDataplaneServerTLSOptions() (TLSOptions, error)