counterservice

Documentation

Index

• func InitApi(ctx context.Context, dbProvider store.DbProvider, mux *http.ServeMux, ...) (func() error, error)
• type Server
  • func (s *Server) GetValue(ctx context.Context, req *rpc.CounterRequest) (*rpc.CounterValue, error)
  • func (s *Server) Increment(ctx context.Context, req *rpc.IncrementRequest) (*rpc.CounterValue, error)

Functions

func InitApi

func InitApi(ctx context.Context, dbProvider store.DbProvider, mux *http.ServeMux, pathPrefix string, requestsReceived chan<- struct{}) (func() error, error)

Types

type Server

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

Server implements the Counter service

func (*Server) GetValue

func (s *Server) GetValue(ctx context.Context, req *rpc.CounterRequest) (*rpc.CounterValue, error)

func (*Server) Increment

func (s *Server) Increment(ctx context.Context, req *rpc.IncrementRequest) (*rpc.CounterValue, error)