log

package
v4.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 3, 2024 License: AGPL-3.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	RelType_name = map[int32]string{
		0: "NONE",
		1: "FIRST",
		2: "PREV",
		3: "NEXT",
		4: "LAST",
	}
	RelType_value = map[string]int32{
		"NONE":  0,
		"FIRST": 1,
		"PREV":  2,
		"NEXT":  3,
		"LAST":  4,
	}
)

Enum value maps for RelType.

View Source
var (
	ListLogRequest_LogFormat_name = map[int32]string{
		0: "JSON",
		1: "CSV",
		2: "XLSX",
	}
	ListLogRequest_LogFormat_value = map[string]int32{
		"JSON": 0,
		"CSV":  1,
		"XLSX": 2,
	}
)

Enum value maps for ListLogRequest_LogFormat.

View Source
var File_cells_log_proto protoreflect.FileDescriptor
View Source
var LogRecorder_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "log.LogRecorder",
	HandlerType: (*LogRecorderServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "DeleteLogs",
			Handler:    _LogRecorder_DeleteLogs_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "PutLog",
			Handler:       _LogRecorder_PutLog_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "ListLogs",
			Handler:       _LogRecorder_ListLogs_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "AggregatedLogs",
			Handler:       _LogRecorder_AggregatedLogs_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "cells-log.proto",
}

LogRecorder_ServiceDesc is the grpc.ServiceDesc for LogRecorder service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func DeregisterLogRecorderEnhancedServer

func DeregisterLogRecorderEnhancedServer(s grpc.ServiceRegistrar, name string)

func RegisterLogRecorderEnhancedServer

func RegisterLogRecorderEnhancedServer(s grpc.ServiceRegistrar, srv NamedLogRecorderServer)

func RegisterLogRecorderServer

func RegisterLogRecorderServer(s grpc.ServiceRegistrar, srv LogRecorderServer)

Types

type DeleteLogsResponse

