cacheserver

Documentation

Index

• type CacheServer
  • func (s *CacheServer) Run(stopCh <-chan struct{}) error
• type Config
  • func (cfg *Config) Complete() completedConfig
• type GRPCServer
  • func NewGRPCServer(grpcOptions *genericoptions.GRPCOptions, tlsOptions *genericoptions.TLSOptions, ...) (*GRPCServer, error)
  • func (s *GRPCServer) GracefulStop()
  • func (s *GRPCServer) RunOrDie()
• type Server

Types

type CacheServer

type CacheServer struct {
	// contains filtered or unexported fields
}

CacheServer represents the cache server.

func (*CacheServer) Run

func (s *CacheServer) Run(stopCh <-chan struct{}) error

Run run the cache server.

type Config

type Config struct {
	DisableCache  bool
	GRPCOptions   *genericoptions.GRPCOptions
	TLSOptions    *genericoptions.TLSOptions
	RedisOptions  *genericoptions.RedisOptions
	MySQLOptions  *genericoptions.MySQLOptions
	JaegerOptions *genericoptions.JaegerOptions
}

Config represents the configuration of the service.

func (*Config) Complete

func (cfg *Config) Complete() completedConfig

Complete fills in any fields not set that are required to have valid data. It's mutating the receiver.

type GRPCServer

type GRPCServer struct {
	// contains filtered or unexported fields
}

func NewGRPCServer

func NewGRPCServer(
	grpcOptions *genericoptions.GRPCOptions,
	tlsOptions *genericoptions.TLSOptions,
	srv pb.CacheServerServer,
) (*GRPCServer, error)

func (*GRPCServer) GracefulStop

func (s *GRPCServer) GracefulStop()

func (*GRPCServer) RunOrDie

func (s *GRPCServer) RunOrDie()

type Server

type Server interface {
	RunOrDie()
	GracefulStop()
}