log

Documentation

Index

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

Functions

func NewProxyServer

func NewProxyServer(s logapi.LogServiceServer) logapi.LogServiceServer

NewProxyServer creates a new read-only log server

Types

type ProxyServer

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

ProxyServer is a read-only log primitive server

func (*ProxyServer) Append

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

func (*ProxyServer) Clear

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

func (*ProxyServer) Entries

func (s *ProxyServer) Entries(request *logapi.EntriesRequest, server logapi.LogService_EntriesServer) error

func (*ProxyServer) Events

func (s *ProxyServer) Events(request *logapi.EventsRequest, server logapi.LogService_EventsServer) error

func (*ProxyServer) FirstEntry

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

func (*ProxyServer) Get

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

func (*ProxyServer) LastEntry

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

func (*ProxyServer) NextEntry

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

func (*ProxyServer) PrevEntry

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

func (*ProxyServer) Remove

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

func (*ProxyServer) Size

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