Documentation
¶
Index ¶
- func Module() fx.Option
- func Register(handler *DistCacheService, server *grpc.Server, healthsrv *health.Server) error
- type DistCache
- type DistCacheConstructor
- type DistCacheConstructorIn
- type DistCacheMetrics
- type DistCacheService
- type OlricLogWriter
- type ServiceDiscovery
- func (s *ServiceDiscovery) Close() error
- func (s *ServiceDiscovery) Deregister() error
- func (s *ServiceDiscovery) DiscoverPeers() ([]string, error)
- func (s *ServiceDiscovery) Initialize() error
- func (s *ServiceDiscovery) Register() error
- func (s *ServiceDiscovery) SetConfig(cfg map[string]interface{}) error
- func (s *ServiceDiscovery) SetLogger(l *log.Logger)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type DistCache ¶
type DistCache struct { sync.Mutex Config *olricconfig.Config Olric *olric.Olric Metrics *DistCacheMetrics }
DistCache is a peer to peer distributed cache.
func (*DistCache) AddDMapCustomConfig ¶
func (dc *DistCache) AddDMapCustomConfig(name string, dmapConfig olricconfig.DMap)
AddDMapCustomConfig adds a named DMap config into DistCache's config. If a custom config with the name does not exist, it is added. If it already exists, it is overwritten.
func (*DistCache) RemoveDMapCustomConfig ¶
RemoveDMapCustomConfig removes a named DMap config from DistCache's config.
type DistCacheConstructor ¶
type DistCacheConstructor struct { ConfigKey string DefaultConfig distcacheconfig.DistCacheConfig }
DistCacheConstructor holds fields to create an instance of DistCache.
func (DistCacheConstructor) ProvideDistCache ¶
func (constructor DistCacheConstructor) ProvideDistCache(in DistCacheConstructorIn) (*DistCache, error)
ProvideDistCache creates a new instance of distributed cache. It also hooks in the service discovery plugin.
type DistCacheConstructorIn ¶
type DistCacheConstructorIn struct { fx.In PeerDiscovery *peers.PeerDiscovery PrometheusRegistry *prometheus.Registry LivenessMultiJob *jobs.MultiJob `name:"liveness.service"` Unmarshaller config.Unmarshaller Lifecycle fx.Lifecycle Shutdowner fx.Shutdowner Logger *log.Logger }
DistCacheConstructorIn holds parameters of ProvideDistCache.
type DistCacheMetrics ¶
type DistCacheMetrics struct { EntriesTotal *prometheus.GaugeVec DeleteHits *prometheus.GaugeVec DeleteMisses *prometheus.GaugeVec GetMisses *prometheus.GaugeVec GetHits *prometheus.GaugeVec EvictedTotal *prometheus.GaugeVec }
DistCacheMetrics holds metrics from DistCache, Olric, DMap statistics.
type DistCacheService ¶
type DistCacheService struct { distcachev1.UnimplementedDistCacheServiceServer Olric *olric.Olric }
DistCacheService implements distcache.v1 service.
func RegisterDistCacheService ¶
func RegisterDistCacheService(distcahce *DistCache) *DistCacheService
RegisterDistCacheService returns a new Handler.
func (*DistCacheService) GetStats ¶
func (svc *DistCacheService) GetStats(ctx context.Context, _ *emptypb.Empty) (*distcachev1.Stats, error)
GetStats returns stats of the current Olric member.
type OlricLogWriter ¶
OlricLogWriter is wrapper around aperture Logger that parse the message before writing to olricConfig.LogOutput.
type ServiceDiscovery ¶
type ServiceDiscovery struct {
// contains filtered or unexported fields
}
ServiceDiscovery holds fields needed to implement Olric's Service Discovery interface.
func (*ServiceDiscovery) Close ¶
func (s *ServiceDiscovery) Close() error
Close stops underlying goroutines, if there is any. It should be a blocking call. This method is not implemented.
func (*ServiceDiscovery) Deregister ¶
func (s *ServiceDiscovery) Deregister() error
Deregister removes this node from a service discovery directory. This method is not implemented.
func (*ServiceDiscovery) DiscoverPeers ¶
func (s *ServiceDiscovery) DiscoverPeers() ([]string, error)
DiscoverPeers returns a list of known Olric nodes.
func (*ServiceDiscovery) Initialize ¶
func (s *ServiceDiscovery) Initialize() error
Initialize initializes the plugin: registers some internal data structures, clients etc. This method is not implemented.
func (*ServiceDiscovery) Register ¶
func (s *ServiceDiscovery) Register() error
Register registers this node to a service discovery directory. This method is not implemented.
func (*ServiceDiscovery) SetConfig ¶
func (s *ServiceDiscovery) SetConfig(cfg map[string]interface{}) error
SetConfig registers plugin configuration. This method is not implemented.
func (*ServiceDiscovery) SetLogger ¶
func (s *ServiceDiscovery) SetLogger(l *log.Logger)
SetLogger sets an appropriate logger. This method is not implemented.