type DeleteLogsResponse struct {
	Deleted int64 `protobuf:"varint,1,opt,name=Deleted,proto3" json:"Deleted,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteLogsResponse) Descriptor deprecated

func (*DeleteLogsResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteLogsResponse.ProtoReflect.Descriptor instead.

func (*DeleteLogsResponse) GetDeleted

func (x *DeleteLogsResponse) GetDeleted() int64

func (*DeleteLogsResponse) ProtoMessage

func (*DeleteLogsResponse) ProtoMessage()

func (*DeleteLogsResponse) ProtoReflect

func (x *DeleteLogsResponse) ProtoReflect() protoreflect.Message

func (*DeleteLogsResponse) Reset

func (x *DeleteLogsResponse) Reset()

func (*DeleteLogsResponse) String

func (x *DeleteLogsResponse) String() string

func (*DeleteLogsResponse) Validate

func (this *DeleteLogsResponse) Validate() error

type ListLogRequest

type ListLogRequest struct {

	// Bleve-type Query stsring
	Query string `protobuf:"bytes,1,opt,name=Query,proto3" json:"Query,omitempty"`
	// Start at page
	Page int32 `protobuf:"varint,2,opt,name=Page,proto3" json:"Page,omitempty"`
	// Number of results
	Size   int32                    `protobuf:"varint,3,opt,name=Size,proto3" json:"Size,omitempty"`
	Format ListLogRequest_LogFormat `protobuf:"varint,4,opt,name=Format,proto3,enum=log.ListLogRequest_LogFormat" json:"Format,omitempty"`
	// contains filtered or unexported fields
}

ListLogRequest launches a parameterised query in the log repository and streams the results.

func (*ListLogRequest) Descriptor deprecated

func (*ListLogRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListLogRequest.ProtoReflect.Descriptor instead.

func (*ListLogRequest) GetFormat

func (*ListLogRequest) GetPage

func (x *ListLogRequest) GetPage() int32

func (*ListLogRequest) GetQuery

func (x *ListLogRequest) GetQuery() string

func (*ListLogRequest) GetSize

func (x *ListLogRequest) GetSize() int32

func (*ListLogRequest) ProtoMessage

func (*ListLogRequest) ProtoMessage()

func (*ListLogRequest) ProtoReflect

func (x *ListLogRequest) ProtoReflect() protoreflect.Message

func (*ListLogRequest) Reset

func (x *ListLogRequest) Reset()

func (*ListLogRequest) String

func (x *ListLogRequest) String() string

func (*ListLogRequest) Validate

func (this *ListLogRequest) Validate() error

type ListLogRequest_LogFormat

type ListLogRequest_LogFormat int32

Output Format

const (
	ListLogRequest_JSON ListLogRequest_LogFormat = 0
	ListLogRequest_CSV  ListLogRequest_LogFormat = 1
	ListLogRequest_XLSX ListLogRequest_LogFormat = 2
)

func (ListLogRequest_LogFormat) Descriptor

func (ListLogRequest_LogFormat) Enum

func (ListLogRequest_LogFormat) EnumDescriptor deprecated

func (ListLogRequest_LogFormat) EnumDescriptor() ([]byte, []int)

Deprecated: Use ListLogRequest_LogFormat.Descriptor instead.

func (ListLogRequest_LogFormat) Number

func (ListLogRequest_LogFormat) String

func (x ListLogRequest_LogFormat) String() string

func (ListLogRequest_LogFormat) Type

type ListLogResponse

type ListLogResponse struct {
	LogMessage *LogMessage `protobuf:"bytes,1,opt,name=LogMessage,proto3" json:"LogMessage,omitempty"`
	// contains filtered or unexported fields
}

func (*ListLogResponse) Descriptor deprecated

func (*ListLogResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListLogResponse.ProtoReflect.Descriptor instead.

func (*ListLogResponse) GetLogMessage

func (x *ListLogResponse) GetLogMessage() *LogMessage

func (*ListLogResponse) ProtoMessage

func (*ListLogResponse) ProtoMessage()

func (*ListLogResponse) ProtoReflect

func (x *ListLogResponse) ProtoReflect() protoreflect.Message

func (*ListLogResponse) Reset

func (x *ListLogResponse) Reset()

func (*ListLogResponse) String

func (x *ListLogResponse) String() string

func (*ListLogResponse) Validate

func (this *ListLogResponse) Validate() error

type Log

type Log struct {
	Message []byte `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"`
	Nano    int32  `protobuf:"varint,2,opt,name=Nano,proto3" json:"Nano,omitempty"`
	// contains filtered or unexported fields
}

Log is a generic message format used by the sync service to publish log messages to the various log repositories (typically, bleve).

func (*Log) Descriptor deprecated

func (*Log) Descriptor() ([]byte, []int)

Deprecated: Use Log.ProtoReflect.Descriptor instead.

func (*Log) GetMessage

func (x *Log) GetMessage() []byte

func (*Log) GetNano

func (x *Log) GetNano() int32

func (*Log) ProtoMessage

func (*Log) ProtoMessage()

func (*Log) ProtoReflect

func (x *Log) ProtoReflect() protoreflect.Message

func (*Log) Reset

func (x *Log) Reset()

func (*Log) String

func (x *Log) String() string

func (*Log) Validate

func (this *Log) Validate() error

type LogLevelEvent

type LogLevelEvent struct {

	// Reset all services to Info level
	ResetInfo bool `protobuf:"varint,1,opt,name=ResetInfo,proto3" json:"ResetInfo,omitempty"`
	// Set to Debug if true or Info if false
	LevelDebug bool `protobuf:"varint,2,opt,name=LevelDebug,proto3" json:"LevelDebug,omitempty"`
	// List of services where to apply (if Reset is not set)
	Services []string `protobuf:"bytes,3,rep,name=Services,proto3" json:"Services,omitempty"`
	// contains filtered or unexported fields
}

LogLevelEvent can be broadcasted to broker to change logger level from Info to Debug for a specific set of services

func (*LogLevelEvent) Descriptor deprecated

func (*LogLevelEvent) Descriptor() ([]byte, []int)

Deprecated: Use LogLevelEvent.ProtoReflect.Descriptor instead.

func (*LogLevelEvent) GetLevelDebug

func (x *LogLevelEvent) GetLevelDebug() bool

