gubernator

Mar 19, 2024

Changes in this version

+ func NewStaticBuilder() resolver.Builder

type CacheItem

+ func (item *CacheItem) IsExpired() bool

type Config

+ InstanceID string

type Daemon

+ InstanceID string

+ PeerInfo PeerInfo

+ func (s *Daemon) Client() (V1Client, error)

+ func (s *Daemon) MustClient() V1Client

type RateLimitReq

+ CreatedAt *int64

+ func (x *RateLimitReq) GetCreatedAt() int64

+ type RateLimitReqState struct

+ IsOwner bool

type UpdatePeerGlobal

+ CreatedAt int64

+ Duration int64

+ func (x *UpdatePeerGlobal) GetCreatedAt() int64

+ func (x *UpdatePeerGlobal) GetDuration() int64

Feb 9, 2024

Changes in this version

type Behavior

+ const Behavior_DRAIN_OVER_LIMIT

Oct 30, 2023

Changes in this version

type BehaviorConfig

+ GlobalPeerRequestsConcurrency int

Oct 10, 2023

Changes in this version

type BehaviorConfig

+ DisableBatching bool

+ ForceGlobal bool

Aug 17, 2023

Changes in this version

+ const GregorianDays

+ const GregorianHours

+ const GregorianMinutes

+ const GregorianMonths

+ const GregorianWeeks

+ const GregorianYears

+ const Healthy

+ const Millisecond

+ const Minute

+ const PeersV1_GetPeerRateLimits_FullMethodName

+ const PeersV1_UpdatePeerGlobals_FullMethodName

+ const Second

+ const UnHealthy

+ const V1_GetRateLimits_FullMethodName

+ const V1_HealthCheck_FullMethodName

+ var Algorithm_name = map[int32]string

+ var Algorithm_value = map[string]int32

+ var Behavior_name = map[int32]string

+ var Behavior_value = map[string]int32

+ var DebugEnabled = false

+ var File_gubernator_proto protoreflect.FileDescriptor

+ var File_peers_proto protoreflect.FileDescriptor

+ var PeersV1_ServiceDesc = grpc.ServiceDesc

+ var Status_name = map[int32]string

+ var Status_value = map[string]int32

+ var TraceLevelInfoFilter = otelgrpc.Filter(func(info *otelgrpc.InterceptorInfo) bool { ... })

+ var V1_ServiceDesc = grpc.ServiceDesc

+ func ContextWithStats(ctx context.Context, stats *GRPCStats) context.Context

+ func FromTimeStamp(ts int64) time.Duration

+ func FromUnixMilliseconds(ts int64) time.Time

+ func GetInstanceID() string

+ func GetTracingLevel() tracing.Level

+ func GregorianDuration(now clock.Time, d int64) (int64, error)

+ func GregorianExpiration(now clock.Time, d int64) (int64, error)

+ func HasBehavior(b Behavior, flag Behavior) bool

+ func IsNotReady(err error) bool

+ func LocalHost() string

+ func MillisecondNow() int64

+ func RandomString(n int) string

+ func RegisterPeersV1Handler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterPeersV1HandlerClient(ctx context.Context, mux *runtime.ServeMux, client PeersV1Client) error

+ func RegisterPeersV1HandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

+ func RegisterPeersV1HandlerServer(ctx context.Context, mux *runtime.ServeMux, server PeersV1Server) error

+ func RegisterPeersV1Server(s grpc.ServiceRegistrar, srv PeersV1Server)

+ func RegisterV1Handler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterV1HandlerClient(ctx context.Context, mux *runtime.ServeMux, client V1Client) error

+ func RegisterV1HandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

+ func RegisterV1HandlerServer(ctx context.Context, mux *runtime.ServeMux, server V1Server) error

+ func RegisterV1Server(s grpc.ServiceRegistrar, srv V1Server)

+ func ResolveHostIP(addr string) (string, error)

