log

Documentation

Overview

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

Index

• Constants
• func NewProxyServer(client *rsm.Client) _log.LogServiceServer
• func Register(protocol *rsm.Protocol)
• type ProxyServer
  • func (s *ProxyServer) Append(ctx context.Context, request *_log.AppendRequest) (*_log.AppendResponse, error)
  • func (s *ProxyServer) Clear(ctx context.Context, request *_log.ClearRequest) (*_log.ClearResponse, error)
  • func (s *ProxyServer) Entries(request *_log.EntriesRequest, srv _log.LogService_EntriesServer) error
  • func (s *ProxyServer) Events(request *_log.EventsRequest, srv _log.LogService_EventsServer) error
  • func (s *ProxyServer) FirstEntry(ctx context.Context, request *_log.FirstEntryRequest) (*_log.FirstEntryResponse, error)
  • func (s *ProxyServer) Get(ctx context.Context, request *_log.GetRequest) (*_log.GetResponse, error)
  • func (s *ProxyServer) LastEntry(ctx context.Context, request *_log.LastEntryRequest) (*_log.LastEntryResponse, error)
  • func (s *ProxyServer) NextEntry(ctx context.Context, request *_log.NextEntryRequest) (*_log.NextEntryResponse, error)
  • func (s *ProxyServer) PrevEntry(ctx context.Context, request *_log.PrevEntryRequest) (*_log.PrevEntryResponse, error)
  • func (s *ProxyServer) Remove(ctx context.Context, request *_log.RemoveRequest) (*_log.RemoveResponse, error)
  • func (s *ProxyServer) Size(ctx context.Context, request *_log.SizeRequest) (*_log.SizeResponse, error)

Constants

const Type = "Log"

Functions

func NewProxyServer

func NewProxyServer(client *rsm.Client) _log.LogServiceServer

NewProxyServer creates a new ProxyServer

func Register

func Register(protocol *rsm.Protocol)

Types

type ProxyServer

type ProxyServer struct {
	*rsm.Client
	// contains filtered or unexported fields
}

func (*ProxyServer) Append

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

func (*ProxyServer) Clear

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

func (*ProxyServer) Entries

func (s *ProxyServer) Entries(request *_log.EntriesRequest, srv _log.LogService_EntriesServer) error

func (*ProxyServer) Events

func (s *ProxyServer) Events(request *_log.EventsRequest, srv _log.LogService_EventsServer) error

func (*ProxyServer) FirstEntry

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

func (*ProxyServer) Get

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

func (*ProxyServer) LastEntry

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

func (*ProxyServer) NextEntry

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

func (*ProxyServer) PrevEntry

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

func (*ProxyServer) Remove

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

func (*ProxyServer) Size

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