func (*LogLevelEvent) GetResetInfo

func (x *LogLevelEvent) GetResetInfo() bool

func (*LogLevelEvent) GetServices

func (x *LogLevelEvent) GetServices() []string

func (*LogLevelEvent) ProtoMessage

func (*LogLevelEvent) ProtoMessage()

func (*LogLevelEvent) ProtoReflect

func (x *LogLevelEvent) ProtoReflect() protoreflect.Message

func (*LogLevelEvent) Reset

func (x *LogLevelEvent) Reset()

func (*LogLevelEvent) String

func (x *LogLevelEvent) String() string

func (*LogLevelEvent) Validate

func (this *LogLevelEvent) Validate() error

type LogMessage

type LogMessage struct {

	// Generic zap fields
	Ts     int32  `protobuf:"varint,1,opt,name=Ts,proto3" json:"Ts,omitempty"`
	Level  string `protobuf:"bytes,2,opt,name=Level,proto3" json:"Level,omitempty"`
	Logger string `protobuf:"bytes,3,opt,name=Logger,proto3" json:"Logger,omitempty"`
	Msg    string `protobuf:"bytes,4,opt,name=Msg,proto3" json:"Msg,omitempty"`
	// Pydio specific
	MsgId string `protobuf:"bytes,5,opt,name=MsgId,proto3" json:"MsgId,omitempty"`
	// User Info
	UserName  string   `protobuf:"bytes,6,opt,name=UserName,proto3" json:"UserName,omitempty"`
	UserUuid  string   `protobuf:"bytes,7,opt,name=UserUuid,proto3" json:"UserUuid,omitempty"`
	GroupPath string   `protobuf:"bytes,8,opt,name=GroupPath,proto3" json:"GroupPath,omitempty"`
	Profile   string   `protobuf:"bytes,16,opt,name=Profile,proto3" json:"Profile,omitempty"`
	RoleUuids []string `protobuf:"bytes,9,rep,name=RoleUuids,proto3" json:"RoleUuids,omitempty"`
	// Client info
	RemoteAddress string `protobuf:"bytes,10,opt,name=RemoteAddress,proto3" json:"RemoteAddress,omitempty"`
	UserAgent     string `protobuf:"bytes,11,opt,name=UserAgent,proto3" json:"UserAgent,omitempty"`
	HttpProtocol  string `protobuf:"bytes,12,opt,name=HttpProtocol,proto3" json:"HttpProtocol,omitempty"`
	// Tree Info
	NodeUuid     string `protobuf:"bytes,13,opt,name=NodeUuid,proto3" json:"NodeUuid,omitempty"`
	NodePath     string `protobuf:"bytes,14,opt,name=NodePath,proto3" json:"NodePath,omitempty"`
	TransferSize int64  `protobuf:"varint,27,opt,name=TransferSize,proto3" json:"TransferSize,omitempty"`
	WsUuid       string `protobuf:"bytes,15,opt,name=WsUuid,proto3" json:"WsUuid,omitempty"`
	WsScope      string `protobuf:"bytes,17,opt,name=WsScope,proto3" json:"WsScope,omitempty"`
	// Span Info
	SpanUuid       string `protobuf:"bytes,18,opt,name=SpanUuid,proto3" json:"SpanUuid,omitempty"`
	SpanParentUuid string `protobuf:"bytes,19,opt,name=SpanParentUuid,proto3" json:"SpanParentUuid,omitempty"`
	SpanRootUuid   string `protobuf:"bytes,20,opt,name=SpanRootUuid,proto3" json:"SpanRootUuid,omitempty"`
	// High Level Operation Info
	OperationUuid           string `protobuf:"bytes,21,opt,name=OperationUuid,proto3" json:"OperationUuid,omitempty"`
	OperationLabel          string `protobuf:"bytes,22,opt,name=OperationLabel,proto3" json:"OperationLabel,omitempty"`
	SchedulerJobUuid        string `protobuf:"bytes,23,opt,name=SchedulerJobUuid,proto3" json:"SchedulerJobUuid,omitempty"`
	SchedulerTaskUuid       string `protobuf:"bytes,24,opt,name=SchedulerTaskUuid,proto3" json:"SchedulerTaskUuid,omitempty"`
	SchedulerTaskActionPath string `protobuf:"bytes,25,opt,name=SchedulerTaskActionPath,proto3" json:"SchedulerTaskActionPath,omitempty"`
	// Other Unkown Fields
	JsonZaps string `protobuf:"bytes,26,opt,name=JsonZaps,proto3" json:"JsonZaps,omitempty"`
	// contains filtered or unexported fields
}

