grpc

Documentation

Overview

Package grpc provides a Pydio GRPC service for querying the logs

Index

• Constants
• type Handler
  • func (h *Handler) AggregatedLogs(req *proto.TimeRangeRequest, stream proto.LogRecorder_AggregatedLogsServer) error
  • func (h *Handler) DeleteLogs(ctx context.Context, req *proto.ListLogRequest) (*proto.DeleteLogsResponse, error)
  • func (h *Handler) ListLogs(req *proto.ListLogRequest, stream proto.LogRecorder_ListLogsServer) error
  • func (h *Handler) Name() string
  • func (h *Handler) PutLog(stream proto.LogRecorder_PutLogServer) error
  • func (h *Handler) TriggerResync(ctx context.Context, request *sync.ResyncRequest) (*sync.ResyncResponse, error)

Constants

const (
	ServiceName = common.ServiceGrpcNamespace_ + common.ServiceLog
)

Types

type Handler

type Handler struct {
	sync.UnimplementedSyncEndpointServer
	proto.UnimplementedLogRecorderServer
	RuntimeCtx  context.Context
	Repo        log.MessageRepository
	HandlerName string
}

Handler is the gRPC interface for the log service.

func (*Handler) AggregatedLogs

func (h *Handler) AggregatedLogs(req *proto.TimeRangeRequest, stream proto.LogRecorder_AggregatedLogsServer) error

AggregatedLogs retrieves aggregated figures from the indexer to generate charts and reports.

func (*Handler) DeleteLogs

func (h *Handler) DeleteLogs(ctx context.Context, req *proto.ListLogRequest) (*proto.DeleteLogsResponse, error)

DeleteLogs removes logs based on a ListLogRequest

func (*Handler) ListLogs

func (h *Handler) ListLogs(req *proto.ListLogRequest, stream proto.LogRecorder_ListLogsServer) error

ListLogs is a simple gateway from protobuf to the indexer search engine.

func (*Handler) Name

func (h *Handler) Name() string

func (*Handler) PutLog

func (h *Handler) PutLog(stream proto.LogRecorder_PutLogServer) error

PutLog retrieves the log messages from the proto stream and stores them in the index.

func (*Handler) TriggerResync

func (h *Handler) TriggerResync(ctx context.Context, request *sync.ResyncRequest) (*sync.ResyncResponse, error)

TriggerResync uses the request.Path as parameter. If nothing is passed, it reads all the logs from index and reconstructs a new index entirely. If truncate/{int64} is passed, it truncates the log to the given size (or closer)