indexedmap

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) indexedmap.IndexedMapServiceServer
• type ProxyRegistry
  • func NewProxyRegistry() *ProxyRegistry
  • func (r *ProxyRegistry) AddProxy(id primitiveapi.PrimitiveId, server indexedmap.IndexedMapServiceServer) error
  • func (r *ProxyRegistry) GetProxy(id primitiveapi.PrimitiveId) (indexedmap.IndexedMapServiceServer, error)
  • func (r *ProxyRegistry) RemoveProxy(id primitiveapi.PrimitiveId) error
• type ProxyServer
  • func (s *ProxyServer) Clear(ctx context.Context, request *indexedmap.ClearRequest) (*indexedmap.ClearResponse, error)
  • func (s *ProxyServer) Entries(request *indexedmap.EntriesRequest, ...) error
  • func (s *ProxyServer) Events(request *indexedmap.EventsRequest, ...) error
  • func (s *ProxyServer) FirstEntry(ctx context.Context, request *indexedmap.FirstEntryRequest) (*indexedmap.FirstEntryResponse, error)
  • func (s *ProxyServer) Get(ctx context.Context, request *indexedmap.GetRequest) (*indexedmap.GetResponse, error)
  • func (s *ProxyServer) LastEntry(ctx context.Context, request *indexedmap.LastEntryRequest) (*indexedmap.LastEntryResponse, error)
  • func (s *ProxyServer) NextEntry(ctx context.Context, request *indexedmap.NextEntryRequest) (*indexedmap.NextEntryResponse, error)
  • func (s *ProxyServer) PrevEntry(ctx context.Context, request *indexedmap.PrevEntryRequest) (*indexedmap.PrevEntryResponse, error)
  • func (s *ProxyServer) Put(ctx context.Context, request *indexedmap.PutRequest) (*indexedmap.PutResponse, error)
  • func (s *ProxyServer) Remove(ctx context.Context, request *indexedmap.RemoveRequest) (*indexedmap.RemoveResponse, error)
  • func (s *ProxyServer) Size(ctx context.Context, request *indexedmap.SizeRequest) (*indexedmap.SizeResponse, error)

Functions

func NewProxyServer

func NewProxyServer(registry *ProxyRegistry, env env.DriverEnv) indexedmap.IndexedMapServiceServer

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 indexedmap.IndexedMapServiceServer) error

func (*ProxyRegistry) GetProxy

func (r *ProxyRegistry) GetProxy(id primitiveapi.PrimitiveId) (indexedmap.IndexedMapServiceServer, 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 *indexedmap.ClearRequest) (*indexedmap.ClearResponse, error)

func (*ProxyServer) Entries

func (s *ProxyServer) Entries(request *indexedmap.EntriesRequest, srv indexedmap.IndexedMapService_EntriesServer) error

func (*ProxyServer) Events

func (s *ProxyServer) Events(request *indexedmap.EventsRequest, srv indexedmap.IndexedMapService_EventsServer) error

func (*ProxyServer) FirstEntry

func (s *ProxyServer) FirstEntry(ctx context.Context, request *indexedmap.FirstEntryRequest) (*indexedmap.FirstEntryResponse, error)

func (*ProxyServer) Get

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

func (*ProxyServer) LastEntry

func (s *ProxyServer) LastEntry(ctx context.Context, request *indexedmap.LastEntryRequest) (*indexedmap.LastEntryResponse, error)

func (*ProxyServer) NextEntry

func (s *ProxyServer) NextEntry(ctx context.Context, request *indexedmap.NextEntryRequest) (*indexedmap.NextEntryResponse, error)

func (*ProxyServer) PrevEntry

func (s *ProxyServer) PrevEntry(ctx context.Context, request *indexedmap.PrevEntryRequest) (*indexedmap.PrevEntryResponse, error)

func (*ProxyServer) Put

func (s *ProxyServer) Put(ctx context.Context, request *indexedmap.PutRequest) (*indexedmap.PutResponse, error)

func (*ProxyServer) Remove

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

func (*ProxyServer) Size

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