LogMessage is the format used to transmit log messages to clients via the REST API.

func (*LogMessage) Descriptor deprecated

func (*LogMessage) Descriptor() ([]byte, []int)

Deprecated: Use LogMessage.ProtoReflect.Descriptor instead.

func (*LogMessage) GetGroupPath

func (x *LogMessage) GetGroupPath() string

func (*LogMessage) GetHttpProtocol

func (x *LogMessage) GetHttpProtocol() string

func (*LogMessage) GetJsonZaps

func (x *LogMessage) GetJsonZaps() string

func (*LogMessage) GetLevel

func (x *LogMessage) GetLevel() string

func (*LogMessage) GetLogger

func (x *LogMessage) GetLogger() string

func (*LogMessage) GetMsg

func (x *LogMessage) GetMsg() string

func (*LogMessage) GetMsgId

func (x *LogMessage) GetMsgId() string

func (*LogMessage) GetNodePath

func (x *LogMessage) GetNodePath() string

func (*LogMessage) GetNodeUuid

func (x *LogMessage) GetNodeUuid() string

func (*LogMessage) GetOperationLabel

func (x *LogMessage) GetOperationLabel() string

func (*LogMessage) GetOperationUuid

func (x *LogMessage) GetOperationUuid() string

func (*LogMessage) GetProfile

func (x *LogMessage) GetProfile() string

func (*LogMessage) GetRemoteAddress

func (x *LogMessage) GetRemoteAddress() string

func (*LogMessage) GetRoleUuids

func (x *LogMessage) GetRoleUuids() []string

func (*LogMessage) GetSchedulerJobUuid

func (x *LogMessage) GetSchedulerJobUuid() string

func (*LogMessage) GetSchedulerTaskActionPath

func (x *LogMessage) GetSchedulerTaskActionPath() string

func (*LogMessage) GetSchedulerTaskUuid

func (x *LogMessage) GetSchedulerTaskUuid() string

func (*LogMessage) GetSpanParentUuid

func (x *LogMessage) GetSpanParentUuid() string

func (*LogMessage) GetSpanRootUuid

func (x *LogMessage) GetSpanRootUuid() string

func (*LogMessage) GetSpanUuid

func (x *LogMessage) GetSpanUuid() string

func (*LogMessage) GetTransferSize added in v4.3.1

func (x *LogMessage) GetTransferSize() int64

func (*LogMessage) GetTs

func (x *LogMessage) GetTs() int32

func (*LogMessage) GetUserAgent

func (x *LogMessage) GetUserAgent() string

func (*LogMessage) GetUserName

func (x *LogMessage) GetUserName() string

func (*LogMessage) GetUserUuid

func (x *LogMessage) GetUserUuid() string

func (*LogMessage) GetWsScope

func (x *LogMessage) GetWsScope() string

func (*LogMessage) GetWsUuid

func (x *LogMessage) GetWsUuid() string

func (*LogMessage) ProtoMessage

func (*LogMessage) ProtoMessage()

func (*LogMessage) ProtoReflect

func (x *LogMessage) ProtoReflect() protoreflect.Message

func (*LogMessage) Reset

func (x *LogMessage) Reset()

func (*LogMessage) String

func (x *LogMessage) String() string

func (*LogMessage) Validate

func (this *LogMessage) Validate() error

type LogRecorderClient

