counter

Documentation

Overview

Code generated by atomix-go-framework. DO NOT EDIT.

Code generated by atomix-go-framework. DO NOT EDIT.

Index

• func NewProxyServer(registry *ProxyRegistry, env env.DriverEnv) counter.CounterServiceServer
• type ProxyRegistry
  • func NewProxyRegistry() *ProxyRegistry
  • func (r *ProxyRegistry) AddProxy(id primitiveapi.PrimitiveId, server counter.CounterServiceServer) error
  • func (r *ProxyRegistry) GetProxy(id primitiveapi.PrimitiveId) (counter.CounterServiceServer, error)
  • func (r *ProxyRegistry) RemoveProxy(id primitiveapi.PrimitiveId) error
• type ProxyServer
  • func (s *ProxyServer) Decrement(ctx context.Context, request *counter.DecrementRequest) (*counter.DecrementResponse, error)
  • func (s *ProxyServer) Get(ctx context.Context, request *counter.GetRequest) (*counter.GetResponse, error)
  • func (s *ProxyServer) Increment(ctx context.Context, request *counter.IncrementRequest) (*counter.IncrementResponse, error)
  • func (s *ProxyServer) Set(ctx context.Context, request *counter.SetRequest) (*counter.SetResponse, error)

Functions

func NewProxyServer

func NewProxyServer(registry *ProxyRegistry, env env.DriverEnv) counter.CounterServiceServer

NewProxyServer creates a new ProxyServer

Types

type ProxyRegistry

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

func NewProxyRegistry

func NewProxyRegistry() *ProxyRegistry

NewProxyRegistry creates a new ProxyRegistry

func (*ProxyRegistry) AddProxy

func (r *ProxyRegistry) AddProxy(id primitiveapi.PrimitiveId, server counter.CounterServiceServer) error

func (*ProxyRegistry) GetProxy

func (r *ProxyRegistry) GetProxy(id primitiveapi.PrimitiveId) (counter.CounterServiceServer, error)

func (*ProxyRegistry) RemoveProxy

func (r *ProxyRegistry) RemoveProxy(id primitiveapi.PrimitiveId) error

type ProxyServer

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

func (*ProxyServer) Decrement

func (s *ProxyServer) Decrement(ctx context.Context, request *counter.DecrementRequest) (*counter.DecrementResponse, error)

func (*ProxyServer) Get

func (s *ProxyServer) Get(ctx context.Context, request *counter.GetRequest) (*counter.GetResponse, error)

func (*ProxyServer) Increment

func (s *ProxyServer) Increment(ctx context.Context, request *counter.IncrementRequest) (*counter.IncrementResponse, error)

func (*ProxyServer) Set

func (s *ProxyServer) Set(ctx context.Context, request *counter.SetRequest) (*counter.SetResponse, error)