+ func RestConfig() (*rest.Config, error)

+ func SetBehavior(b *Behavior, flag Behavior, set bool)

+ func SetupTLS(conf *TLSConfig) error

+ func ToTimeStamp(duration time.Duration) int64

+ func WaitForConnect(ctx context.Context, addresses []string) error

+ type Algorithm int32

+ const Algorithm_LEAKY_BUCKET

+ const Algorithm_TOKEN_BUCKET

+ func (Algorithm) Descriptor() protoreflect.EnumDescriptor

+ func (Algorithm) EnumDescriptor() ([]byte, []int)

+ func (Algorithm) Type() protoreflect.EnumType

+ func (x Algorithm) Enum() *Algorithm

+ func (x Algorithm) Number() protoreflect.EnumNumber

+ func (x Algorithm) String() string

+ type AsyncReq struct

+ AsyncCh chan AsyncResp

+ Idx int

+ Key string

+ Peer *PeerClient

+ Req *RateLimitReq

+ WG *sync.WaitGroup

+ type AsyncResp struct

+ Idx int

+ Resp *RateLimitResp

+ type Behavior int32

+ const Behavior_BATCHING

+ const Behavior_DURATION_IS_GREGORIAN

+ const Behavior_GLOBAL

+ const Behavior_MULTI_REGION

+ const Behavior_NO_BATCHING

+ const Behavior_RESET_REMAINING

+ func (Behavior) Descriptor() protoreflect.EnumDescriptor

+ func (Behavior) EnumDescriptor() ([]byte, []int)

+ func (Behavior) Type() protoreflect.EnumType

+ func (x Behavior) Enum() *Behavior

+ func (x Behavior) Number() protoreflect.EnumNumber

+ func (x Behavior) String() string

+ type BehaviorConfig struct

+ BatchLimit int

+ BatchTimeout time.Duration

+ BatchWait time.Duration

+ GlobalBatchLimit int

+ GlobalSyncWait time.Duration

+ GlobalTimeout time.Duration

+ type Cache interface

+ Add func(item *CacheItem) bool

+ Close func() error

+ Each func() chan *CacheItem

+ GetItem func(key string) (value *CacheItem, ok bool)

+ Remove func(key string)

+ Size func() int64

+ UpdateExpiration func(key string, expireAt int64) bool

+ type CacheItem struct

+ Algorithm Algorithm

+ ExpireAt int64

+ InvalidAt int64

+ Key string

+ Value interface{}

+ type Config struct

+ Behaviors BehaviorConfig

+ CacheFactory func(maxSize int) Cache

+ CacheSize int

+ DataCenter string

+ GRPCServers []*grpc.Server

+ Loader Loader

+ LocalPicker PeerPicker

+ Logger FieldLogger

+ PeerTLS *tls.Config

+ PeerTraceGRPC bool

+ RegionPicker RegionPeerPicker

+ Store Store

+ Workers int

+ func (c *Config) SetDefaults() error

+ type DNSPool struct

+ func NewDNSPool(conf DNSPoolConfig) (*DNSPool, error)

+ func (p *DNSPool) Close()

+ type DNSPoolConfig struct

+ FQDN string

+ Logger FieldLogger

+ OnUpdate UpdateFunc

+ OwnAddress string

+ ResolvConf string

+ type DNSResolver struct

+ Servers []string

+ func NewFromResolvConf(path string) (*DNSResolver, error)

+ type Daemon struct

+ GRPCListeners []net.Listener

+ HTTPListener net.Listener

+ V1Server *V1Instance

+ func SpawnDaemon(ctx context.Context, conf DaemonConfig) (*Daemon, error)

+ func (s *Daemon) Close()

+ func (s *Daemon) Config() DaemonConfig

+ func (s *Daemon) Peers() []PeerInfo

+ func (s *Daemon) SetPeers(in []PeerInfo)

+ func (s *Daemon) Start(ctx context.Context) error