type LogRecorderClient interface {
	// PutLog adds received log messages to the corresponding log repository.
	PutLog(ctx context.Context, opts ...grpc.CallOption) (LogRecorder_PutLogClient, error)
	// ListLogs performs a paginated search query in the log repository.
	ListLogs(ctx context.Context, in *ListLogRequest, opts ...grpc.CallOption) (LogRecorder_ListLogsClient, error)
	// DeleteLogs deletes logs based on a request (cannot be empty)
	DeleteLogs(ctx context.Context, in *ListLogRequest, opts ...grpc.CallOption) (*DeleteLogsResponse, error)
	// AggregatedLogs performs a query to retrieve log events of the given type, faceted by time range.
	AggregatedLogs(ctx context.Context, in *TimeRangeRequest, opts ...grpc.CallOption) (LogRecorder_AggregatedLogsClient, error)
}

LogRecorderClient is the client API for LogRecorder service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type LogRecorderEnhancedServer

type LogRecorderEnhancedServer map[string]NamedLogRecorderServer

func (LogRecorderEnhancedServer) AggregatedLogs

func (LogRecorderEnhancedServer) DeleteLogs

func (LogRecorderEnhancedServer) ListLogs

func (LogRecorderEnhancedServer) PutLog

type LogRecorderServer

type LogRecorderServer interface {
	// PutLog adds received log messages to the corresponding log repository.
	PutLog(LogRecorder_PutLogServer) error
	// ListLogs performs a paginated search query in the log repository.
	ListLogs(*ListLogRequest, LogRecorder_ListLogsServer) error
	// DeleteLogs deletes logs based on a request (cannot be empty)
	DeleteLogs(context.Context, *ListLogRequest) (*DeleteLogsResponse, error)
	// AggregatedLogs performs a query to retrieve log events of the given type, faceted by time range.
	AggregatedLogs(*TimeRangeRequest, LogRecorder_AggregatedLogsServer) error
	// contains filtered or unexported methods
}

LogRecorderServer is the server API for LogRecorder service. All implementations must embed UnimplementedLogRecorderServer for forward compatibility

type LogRecorder_AggregatedLogsClient

type LogRecorder_AggregatedLogsClient interface {
	Recv() (*TimeRangeResponse, error)
	grpc.ClientStream
}

type LogRecorder_AggregatedLogsServer

type LogRecorder_AggregatedLogsServer interface {
	Send(*TimeRangeResponse) error
	grpc.ServerStream
}

type LogRecorder_ListLogsClient

type LogRecorder_ListLogsClient interface {
	Recv() (*ListLogResponse, error)
	grpc.ClientStream
}

type LogRecorder_ListLogsServer

type LogRecorder_ListLogsServer interface {
	Send(*ListLogResponse) error
	grpc.ServerStream
}

type LogRecorder_PutLogClient

type LogRecorder_PutLogClient interface {
	Send(*Log) error
	CloseAndRecv() (*RecorderPutResponse, error)
	grpc.ClientStream
}

type LogRecorder_PutLogServer

type LogRecorder_PutLogServer interface {
	SendAndClose(*RecorderPutResponse) error
	Recv() (*Log, error)
	grpc.ServerStream
}

type NamedLogRecorderServer

type NamedLogRecorderServer interface {
	LogRecorderServer
	Name() string
}

type RecorderPutResponse

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

func (*RecorderPutResponse) Descriptor deprecated

func (*RecorderPutResponse) Descriptor() ([]byte, []int)

Deprecated: Use RecorderPutResponse.ProtoReflect.Descriptor instead.

func (*RecorderPutResponse) ProtoMessage

func (*RecorderPutResponse) ProtoMessage()

func (*RecorderPutResponse) ProtoReflect

func (x *RecorderPutResponse) ProtoReflect() protoreflect.Message

func (*RecorderPutResponse) Reset

func (x *RecorderPutResponse) Reset()

func (*RecorderPutResponse) String

func (x *RecorderPutResponse) String() string

func (*RecorderPutResponse) Validate

func (this *RecorderPutResponse) Validate() error

type RelType

type RelType int32

Relative links types. Note that First is time.Now() and last time.Unix(0). We added an unused NONE enum with value 0 to workaround 0 issues between JSON and proto3.

const (
	RelType_NONE  RelType = 0
	RelType_FIRST RelType = 1
	RelType_PREV  RelType = 2
	RelType_NEXT  RelType = 3
	RelType_LAST  RelType = 4
)

