gubernator

package module

Go to main page

Versions in this module

v1

v1.0.0-rc.9

Apr 22, 2021

v1.0.0-rc.8

Mar 16, 2021

v1.0.0-rc.7

Mar 10, 2021

v1.0.0-rc.5

Jan 13, 2021

v1.0.0-rc.4

Dec 19, 2020

v1.0.0-rc.3

Nov 11, 2020

v1.0.0-rc.2

Nov 5, 2020

v1.0.0-rc.1

Oct 28, 2020

v0

v0.9.2

Oct 23, 2020

v0.9.1

Oct 19, 2020

v0.9.0

Oct 13, 2020

Changes in this version

+ const DefaultReplicas

+ func IsNotReady(err error) bool

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

type Behavior

+ const Behavior_MULTI_REGION

type BehaviorConfig

+ MultiRegionBatchLimit int

+ MultiRegionSyncWait time.Duration

+ MultiRegionTimeout time.Duration

type Config

+ DataCenter string

+ LocalPicker PeerPicker

+ RegionPicker RegionPeerPicker

type ConsistantHash

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

type GetPeerRateLimitsReq

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *GetPeerRateLimitsReq) XXX_DiscardUnknown()

+ func (m *GetPeerRateLimitsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetPeerRateLimitsReq) XXX_Merge(src proto.Message)

+ func (m *GetPeerRateLimitsReq) XXX_Size() int

+ func (m *GetPeerRateLimitsReq) XXX_Unmarshal(b []byte) error

type GetPeerRateLimitsResp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *GetPeerRateLimitsResp) XXX_DiscardUnknown()

+ func (m *GetPeerRateLimitsResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetPeerRateLimitsResp) XXX_Merge(src proto.Message)

+ func (m *GetPeerRateLimitsResp) XXX_Size() int

+ func (m *GetPeerRateLimitsResp) XXX_Unmarshal(b []byte) error

type GetRateLimitsReq

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *GetRateLimitsReq) XXX_DiscardUnknown()

+ func (m *GetRateLimitsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetRateLimitsReq) XXX_Merge(src proto.Message)

+ func (m *GetRateLimitsReq) XXX_Size() int

+ func (m *GetRateLimitsReq) XXX_Unmarshal(b []byte) error

type GetRateLimitsResp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *GetRateLimitsResp) XXX_DiscardUnknown()

+ func (m *GetRateLimitsResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetRateLimitsResp) XXX_Merge(src proto.Message)

+ func (m *GetRateLimitsResp) XXX_Size() int

+ func (m *GetRateLimitsResp) XXX_Unmarshal(b []byte) error

+ type HashFunc64 func(data []byte) uint64

+ var DefaultHash64 HashFunc64 = fnv1.HashBytes64

type HealthCheckReq

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *HealthCheckReq) XXX_DiscardUnknown()

+ func (m *HealthCheckReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *HealthCheckReq) XXX_Merge(src proto.Message)

+ func (m *HealthCheckReq) XXX_Size() int

+ func (m *HealthCheckReq) XXX_Unmarshal(b []byte) error

type HealthCheckResp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *HealthCheckResp) XXX_DiscardUnknown()

+ func (m *HealthCheckResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *HealthCheckResp) XXX_Merge(src proto.Message)

+ func (m *HealthCheckResp) XXX_Size() int

+ func (m *HealthCheckResp) XXX_Unmarshal(b []byte) error

type Instance

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

+ type MemberlistPool struct

+ func NewMemberlistPool(conf MemberlistPoolConfig) (*MemberlistPool, error)

+ func (m *MemberlistPool) Close()

+ type MemberlistPoolConfig struct

+ AdvertiseAddress string

+ AdvertisePort int

+ DataCenter string

+ Enabled bool

+ GubernatorPort int

+ KnownNodes []string

+ Logger *l.Logger

+ LoggerOutput io.Writer

+ NodeName string

+ OnUpdate UpdateFunc

type PeerClient

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

+ type PeerErr struct

+ func (p *PeerErr) Cause() error

+ func (p *PeerErr) Error() string

+ func (p *PeerErr) NotReady() bool

type PeerInfo