+ type DaemonConfig struct

+ AdvertiseAddress string

+ Behaviors BehaviorConfig

+ CacheSize int

+ DNSPoolConf DNSPoolConfig

+ DataCenter string

+ EtcdPoolConf EtcdPoolConfig

+ GRPCListenAddress string

+ GRPCMaxConnectionAgeSeconds int

+ HTTPListenAddress string

+ HTTPStatusListenAddress string

+ InstanceID string

+ K8PoolConf K8sPoolConfig

+ Logger FieldLogger

+ MemberListPoolConf MemberListPoolConfig

+ MetricFlags MetricFlags

+ PeerDiscoveryType string

+ Picker PeerPicker

+ TLS *TLSConfig

+ TraceLevel tracing.Level

+ Workers int

+ func SetupDaemonConfig(logger *logrus.Logger, configFile string) (DaemonConfig, error)

+ func (d *DaemonConfig) ClientTLS() *tls.Config

+ func (d *DaemonConfig) ServerTLS() *tls.Config

+ type EtcdPool struct

+ func NewEtcdPool(conf EtcdPoolConfig) (*EtcdPool, error)

+ func (e *EtcdPool) Close()

+ func (e *EtcdPool) GetPeers(ctx context.Context) ([]PeerInfo, error)

+ type EtcdPoolConfig struct

+ Advertise PeerInfo

+ Client *etcd.Client

+ EtcdConfig *etcd.Config

+ KeyPrefix string

+ Logger FieldLogger

+ OnUpdate UpdateFunc

+ type FieldLogger interface

+ Debug func(args ...interface{})

+ Debugf func(format string, args ...interface{})

+ Error func(args ...interface{})

+ Errorf func(format string, args ...interface{})

+ Fatalf func(format string, args ...interface{})

+ Info func(args ...interface{})

+ Infof func(format string, args ...interface{})

+ Log func(level logrus.Level, args ...interface{})

+ Print func(args ...interface{})

+ Printf func(format string, args ...interface{})

+ Tracef func(format string, args ...interface{})

+ Warn func(args ...interface{})

+ Warnf func(format string, args ...interface{})

+ Warning func(args ...interface{})

+ Warningf func(format string, args ...interface{})

+ WithContext func(ctx context.Context) *logrus.Entry

+ WithError func(err error) *logrus.Entry

+ WithField func(key string, value interface{}) *logrus.Entry

+ WithFields func(fields logrus.Fields) *logrus.Entry

+ WithTime func(t time.Time) *logrus.Entry

+ type GRPCStats struct

+ Duration clock.Duration

+ Failed float64

+ Method string

+ Success float64

+ func StatsFromContext(ctx context.Context) *GRPCStats

+ type GRPCStatsHandler struct

+ func NewGRPCStatsHandler() *GRPCStatsHandler

+ func (c *GRPCStatsHandler) Close()

+ func (c *GRPCStatsHandler) Collect(ch chan<- prometheus.Metric)

+ func (c *GRPCStatsHandler) Describe(ch chan<- *prometheus.Desc)

+ func (c *GRPCStatsHandler) HandleConn(ctx context.Context, s stats.ConnStats)

+ func (c *GRPCStatsHandler) HandleRPC(ctx context.Context, s stats.RPCStats)

+ func (c *GRPCStatsHandler) TagConn(ctx context.Context, _ *stats.ConnTagInfo) context.Context

+ func (c *GRPCStatsHandler) TagRPC(ctx context.Context, tagInfo *stats.RPCTagInfo) context.Context

+ type GetPeerRateLimitsReq struct

+ Requests []*RateLimitReq

+ func (*GetPeerRateLimitsReq) Descriptor() ([]byte, []int)

+ func (*GetPeerRateLimitsReq) ProtoMessage()

+ func (x *GetPeerRateLimitsReq) GetRequests() []*RateLimitReq

