Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

gubernator

package module

Go to main page

Versions in this module

v2

v2.7.5

May 25, 2024

v2.7.4

May 20, 2024

v2.7.3

May 20, 2024

v2.7.2

May 14, 2024

v2.7.1

May 6, 2024

v2.7.0

May 2, 2024

Changes in this version

+ type MemberListEncryptionConfig struct

+ GossipVerifyIncoming bool

+ GossipVerifyOutgoing bool

+ SecretKeys []string

type MemberListPoolConfig

+ EncryptionConfig MemberListEncryptionConfig

v2.6.0

Mar 26, 2024

v2.5.0

Mar 22, 2024

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 LocalHost() string

+ func MillisecondNow() int64

+ func NewStaticBuilder() resolver.Builder

+ 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_DRAIN_OVER_LIMIT

+ 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

+ DisableBatching bool

+ ForceGlobal bool

+ GlobalBatchLimit int

+ GlobalPeerRequestsConcurrency 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{}

+ func (item *CacheItem) IsExpired() bool

+ type Config struct

+ Behaviors BehaviorConfig

+ CacheFactory func(maxSize int) Cache

+ CacheSize int

+ DataCenter string

+ GRPCServers []*grpc.Server

+ InstanceID string

+ 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

+ InstanceID string

+ PeerInfo PeerInfo

+ V1Server *V1Instance

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

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

+ func (s *Daemon) Close()

+ func (s *Daemon) Config() DaemonConfig

+ func (s *Daemon) MustClient() V1Client

+ 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 io.Reader) (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, error)

+ 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 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

+ CreatedAt *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) GetCreatedAt() 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 RateLimitReqState struct

+ IsOwner bool

+ 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

+ CreatedAt int64

+ Duration int64

+ Key string

+ Status *RateLimitResp

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

+ func (*UpdatePeerGlobal) ProtoMessage()

+ func (x *UpdatePeerGlobal) GetAlgorithm() Algorithm

+ func (x *UpdatePeerGlobal) GetCreatedAt() int64

+ func (x *UpdatePeerGlobal) GetDuration() int64

+ 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, reqState RateLimitReqState) (*RateLimitResp, error)

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

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