+ DataCenter string

+ func (p PeerInfo) HashKey() string

type PeerPicker

+ GetByPeerInfo func(PeerInfo) *PeerClient

type RateLimitReq

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *RateLimitReq) XXX_DiscardUnknown()

+ func (m *RateLimitReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RateLimitReq) XXX_Merge(src proto.Message)

+ func (m *RateLimitReq) XXX_Size() int

+ func (m *RateLimitReq) XXX_Unmarshal(b []byte) error

type RateLimitResp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *RateLimitResp) XXX_DiscardUnknown()

+ func (m *RateLimitResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RateLimitResp) XXX_Merge(src proto.Message)

+ func (m *RateLimitResp) XXX_Size() int

+ func (m *RateLimitResp) XXX_Unmarshal(b []byte) error

+ 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 HashFunc) *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 ReplicatedConsistantHash struct

+ func NewReplicatedConsistantHash(fn HashFunc64, replicas int) *ReplicatedConsistantHash

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

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

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

+ func (ch *ReplicatedConsistantHash) New() PeerPicker

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

+ func (ch *ReplicatedConsistantHash) Size() int

+ type UnimplementedPeersV1Server struct

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

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

+ type UnimplementedV1Server struct

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

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

type UpdatePeerGlobal

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *UpdatePeerGlobal) XXX_DiscardUnknown()

+ func (m *UpdatePeerGlobal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *UpdatePeerGlobal) XXX_Merge(src proto.Message)

+ func (m *UpdatePeerGlobal) XXX_Size() int

+ func (m *UpdatePeerGlobal) XXX_Unmarshal(b []byte) error

type UpdatePeerGlobalsReq

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *UpdatePeerGlobalsReq) XXX_DiscardUnknown()

+ func (m *UpdatePeerGlobalsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *UpdatePeerGlobalsReq) XXX_Merge(src proto.Message)

+ func (m *UpdatePeerGlobalsReq) XXX_Size() int

+ func (m *UpdatePeerGlobalsReq) XXX_Unmarshal(b []byte) error

type UpdatePeerGlobalsResp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *UpdatePeerGlobalsResp) XXX_DiscardUnknown()

+ func (m *UpdatePeerGlobalsResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *UpdatePeerGlobalsResp) XXX_Merge(src proto.Message)

+ func (m *UpdatePeerGlobalsResp) XXX_Size() int

+ func (m *UpdatePeerGlobalsResp) XXX_Unmarshal(b []byte) error

v0.8.3

May 11, 2020

v0.8.2

May 6, 2020

v0.8.1

Apr 16, 2020

v0.8.0

Jan 7, 2020

Changes in this version

+ func HasBehavior(b Behavior, flag Behavior) bool

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

type Behavior

+ const Behavior_RESET_REMAINING

type CacheItem

+ InvalidAt int64

type LeakyBucketItem

+ UpdatedAt int64

+ type TokenBucketItem struct

+ CreatedAt int64

+ Duration int64

+ Limit int64

+ Remaining int64

+ Status Status

v0.7.1

Dec 10, 2019

Changes in this version

+ const GregorianDays

+ const GregorianHours

+ const GregorianMinutes

+ const GregorianMonths

+ const GregorianWeeks

+ const GregorianYears

+ var ErrClosing = errors.New("closing")

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

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

+ func MillisecondNow() int64

type Behavior

+ const Behavior_DURATION_IS_GREGORIAN

+ type Cache interface

+ Add func(*CacheItem) bool

+ Each func() chan *CacheItem

+ GetItem func(key interface{}) (value *CacheItem, ok bool)

+ Lock func()

+ Remove func(key interface{})

+ Unlock func()

+ UpdateExpiration func(key interface{}, expireAt int64) bool

+ type CacheItem struct

+ Algorithm Algorithm

+ ExpireAt int64

+ Key string

+ Value interface{}

type Config

+ Loader Loader

+ Store Store

type Instance

+ func (s *Instance) Close() error

+ type LRUCache struct

+ func NewLRUCache(maxSize int) *LRUCache

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

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

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

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

+ func (c *LRUCache) GetItem(key interface{}) (item *CacheItem, ok bool)