+ func (x *GetPeerRateLimitsReq) ProtoReflect() protoreflect.Message

+ func (x *GetPeerRateLimitsReq) Reset()

+ func (x *GetPeerRateLimitsReq) String() string

+ type GetPeerRateLimitsResp struct

+ RateLimits []*RateLimitResp

+ func (*GetPeerRateLimitsResp) Descriptor() ([]byte, []int)

+ func (*GetPeerRateLimitsResp) ProtoMessage()

+ func (x *GetPeerRateLimitsResp) GetRateLimits() []*RateLimitResp

+ func (x *GetPeerRateLimitsResp) ProtoReflect() protoreflect.Message

+ func (x *GetPeerRateLimitsResp) Reset()

+ func (x *GetPeerRateLimitsResp) String() string

+ type GetRateLimitsReq struct

+ Requests []*RateLimitReq

+ func (*GetRateLimitsReq) Descriptor() ([]byte, []int)

+ func (*GetRateLimitsReq) ProtoMessage()

+ func (x *GetRateLimitsReq) GetRequests() []*RateLimitReq

+ func (x *GetRateLimitsReq) ProtoReflect() protoreflect.Message

+ func (x *GetRateLimitsReq) Reset()

+ func (x *GetRateLimitsReq) String() string

+ type GetRateLimitsResp struct

+ Responses []*RateLimitResp

+ func (*GetRateLimitsResp) Descriptor() ([]byte, []int)

+ func (*GetRateLimitsResp) ProtoMessage()

+ func (x *GetRateLimitsResp) GetResponses() []*RateLimitResp

+ func (x *GetRateLimitsResp) ProtoReflect() protoreflect.Message

+ func (x *GetRateLimitsResp) Reset()

+ func (x *GetRateLimitsResp) String() string

+ type HashString64 func(data string) uint64

+ type HealthCheckReq struct

+ func (*HealthCheckReq) Descriptor() ([]byte, []int)

+ func (*HealthCheckReq) ProtoMessage()

+ func (x *HealthCheckReq) ProtoReflect() protoreflect.Message

+ func (x *HealthCheckReq) Reset()

+ func (x *HealthCheckReq) String() string

+ type HealthCheckResp struct

+ Message string

+ PeerCount int32

+ Status string

+ func (*HealthCheckResp) Descriptor() ([]byte, []int)

+ func (*HealthCheckResp) ProtoMessage()

+ func (x *HealthCheckResp) GetMessage() string

+ func (x *HealthCheckResp) GetPeerCount() int32

+ func (x *HealthCheckResp) GetStatus() string

+ func (x *HealthCheckResp) ProtoReflect() protoreflect.Message

+ func (x *HealthCheckResp) Reset()

+ func (x *HealthCheckResp) String() string

+ type Interval struct

+ C chan struct{}

+ func NewInterval(d clock.Duration) *Interval

+ func (i *Interval) Next()

+ func (i *Interval) Stop()

+ type K8sPool struct

+ func NewK8sPool(conf K8sPoolConfig) (*K8sPool, error)

+ func (e *K8sPool) Close()

+ type K8sPoolConfig struct

+ Logger FieldLogger

+ Mechanism WatchMechanism

+ Namespace string

+ OnUpdate UpdateFunc

+ PodIP string

+ PodPort string

+ Selector string

+ type LRUCache struct

+ func NewLRUCache(maxSize int) *LRUCache

+ func (c *LRUCache) Add(item *CacheItem) bool

+ func (c *LRUCache) Close() error

+ func (c *LRUCache) Each() chan *CacheItem

+ func (c *LRUCache) GetItem(key string) (item *CacheItem, ok bool)

+ func (c *LRUCache) Remove(key string)

+ func (c *LRUCache) Size() int64

+ func (c *LRUCache) UpdateExpiration(key string, expireAt int64) bool

+ type LRUCacheCollector struct

