log

package
v4.0.0-beta2 Latest Latest
Warning

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

 Go to latest Published: Jun 9, 2022 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 (x *ListLogRequest) GetFormat() ListLogRequest_LogFormat

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) Descriptor() protoreflect.EnumDescriptor

func (ListLogRequest_LogFormat) Enum 

func (x ListLogRequest_LogFormat) Enum() *ListLogRequest_LogFormat

func (ListLogRequest_LogFormat) EnumDescriptor deprecated 

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

Deprecated: Use ListLogRequest_LogFormat.Descriptor instead.

func (ListLogRequest_LogFormat) Number 

func (x ListLogRequest_LogFormat) Number() protoreflect.EnumNumber

func (ListLogRequest_LogFormat) String 

func (x ListLogRequest_LogFormat) String() string

func (ListLogRequest_LogFormat) Type 

func (ListLogRequest_LogFormat) Type() protoreflect.EnumType

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"`
	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) 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.

func NewLogRecorderClient 

func NewLogRecorderClient(cc grpc.ClientConnInterface) LogRecorderClient

type LogRecorderEnhancedServer 

type LogRecorderEnhancedServer map[string]NamedLogRecorderServer

func (LogRecorderEnhancedServer) AggregatedLogs 

func (m LogRecorderEnhancedServer) AggregatedLogs(r *TimeRangeRequest, s LogRecorder_AggregatedLogsServer) error

func (LogRecorderEnhancedServer) DeleteLogs 

func (m LogRecorderEnhancedServer) DeleteLogs(ctx context.Context, r *ListLogRequest) (*DeleteLogsResponse, error)

func (LogRecorderEnhancedServer) ListLogs 

func (m LogRecorderEnhancedServer) ListLogs(r *ListLogRequest, s LogRecorder_ListLogsServer) error

func (LogRecorderEnhancedServer) PutLog 

func (m LogRecorderEnhancedServer) PutLog(s LogRecorder_PutLogServer) error

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) AggregatedLogs(*TimeRangeRequest, LogRecorder_AggregatedLogsServer) error

func (UnimplementedLogRecorderServer) DeleteLogs 

func (UnimplementedLogRecorderServer) DeleteLogs(context.Context, *ListLogRequest) (*DeleteLogsResponse, error)

func (UnimplementedLogRecorderServer) ListLogs 

func (UnimplementedLogRecorderServer) ListLogs(*ListLogRequest, LogRecorder_ListLogsServer) error

func (UnimplementedLogRecorderServer) PutLog 

func (UnimplementedLogRecorderServer) PutLog(LogRecorder_PutLogServer) error

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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.