list

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) list.ListServiceServer
• type ProxyRegistry
  • func NewProxyRegistry() *ProxyRegistry
  • func (r *ProxyRegistry) AddProxy(id primitiveapi.PrimitiveId, server list.ListServiceServer) error
  • func (r *ProxyRegistry) GetProxy(id primitiveapi.PrimitiveId) (list.ListServiceServer, error)
  • func (r *ProxyRegistry) RemoveProxy(id primitiveapi.PrimitiveId) error
• type ProxyServer
  • func (s *ProxyServer) Append(ctx context.Context, request *list.AppendRequest) (*list.AppendResponse, error)
  • func (s *ProxyServer) Clear(ctx context.Context, request *list.ClearRequest) (*list.ClearResponse, error)
  • func (s *ProxyServer) Elements(request *list.ElementsRequest, srv list.ListService_ElementsServer) error
  • func (s *ProxyServer) Events(request *list.EventsRequest, srv list.ListService_EventsServer) error
  • func (s *ProxyServer) Get(ctx context.Context, request *list.GetRequest) (*list.GetResponse, error)
  • func (s *ProxyServer) Insert(ctx context.Context, request *list.InsertRequest) (*list.InsertResponse, error)
  • func (s *ProxyServer) Remove(ctx context.Context, request *list.RemoveRequest) (*list.RemoveResponse, error)
  • func (s *ProxyServer) Set(ctx context.Context, request *list.SetRequest) (*list.SetResponse, error)
  • func (s *ProxyServer) Size(ctx context.Context, request *list.SizeRequest) (*list.SizeResponse, error)

Functions

func NewProxyServer

func NewProxyServer(registry *ProxyRegistry, env env.DriverEnv) list.ListServiceServer

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 list.ListServiceServer) error

func (*ProxyRegistry) GetProxy

func (r *ProxyRegistry) GetProxy(id primitiveapi.PrimitiveId) (list.ListServiceServer, error)

func (*ProxyRegistry) RemoveProxy

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

type ProxyServer

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

func (*ProxyServer) Append

func (s *ProxyServer) Append(ctx context.Context, request *list.AppendRequest) (*list.AppendResponse, error)

func (*ProxyServer) Clear

func (s *ProxyServer) Clear(ctx context.Context, request *list.ClearRequest) (*list.ClearResponse, error)

func (*ProxyServer) Elements

func (s *ProxyServer) Elements(request *list.ElementsRequest, srv list.ListService_ElementsServer) error

func (*ProxyServer) Events

func (s *ProxyServer) Events(request *list.EventsRequest, srv list.ListService_EventsServer) error

func (*ProxyServer) Get

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

func (*ProxyServer) Insert

func (s *ProxyServer) Insert(ctx context.Context, request *list.InsertRequest) (*list.InsertResponse, error)

func (*ProxyServer) Remove

func (s *ProxyServer) Remove(ctx context.Context, request *list.RemoveRequest) (*list.RemoveResponse, error)

func (*ProxyServer) Set

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

func (*ProxyServer) Size

func (s *ProxyServer) Size(ctx context.Context, request *list.SizeRequest) (*list.SizeResponse, error)