+ func NewLRUCacheCollector() *LRUCacheCollector

+ func (collector *LRUCacheCollector) AddCache(cache Cache)

+ func (collector *LRUCacheCollector) Collect(ch chan<- prometheus.Metric)

+ func (collector *LRUCacheCollector) Describe(ch chan<- *prometheus.Desc)

+ type LeakyBucketItem struct

+ Burst int64

+ Duration int64

+ Limit int64

+ Remaining float64

+ UpdatedAt int64

+ type Loader interface

+ Load func() (chan *CacheItem, error)

+ Save func(chan *CacheItem) error

+ type LogLevelJSON struct

+ Level logrus.Level

+ func (ll *LogLevelJSON) UnmarshalJSON(b []byte) error

+ func (ll LogLevelJSON) MarshalJSON() ([]byte, error)

+ func (ll LogLevelJSON) String() string

+ type MemberListPool struct

+ func NewMemberListPool(ctx context.Context, conf MemberListPoolConfig) (*MemberListPool, error)

+ func (m *MemberListPool) Close()

+ type MemberListPoolConfig struct

+ Advertise PeerInfo

+ AdvertiseAddress string

+ KnownNodes []string

+ Logger FieldLogger

+ MemberListAddress string

+ NodeName string

+ OnUpdate UpdateFunc

+ type MetadataCarrier struct

+ Map map[string]string

+ func (c MetadataCarrier) Get(key string) string

+ func (c MetadataCarrier) Keys() []string

+ func (c MetadataCarrier) Set(key, value string)

+ type MetricFlags int64

+ const FlagGolangMetrics

+ const FlagOSMetrics

+ func (f *MetricFlags) Has(flag MetricFlags) bool

+ func (f *MetricFlags) Set(flag MetricFlags, set bool)

+ type MockLoader struct

+ CacheItems []*CacheItem

+ Called map[string]int

+ func NewMockLoader() *MockLoader

+ func (ml *MockLoader) Load() (chan *CacheItem, error)

+ func (ml *MockLoader) Save(in chan *CacheItem) error

+ type MockStore struct

+ CacheItems map[string]*CacheItem

+ Called map[string]int

+ func NewMockStore() *MockStore

+ func (ms *MockStore) Get(ctx context.Context, r *RateLimitReq) (*CacheItem, bool)

+ func (ms *MockStore) OnChange(ctx context.Context, r *RateLimitReq, item *CacheItem)

+ func (ms *MockStore) Remove(ctx context.Context, key string)

+ type PeerClient struct

+ func NewPeerClient(conf PeerConfig) *PeerClient

+ func (c *PeerClient) GetLastErr() []string

+ func (c *PeerClient) GetPeerRateLimit(ctx context.Context, r *RateLimitReq) (resp *RateLimitResp, err error)

+ func (c *PeerClient) GetPeerRateLimits(ctx context.Context, r *GetPeerRateLimitsReq) (resp *GetPeerRateLimitsResp, err error)

+ func (c *PeerClient) Info() PeerInfo

+ func (c *PeerClient) Shutdown(ctx context.Context) error

+ func (c *PeerClient) UpdatePeerGlobals(ctx context.Context, r *UpdatePeerGlobalsReq) (resp *UpdatePeerGlobalsResp, err error)

+ type PeerConfig struct

+ Behavior BehaviorConfig

+ Info PeerInfo

+ Log FieldLogger

+ TLS *tls.Config

+ TraceGRPC bool

+ type PeerErr struct

+ func (p *PeerErr) Cause() error

+ func (p *PeerErr) Error() string

+ func (p *PeerErr) NotReady() bool

+ type PeerInfo struct

+ DataCenter string

+ GRPCAddress string

+ HTTPAddress string

+ IsOwner bool

+ func RandomPeer(peers []PeerInfo) PeerInfo

+ func (p PeerInfo) HashKey() string

+ type PeerPicker interface

+ Add func(*PeerClient)

+ Get func(string) (*PeerClient, error)

+ GetByPeerInfo func(PeerInfo) *PeerClient

+ New func() PeerPicker

+ Peers func() []*PeerClient

+ type PeersV1Client interface

+ GetPeerRateLimits func(ctx context.Context, in *GetPeerRateLimitsReq, opts ...grpc.CallOption) (*GetPeerRateLimitsResp, error)

+ UpdatePeerGlobals func(ctx context.Context, in *UpdatePeerGlobalsReq, opts ...grpc.CallOption) (*UpdatePeerGlobalsResp, error)

+ func NewPeersV1Client(cc grpc.ClientConnInterface) PeersV1Client

+ type PeersV1Server interface

+ GetPeerRateLimits func(context.Context, *GetPeerRateLimitsReq) (*GetPeerRateLimitsResp, error)

+ UpdatePeerGlobals func(context.Context, *UpdatePeerGlobalsReq) (*UpdatePeerGlobalsResp, error)

+ type PoolInterface interface

+ Close func()

+ type RateLimitReq struct

+ Algorithm Algorithm

+ Behavior Behavior

+ Burst int64

+ Duration int64

+ Hits int64

+ Limit int64

+ Metadata map[string]string

+ Name string

+ UniqueKey string

+ func (*RateLimitReq) Descriptor() ([]byte, []int)

+ func (*RateLimitReq) ProtoMessage()

+ func (m *RateLimitReq) HashKey() string

+ func (x *RateLimitReq) GetAlgorithm() Algorithm

+ func (x *RateLimitReq) GetBehavior() Behavior

+ func (x *RateLimitReq) GetBurst() int64

+ func (x *RateLimitReq) GetDuration() int64

+ func (x *RateLimitReq) GetHits() int64

+ func (x *RateLimitReq) GetLimit() int64

+ func (x *RateLimitReq) GetMetadata() map[string]string

+ func (x *RateLimitReq) GetName() string

+ func (x *RateLimitReq) GetUniqueKey() string

+ func (x *RateLimitReq) ProtoReflect() protoreflect.Message

+ func (x *RateLimitReq) Reset()

+ func (x *RateLimitReq) String() string

+ type RateLimitResp struct

+ Error string

+ Limit int64

+ Metadata map[string]string

+ Remaining int64

+ ResetTime int64

+ Status Status

+ func (*RateLimitResp) Descriptor() ([]byte, []int)

+ func (*RateLimitResp) ProtoMessage()

+ func (x *RateLimitResp) GetError() string

+ func (x *RateLimitResp) GetLimit() int64

+ func (x *RateLimitResp) GetMetadata() map[string]string

+ func (x *RateLimitResp) GetRemaining() int64

+ func (x *RateLimitResp) GetResetTime() int64

+ func (x *RateLimitResp) GetStatus() Status

+ func (x *RateLimitResp) ProtoReflect() protoreflect.Message

+ func (x *RateLimitResp) Reset()

+ func (x *RateLimitResp) String() string

+ type RegionPeerPicker interface

+ Add func(*PeerClient)

+ GetByPeerInfo func(PeerInfo) *PeerClient

+ GetClients func(string) ([]*PeerClient, error)

+ New func() RegionPeerPicker

+ Peers func() []*PeerClient

+ Pickers func() map[string]PeerPicker

+ type RegionPicker struct

+ func NewRegionPicker(fn HashString64) *RegionPicker

+ func (rp *RegionPicker) Add(peer *PeerClient)

+ func (rp *RegionPicker) GetByPeerInfo(info PeerInfo) *PeerClient

+ func (rp *RegionPicker) GetClients(key string) ([]*PeerClient, error)

+ func (rp *RegionPicker) New() RegionPeerPicker

+ func (rp *RegionPicker) Peers() []*PeerClient

+ func (rp *RegionPicker) Pickers() map[string]PeerPicker