func (RelType) Descriptor

func (RelType) Descriptor() protoreflect.EnumDescriptor

func (RelType) Enum

func (x RelType) Enum() *RelType

func (RelType) EnumDescriptor deprecated

func (RelType) EnumDescriptor() ([]byte, []int)

Deprecated: Use RelType.Descriptor instead.

func (RelType) Number

func (x RelType) Number() protoreflect.EnumNumber

func (RelType) String

func (x RelType) String() string

func (RelType) Type

func (RelType) Type() protoreflect.EnumType

type TimeRangeCursor

type TimeRangeCursor struct {
	Rel     RelType `protobuf:"varint,1,opt,name=Rel,proto3,enum=log.RelType" json:"Rel,omitempty"`
	RefTime int32   `protobuf:"varint,2,opt,name=RefTime,proto3" json:"RefTime,omitempty"`
	Count   int32   `protobuf:"varint,3,opt,name=Count,proto3" json:"Count,omitempty"`
	// contains filtered or unexported fields
}

Ease implementation of data navigation for a chart.

func (*TimeRangeCursor) Descriptor deprecated

func (*TimeRangeCursor) Descriptor() ([]byte, []int)

Deprecated: Use TimeRangeCursor.ProtoReflect.Descriptor instead.

func (*TimeRangeCursor) GetCount

func (x *TimeRangeCursor) GetCount() int32

func (*TimeRangeCursor) GetRefTime

func (x *TimeRangeCursor) GetRefTime() int32

func (*TimeRangeCursor) GetRel

func (x *TimeRangeCursor) GetRel() RelType

func (*TimeRangeCursor) ProtoMessage

func (*TimeRangeCursor) ProtoMessage()

func (*TimeRangeCursor) ProtoReflect

func (x *TimeRangeCursor) ProtoReflect() protoreflect.Message

func (*TimeRangeCursor) Reset

func (x *TimeRangeCursor) Reset()

func (*TimeRangeCursor) String

func (x *TimeRangeCursor) String() string

func (*TimeRangeCursor) Validate

func (this *TimeRangeCursor) Validate() error

type TimeRangeRequest

type TimeRangeRequest struct {

	// Type of event we are auditing
	MsgId string `protobuf:"bytes,1,opt,name=MsgId,proto3" json:"MsgId,omitempty"`
	// Known types: H, D, W, M or Y
	TimeRangeType string `protobuf:"bytes,2,opt,name=TimeRangeType,proto3" json:"TimeRangeType,omitempty"`
	// Upper bound for our request
	RefTime int32 `protobuf:"varint,3,opt,name=RefTime,proto3" json:"RefTime,omitempty"`
	// contains filtered or unexported fields
}

TimeRangeRequest contains the parameter to configure the query to retrieve the number of audit events of this type for a given time range defined by last timestamp and a range type.

func (*TimeRangeRequest) Descriptor deprecated

func (*TimeRangeRequest) Descriptor() ([]byte, []int)

Deprecated: Use TimeRangeRequest.ProtoReflect.Descriptor instead.

func (*TimeRangeRequest) GetMsgId

func (x *TimeRangeRequest) GetMsgId() string

func (*TimeRangeRequest) GetRefTime

func (x *TimeRangeRequest) GetRefTime() int32

func (*TimeRangeRequest) GetTimeRangeType

func (x *TimeRangeRequest) GetTimeRangeType() string

func (*TimeRangeRequest) ProtoMessage

func (*TimeRangeRequest) ProtoMessage()

func (*TimeRangeRequest) ProtoReflect

func (x *TimeRangeRequest) ProtoReflect() protoreflect.Message

func (*TimeRangeRequest) Reset

func (x *TimeRangeRequest) Reset()

func (*TimeRangeRequest) String

func (x *TimeRangeRequest) String() string

func (*TimeRangeRequest) Validate

func (this *TimeRangeRequest) Validate() error

type TimeRangeResponse