+ func (c *LRUCache) Lock()

+ func (c *LRUCache) Remove(key interface{})

+ func (c *LRUCache) Size() int

+ func (c *LRUCache) Stats(_ bool) cachStats

+ func (c *LRUCache) Unlock()

+ func (c *LRUCache) UpdateExpiration(key interface{}, expireAt int64) bool

+ type LeakyBucketItem struct

+ Duration int64

+ Limit int64

+ Remaining int64

+ TimeStamp int64

+ type Loader interface

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

+ Save func(chan *CacheItem) error

+ 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(r *RateLimitReq) (*CacheItem, bool)

+ func (ms *MockStore) OnChange(r *RateLimitReq, item *CacheItem)

+ func (ms *MockStore) Remove(key string)

type PeerClient

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

+ type Store interface

+ Get func(r *RateLimitReq) (*CacheItem, bool)

+ OnChange func(r *RateLimitReq, item *CacheItem)

+ Remove func(key string)

type UpdatePeerGlobal

+ Algorithm Algorithm

+ func (m *UpdatePeerGlobal) GetAlgorithm() Algorithm

v0.4.1

Oct 29, 2019

Changes in this version

+ const Healthy

+ const Millisecond

+ const Minute

+ const Second

+ const UnHealthy

+ 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 Status_name = map[int32]string

+ var Status_value = map[string]int32

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

+ func FromTimeStamp(ts int64) time.Duration

+ func FromUnixMilliseconds(ts int64) time.Time

+ func NewCache(maxSize int) *cache.LRUCache

+ func RandomPeer(peers []string) string

+ func RandomString(n int) string