+ type ReplicatedConsistentHash struct

+ func NewReplicatedConsistentHash(fn HashString64, replicas int) *ReplicatedConsistentHash

+ func (ch *ReplicatedConsistentHash) Add(peer *PeerClient)

+ func (ch *ReplicatedConsistentHash) Get(key string) (*PeerClient, error)

+ func (ch *ReplicatedConsistentHash) GetByPeerInfo(peer PeerInfo) *PeerClient

+ func (ch *ReplicatedConsistentHash) New() PeerPicker

+ func (ch *ReplicatedConsistentHash) Peers() []*PeerClient

+ func (ch *ReplicatedConsistentHash) Size() int

+ type Status int32

+ const Status_OVER_LIMIT

+ const Status_UNDER_LIMIT

+ func (Status) Descriptor() protoreflect.EnumDescriptor

+ func (Status) EnumDescriptor() ([]byte, []int)

+ func (Status) Type() protoreflect.EnumType

+ func (x Status) Enum() *Status

+ func (x Status) Number() protoreflect.EnumNumber

+ func (x Status) String() string

+ type Store interface

+ Get func(ctx context.Context, r *RateLimitReq) (*CacheItem, bool)

+ OnChange func(ctx context.Context, r *RateLimitReq, item *CacheItem)

+ Remove func(ctx context.Context, key string)

+ type TLSConfig struct

+ AutoTLS bool

+ CaFile string

+ CaKeyFile string

+ CaKeyPEM *bytes.Buffer

+ CaPEM *bytes.Buffer

+ CertFile string

+ CertPEM *bytes.Buffer

+ ClientAuth tls.ClientAuthType

+ ClientAuthCaFile string

+ ClientAuthCaPEM *bytes.Buffer

+ ClientAuthCertFile string

+ ClientAuthCertPEM *bytes.Buffer

+ ClientAuthKeyFile string

+ ClientAuthKeyPEM *bytes.Buffer

+ ClientAuthServerName string

+ ClientTLS *tls.Config

+ InsecureSkipVerify bool

+ KeyFile string

+ KeyPEM *bytes.Buffer

+ Logger FieldLogger

+ MinVersion uint16

+ ServerTLS *tls.Config

+ type TokenBucketItem struct

+ CreatedAt int64

+ Duration int64

+ Limit int64

+ Remaining int64

+ Status Status

+ type UnimplementedPeersV1Server struct

+ func (UnimplementedPeersV1Server) GetPeerRateLimits(context.Context, *GetPeerRateLimitsReq) (*GetPeerRateLimitsResp, error)

+ func (UnimplementedPeersV1Server) UpdatePeerGlobals(context.Context, *UpdatePeerGlobalsReq) (*UpdatePeerGlobalsResp, error)

+ type UnimplementedV1Server struct

+ func (UnimplementedV1Server) GetRateLimits(context.Context, *GetRateLimitsReq) (*GetRateLimitsResp, error)

+ func (UnimplementedV1Server) HealthCheck(context.Context, *HealthCheckReq) (*HealthCheckResp, error)

+ type UnsafePeersV1Server interface

+ type UnsafeV1Server interface

+ type UpdateFunc func([]PeerInfo)

+ type UpdatePeerGlobal struct

+ Algorithm Algorithm

+ Key string

+ Status *RateLimitResp

+ func (*UpdatePeerGlobal) Descriptor() ([]byte, []int)

+ func (*UpdatePeerGlobal) ProtoMessage()

+ func (x *UpdatePeerGlobal) GetAlgorithm() Algorithm

+ func (x *UpdatePeerGlobal) GetKey() string

+ func (x *UpdatePeerGlobal) GetStatus() *RateLimitResp

+ func (x *UpdatePeerGlobal) ProtoReflect() protoreflect.Message

+ func (x *UpdatePeerGlobal) Reset()

+ func (x *UpdatePeerGlobal) String() string

