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) _map.MapServiceServer
- type ProxyRegistry
- type ProxyServer
- func (s *ProxyServer) Clear(ctx context.Context, request *_map.ClearRequest) (*_map.ClearResponse, error)
- func (s *ProxyServer) Entries(request *_map.EntriesRequest, srv _map.MapService_EntriesServer) error
- func (s *ProxyServer) Events(request *_map.EventsRequest, srv _map.MapService_EventsServer) error
- func (s *ProxyServer) Get(ctx context.Context, request *_map.GetRequest) (*_map.GetResponse, error)
- func (s *ProxyServer) Put(ctx context.Context, request *_map.PutRequest) (*_map.PutResponse, error)
- func (s *ProxyServer) Remove(ctx context.Context, request *_map.RemoveRequest) (*_map.RemoveResponse, error)
- func (s *ProxyServer) Size(ctx context.Context, request *_map.SizeRequest) (*_map.SizeResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewProxyServer ¶
func NewProxyServer(registry *ProxyRegistry, env env.DriverEnv) _map.MapServiceServer
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 _map.MapServiceServer) error
func (*ProxyRegistry) GetProxy ¶
func (r *ProxyRegistry) GetProxy(id primitiveapi.PrimitiveId) (_map.MapServiceServer, error)
func (*ProxyRegistry) RemoveProxy ¶
func (r *ProxyRegistry) RemoveProxy(id primitiveapi.PrimitiveId) error
type ProxyServer ¶
type ProxyServer struct {
// contains filtered or unexported fields
}
func (*ProxyServer) Clear ¶
func (s *ProxyServer) Clear(ctx context.Context, request *_map.ClearRequest) (*_map.ClearResponse, error)
func (*ProxyServer) Entries ¶
func (s *ProxyServer) Entries(request *_map.EntriesRequest, srv _map.MapService_EntriesServer) error
func (*ProxyServer) Events ¶
func (s *ProxyServer) Events(request *_map.EventsRequest, srv _map.MapService_EventsServer) error
func (*ProxyServer) Get ¶
func (s *ProxyServer) Get(ctx context.Context, request *_map.GetRequest) (*_map.GetResponse, error)
func (*ProxyServer) Put ¶
func (s *ProxyServer) Put(ctx context.Context, request *_map.PutRequest) (*_map.PutResponse, error)
func (*ProxyServer) Remove ¶
func (s *ProxyServer) Remove(ctx context.Context, request *_map.RemoveRequest) (*_map.RemoveResponse, error)
func (*ProxyServer) Size ¶
func (s *ProxyServer) Size(ctx context.Context, request *_map.SizeRequest) (*_map.SizeResponse, error)
Click to show internal directories.
Click to hide internal directories.