clientsets

Documentation

Index

• Constants
• func AddServiceLookup(fun func(string) []string)
• func ServiceLookup(service string) []string
• type ClientSets
  • func GetClientSets(ctx context.Context, service, kubeconfig, runIdPrefix string) ClientSets
  • func NewClientSets(ctx context.Context, service, runIdPrefix, kubeconfig string) ClientSets
  • func NewClientSetsWithRestConfig(ctx context.Context, service, runIdPrefix string, restConfig *rest.Config) ClientSets
• type LookupFunc

Constants

const (
	SyncPeriod                    = time.Second * 2
	ClientCacheTTL                = time.Minute * 2
	ServerHeartBeatInterval       = time.Second * 1
	ServerHeartBeatTimeout        = time.Second * 5
	ServerHeartBeatRequestTimeout = time.Millisecond * 1000

	ServerInfoUrl = "/apis/proxy.kubegateway.io/v1alpha1/ratelimit/endpoints"
	HeartBeatUrl  = "/apis/proxy.kubegateway.io/v1alpha1/ratelimit/heartbeat"
)

Functions

func AddServiceLookup

func AddServiceLookup(fun func(string) []string)

func ServiceLookup

func ServiceLookup(service string) []string

Types

type ClientSets

type ClientSets interface {
	GetAllClients() []gatewayclientset.Interface
	ClientFor(cluster string) (gatewayclientset.Interface, error)
	ShardIDFor(cluster string) (int, error)
	IsReady(cluster string) bool
	ClientID() string
}

func GetClientSets

func GetClientSets(ctx context.Context, service, kubeconfig, runIdPrefix string) ClientSets

func NewClientSets

func NewClientSets(ctx context.Context, service, runIdPrefix, kubeconfig string) ClientSets

func NewClientSetsWithRestConfig

func NewClientSetsWithRestConfig(ctx context.Context, service, runIdPrefix string, restConfig *rest.Config) ClientSets

type LookupFunc

type LookupFunc func(service string) []string