+ func RegisterPeersV1Server(s *grpc.Server, 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 RegisterV1Server(s *grpc.Server, srv V1Server)

+ func ToTimeStamp(duration time.Duration) int64

+ type Algorithm int32

+ const Algorithm_LEAKY_BUCKET

+ const Algorithm_TOKEN_BUCKET

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

+ func (x Algorithm) String() string

+ type Behavior int32

+ const Behavior_BATCHING

+ const Behavior_GLOBAL

+ const Behavior_NO_BATCHING

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

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

+ func NewGRPCStatsHandler() *Collector

+ func (c *Collector) Close()

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

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

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

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

+ type Config struct

+ Behaviors BehaviorConfig

+ Cache cache.Cache

+ GRPCServer *grpc.Server

+ Picker PeerPicker

+ func (c *Config) SetDefaults() error

+ type ConsistantHash struct

+ func NewConsistantHash(fn HashFunc) *ConsistantHash

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

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

+ func (ch *ConsistantHash) GetPeerByHost(host string) *PeerClient

+ func (ch *ConsistantHash) New() PeerPicker

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

+ func (ch *ConsistantHash) Size() int

+ type EtcdPool struct

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

+ func (e *EtcdPool) Close()

+ type EtcdPoolConfig struct

+ AdvertiseAddress string

+ BaseKey string

+ Client *etcd.Client

+ OnUpdate UpdateFunc

+ type GRPCStats struct

+ Duration time.Duration

+ Failed int64

+ Method string

+ Success int64

+ func StatsFromContext(ctx context.Context) *GRPCStats

+ type GetPeerRateLimitsReq struct

+ Requests []*RateLimitReq

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

+ func (*GetPeerRateLimitsReq) ProtoMessage()

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

+ func (m *GetPeerRateLimitsReq) Reset()

+ func (m *GetPeerRateLimitsReq) String() string

+ type GetPeerRateLimitsResp struct

+ RateLimits []*RateLimitResp

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

+ func (*GetPeerRateLimitsResp) ProtoMessage()

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

+ func (m *GetPeerRateLimitsResp) Reset()

+ func (m *GetPeerRateLimitsResp) String() string

+ type GetRateLimitsReq struct

+ Requests []*RateLimitReq

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

+ func (*GetRateLimitsReq) ProtoMessage()

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

+ func (m *GetRateLimitsReq) Reset()

+ func (m *GetRateLimitsReq) String() string

+ type GetRateLimitsResp struct

+ Responses []*RateLimitResp

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

+ func (*GetRateLimitsResp) ProtoMessage()

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

+ func (m *GetRateLimitsResp) Reset()

+ func (m *GetRateLimitsResp) String() string

+ type HashFunc func(data []byte) uint32

+ type HealthCheckReq struct

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

+ func (*HealthCheckReq) ProtoMessage()

+ func (m *HealthCheckReq) Reset()

+ func (m *HealthCheckReq) String() string

+ type HealthCheckResp struct

+ Message string

+ PeerCount int32

+ Status string

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

+ func (*HealthCheckResp) ProtoMessage()

+ func (m *HealthCheckResp) GetMessage() string

+ func (m *HealthCheckResp) GetPeerCount() int32

+ func (m *HealthCheckResp) GetStatus() string

+ func (m *HealthCheckResp) Reset()

+ func (m *HealthCheckResp) String() string

+ type Instance struct

+ func New(conf Config) (*Instance, error)

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

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

+ func (s *Instance) GetPeer(key string) (*PeerClient, error)

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

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

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

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

+ func (s *Instance) SetPeers(peers []PeerInfo)

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

+ type Interval struct

+ C chan struct{}

+ func NewInterval(d time.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

+ Enabled bool

+ Namespace string

+ OnUpdate UpdateFunc

+ PodIP string

+ PodPort string

+ Selector string

+ type PeerClient struct

+ func NewPeerClient(conf BehaviorConfig, host string) (*PeerClient, error)

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

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

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

+ type PeerInfo struct

+ Address string

+ IsOwner bool

+ type PeerPicker interface

+ Add func(*PeerClient)

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

+ GetPeerByHost func(host string) *PeerClient

+ New func() PeerPicker

+ Peers func() []*PeerClient

+ Size func() int

+ 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.ClientConn) 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

+ Duration int64

+ Hits int64

+ Limit int64

+ Name string

+ UniqueKey string

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

+ func (*RateLimitReq) ProtoMessage()

+ func (m *RateLimitReq) GetAlgorithm() Algorithm

+ func (m *RateLimitReq) GetBehavior() Behavior

+ func (m *RateLimitReq) GetDuration() int64

+ func (m *RateLimitReq) GetHits() int64

+ func (m *RateLimitReq) GetLimit() int64

+ func (m *RateLimitReq) GetName() string

+ func (m *RateLimitReq) GetUniqueKey() string

+ func (m *RateLimitReq) HashKey() string

+ func (m *RateLimitReq) Reset()

+ func (m *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 (m *RateLimitResp) GetError() string

+ func (m *RateLimitResp) GetLimit() int64

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

+ func (m *RateLimitResp) GetRemaining() int64

+ func (m *RateLimitResp) GetResetTime() int64

+ func (m *RateLimitResp) GetStatus() Status

+ func (m *RateLimitResp) Reset()

+ func (m *RateLimitResp) String() string

+ type Status int32

+ const Status_OVER_LIMIT

+ const Status_UNDER_LIMIT

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

+ func (x Status) String() string

+ type UpdateFunc func([]PeerInfo)

+ type UpdatePeerGlobal struct

+ Key string

+ Status *RateLimitResp

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

+ func (*UpdatePeerGlobal) ProtoMessage()

+ func (m *UpdatePeerGlobal) GetKey() string

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

+ func (m *UpdatePeerGlobal) Reset()

+ func (m *UpdatePeerGlobal) String() string

+ type UpdatePeerGlobalsReq struct

+ Globals []*UpdatePeerGlobal

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

+ func (*UpdatePeerGlobalsReq) ProtoMessage()

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

+ func (m *UpdatePeerGlobalsReq) Reset()

+ func (m *UpdatePeerGlobalsReq) String() string

+ type UpdatePeerGlobalsResp struct

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

+ func (*UpdatePeerGlobalsResp) ProtoMessage()

+ func (m *UpdatePeerGlobalsResp) Reset()

+ func (m *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) (V1Client, error)

+ func NewV1Client(cc *grpc.ClientConn) V1Client

+ type V1Server interface

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

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

Other modules containing this package

github.com/mailgun/gubernator/v2

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL