grpccacheserver

Documentation

Index

• type Config
• type Server
  • func New() *Server
  • func NewWithConfig(conf Config) *Server
  • func (s *Server) Add(ctx context.Context, req *grpcCache.KeyValueDurationRequest) (*emptypb.Empty, error)
  • func (s *Server) Count(ctx context.Context, req *grpcCache.CountRequest) (*grpcCache.CountResponse, error)
  • func (s *Server) Delete(ctx context.Context, req *grpcCache.KeyRequest) (*emptypb.Empty, error)
  • func (s *Server) Get(ctx context.Context, req *grpcCache.KeyRequest) (*grpcCache.GetResponse, error)
  • func (s *Server) Login(ctx context.Context, req *grpcCache.LoginRequest) (*grpcCache.LoginResponse, error)
  • func (s *Server) Replace(ctx context.Context, req *grpcCache.KeyValueDurationRequest) (*emptypb.Empty, error)
  • func (s *Server) RunServer()
  • func (s *Server) Set(ctx context.Context, req *grpcCache.KeyValueDurationRequest) (*emptypb.Empty, error)

Types

type Config

type Config struct {
	Port                   string
	DefaultCacheExpiration time.Duration
	CleanupCacheInterval   time.Duration
	TokensFile             string
}

type Server

type Server struct {
	grpcCache.CacheServiceServer
	Tokens *tokens.Tokens
	Cahce  *cache.Cache
	Port   string
}

func New

func New() *Server

func NewWithConfig

func NewWithConfig(conf Config) *Server

func (*Server) Add

func (s *Server) Add(ctx context.Context, req *grpcCache.KeyValueDurationRequest) (*emptypb.Empty, error)

func (*Server) Count

func (s *Server) Count(ctx context.Context, req *grpcCache.CountRequest) (*grpcCache.CountResponse, error)

func (*Server) Delete

func (s *Server) Delete(ctx context.Context, req *grpcCache.KeyRequest) (*emptypb.Empty, error)

func (*Server) Get

func (s *Server) Get(ctx context.Context, req *grpcCache.KeyRequest) (*grpcCache.GetResponse, error)

func (*Server) Login

func (s *Server) Login(ctx context.Context, req *grpcCache.LoginRequest) (*grpcCache.LoginResponse, error)

func (*Server) Replace

func (s *Server) Replace(ctx context.Context, req *grpcCache.KeyValueDurationRequest) (*emptypb.Empty, error)

func (*Server) RunServer

func (s *Server) RunServer()

func (*Server) Set

func (s *Server) Set(ctx context.Context, req *grpcCache.KeyValueDurationRequest) (*emptypb.Empty, error)