type TimeRangeResponse struct {
	TimeRangeResult *TimeRangeResult `protobuf:"bytes,1,opt,name=TimeRangeResult,proto3" json:"TimeRangeResult,omitempty"`
	TimeRangeCursor *TimeRangeCursor `protobuf:"bytes,2,opt,name=TimeRangeCursor,proto3" json:"TimeRangeCursor,omitempty"`
	// contains filtered or unexported fields
}

TimeRangeResponse contains either one aggregated result of a facetted request OR a time range cursor.

func (*TimeRangeResponse) Descriptor deprecated

func (*TimeRangeResponse) Descriptor() ([]byte, []int)

Deprecated: Use TimeRangeResponse.ProtoReflect.Descriptor instead.

func (*TimeRangeResponse) GetTimeRangeCursor

func (x *TimeRangeResponse) GetTimeRangeCursor() *TimeRangeCursor

func (*TimeRangeResponse) GetTimeRangeResult

func (x *TimeRangeResponse) GetTimeRangeResult() *TimeRangeResult

func (*TimeRangeResponse) ProtoMessage

func (*TimeRangeResponse) ProtoMessage()

func (*TimeRangeResponse) ProtoReflect

func (x *TimeRangeResponse) ProtoReflect() protoreflect.Message

func (*TimeRangeResponse) Reset

func (x *TimeRangeResponse) Reset()

func (*TimeRangeResponse) String

func (x *TimeRangeResponse) String() string

func (*TimeRangeResponse) Validate

func (this *TimeRangeResponse) Validate() error

type TimeRangeResult

type TimeRangeResult struct {

	// a label for this time range
	Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	// begin timestamp
	Start int32 `protobuf:"varint,2,opt,name=Start,proto3" json:"Start,omitempty"`
	// end timestamp
	End int32 `protobuf:"varint,3,opt,name=End,proto3" json:"End,omitempty"`
	// nb of occurrences found within this range
	Count int32 `protobuf:"varint,4,opt,name=Count,proto3" json:"Count,omitempty"`
	// a score between 1 and 100 that gives the relevance of this result:
	// if End > now, we ponderate the returned count with the duration of the last time range
	// for instance for a hour range if now is 6PM, last count will be
	// multiplied by 4/3 and have a relevance of 75.
	// Relevance will be almost always equals to 100
	Relevance int32 `protobuf:"varint,5,opt,name=Relevance,proto3" json:"Relevance,omitempty"`
	// contains filtered or unexported fields
}

TimeRangeResult represents one point of a graph.

func (*TimeRangeResult) Descriptor deprecated

func (*TimeRangeResult) Descriptor() ([]byte, []int)

Deprecated: Use TimeRangeResult.ProtoReflect.Descriptor instead.

func (*TimeRangeResult) GetCount

func (x *TimeRangeResult) GetCount() int32

func (*TimeRangeResult) GetEnd

func (x *TimeRangeResult) GetEnd() int32

func (*TimeRangeResult) GetName

func (x *TimeRangeResult) GetName() string

func (*TimeRangeResult) GetRelevance

func (x *TimeRangeResult) GetRelevance() int32

func (*TimeRangeResult) GetStart

func (x *TimeRangeResult) GetStart() int32

func (*TimeRangeResult) ProtoMessage

func (*TimeRangeResult) ProtoMessage()

func (*TimeRangeResult) ProtoReflect

func (x *TimeRangeResult) ProtoReflect() protoreflect.Message

func (*TimeRangeResult) Reset

func (x *TimeRangeResult) Reset()

func (*TimeRangeResult) String

func (x *TimeRangeResult) String() string

func (*TimeRangeResult) Validate

func (this *TimeRangeResult) Validate() error

type UnimplementedLogRecorderServer

type UnimplementedLogRecorderServer struct {
}

UnimplementedLogRecorderServer must be embedded to have forward compatible implementations.

func (UnimplementedLogRecorderServer) AggregatedLogs

func (UnimplementedLogRecorderServer) DeleteLogs

func (UnimplementedLogRecorderServer) ListLogs

func (UnimplementedLogRecorderServer) PutLog

type UnsafeLogRecorderServer

type UnsafeLogRecorderServer interface {
	// contains filtered or unexported methods
}

UnsafeLogRecorderServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LogRecorderServer will result in compilation errors.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL