server

Documentation

Index

• type CommandServer
  • func NewCommandServer() *CommandServer
  • func (s *CommandServer) Echo(ctx context.Context, in *api.EchoRequest) (*api.EchoResponse, error)
  • func (s *CommandServer) Get(ctx context.Context, in *api.GetRequest) (*api.GetResponse, error)
  • func (s *CommandServer) Set(ctx context.Context, in *api.SetRequest) (*emptypb.Empty, error)
• type Option
  • func WithLogger(logger *slog.Logger) Option
  • func WithPort(port string) Option
  • func WithScheduler(scheduler schedule.CronjobRepository) Option
  • func WithTTLCleanupTime(ttlCleanupTime int64) Option
• type Server
  • func New(options ...Option) *Server
  • func (s *Server) Start()

Types

type CommandServer

type CommandServer struct {
	api.UnimplementedCommandsServer
}

func NewCommandServer

func NewCommandServer() *CommandServer

func (*CommandServer) Echo

func (s *CommandServer) Echo(ctx context.Context, in *api.EchoRequest) (*api.EchoResponse, error)

func (*CommandServer) Get

func (s *CommandServer) Get(ctx context.Context, in *api.GetRequest) (*api.GetResponse, error)

func (*CommandServer) Set

func (s *CommandServer) Set(ctx context.Context, in *api.SetRequest) (*emptypb.Empty, error)

type Option

type Option func(*Server)

func WithLogger

func WithLogger(logger *slog.Logger) Option

func WithPort

func WithPort(port string) Option

func WithScheduler

func WithScheduler(scheduler schedule.CronjobRepository) Option

func WithTTLCleanupTime

func WithTTLCleanupTime(ttlCleanupTime int64) Option

type Server

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

func New

func New(options ...Option) *Server

func (*Server) Start

func (s *Server) Start()