+ type UpdatePeerGlobalsReq struct

+ Globals []*UpdatePeerGlobal

+ func (*UpdatePeerGlobalsReq) Descriptor() ([]byte, []int)

+ func (*UpdatePeerGlobalsReq) ProtoMessage()

+ func (x *UpdatePeerGlobalsReq) GetGlobals() []*UpdatePeerGlobal

+ func (x *UpdatePeerGlobalsReq) ProtoReflect() protoreflect.Message

+ func (x *UpdatePeerGlobalsReq) Reset()

+ func (x *UpdatePeerGlobalsReq) String() string

+ type UpdatePeerGlobalsResp struct

+ func (*UpdatePeerGlobalsResp) Descriptor() ([]byte, []int)

+ func (*UpdatePeerGlobalsResp) ProtoMessage()

+ func (x *UpdatePeerGlobalsResp) ProtoReflect() protoreflect.Message

+ func (x *UpdatePeerGlobalsResp) Reset()

+ func (x *UpdatePeerGlobalsResp) String() string

+ type V1Client interface

+ GetRateLimits func(ctx context.Context, in *GetRateLimitsReq, opts ...grpc.CallOption) (*GetRateLimitsResp, error)

+ HealthCheck func(ctx context.Context, in *HealthCheckReq, opts ...grpc.CallOption) (*HealthCheckResp, error)

+ func DialV1Server(server string, tls *tls.Config) (V1Client, error)

+ func NewV1Client(cc grpc.ClientConnInterface) V1Client

+ type V1Instance struct

+ func NewV1Instance(conf Config) (s *V1Instance, err error)

+ func (s *V1Instance) Close() (err error)

+ func (s *V1Instance) Collect(ch chan<- prometheus.Metric)

+ func (s *V1Instance) Describe(ch chan<- *prometheus.Desc)

+ func (s *V1Instance) GetPeer(ctx context.Context, key string) (p *PeerClient, err error)

+ func (s *V1Instance) GetPeerList() []*PeerClient

+ func (s *V1Instance) GetPeerRateLimits(ctx context.Context, r *GetPeerRateLimitsReq) (resp *GetPeerRateLimitsResp, err error)

+ func (s *V1Instance) GetRateLimits(ctx context.Context, r *GetRateLimitsReq) (*GetRateLimitsResp, error)

+ func (s *V1Instance) GetRegionPickers() map[string]PeerPicker

+ func (s *V1Instance) HealthCheck(ctx context.Context, r *HealthCheckReq) (health *HealthCheckResp, err error)

+ func (s *V1Instance) SetPeers(peerInfo []PeerInfo)

+ func (s *V1Instance) UpdatePeerGlobals(ctx context.Context, r *UpdatePeerGlobalsReq) (*UpdatePeerGlobalsResp, error)

+ type V1Server interface

+ GetRateLimits func(context.Context, *GetRateLimitsReq) (*GetRateLimitsResp, error)

+ HealthCheck func(context.Context, *HealthCheckReq) (*HealthCheckResp, error)

+ type WatchMechanism string

+ const WatchEndpoints

+ const WatchPods

+ func WatchMechanismFromString(mechanism string) (WatchMechanism, error)

+ type Worker struct

+ type WorkerPool struct

+ func NewWorkerPool(conf *Config) *WorkerPool

+ func (p *WorkerPool) AddCacheItem(ctx context.Context, key string, item *CacheItem) (err error)

+ func (p *WorkerPool) Close() error

+ func (p *WorkerPool) GetCacheItem(ctx context.Context, key string) (item *CacheItem, found bool, err error)

+ func (p *WorkerPool) GetRateLimit(ctx context.Context, rlRequest *RateLimitReq) (retval *RateLimitResp, reterr error)

+ func (p *WorkerPool) Load(ctx context.Context) (err error)

+ func (p *WorkerPool) Store(ctx context.Context) (err error)