api

package
v1.67.1 Latest Latest
Warning

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

 Go to latest Published: Dec 18, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	EventBatch_EventType_name = map[int32]string{
		0:  "UNSPECIFIED",
		25: "AGENT_STATS",
	}
	EventBatch_EventType_value = map[string]int32{
		"UNSPECIFIED": 0,
		"AGENT_STATS": 25,
	}
)

Enum value maps for EventBatch_EventType.

View Source 
var File_chronicle_http_proto protoreflect.FileDescriptor
View Source 
var File_chronicle_log_proto protoreflect.FileDescriptor
View Source 
var File_events_proto protoreflect.FileDescriptor
View Source 
var File_ingestion_proto protoreflect.FileDescriptor
View Source 
var File_source_proto protoreflect.FileDescriptor
View Source 
var File_stats_proto protoreflect.FileDescriptor
View Source 
var IngestionServiceV2_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "malachite.ingestion.v2.IngestionServiceV2",
	HandlerType: (*IngestionServiceV2Server)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "BatchCreateEvents",
			Handler:    _IngestionServiceV2_BatchCreateEvents_Handler,
		},
		{
			MethodName: "BatchCreateLogs",
			Handler:    _IngestionServiceV2_BatchCreateLogs_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "ingestion.proto",
}

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

Functions

func RegisterIngestionServiceV2Server 

func RegisterIngestionServiceV2Server(s grpc.ServiceRegistrar, srv IngestionServiceV2Server)

Types

type AgentStatsEvent 

type AgentStatsEvent struct {

	// Timestamp when the collector started.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// Time the stats below were last reset. (Event timestamp is window_end)
	// This corresponds to the last stats upload that was successful.
	WindowStartTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=window_start_time,json=windowStartTime,proto3" json:"window_start_time,omitempty"`
	// Timestamp of the last successful batch upload.
	LastSuccessfulUploadTime *timestamppb.Timestamp `` /* 137-byte string literal not displayed */
	// The unique id of the agent
	AgentId []byte `protobuf:"bytes,4,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	// Stats about the receivers.
	ReceiverStats []*ReceiverStats `protobuf:"bytes,5,rep,name=receiver_stats,json=receiverStats,proto3" json:"receiver_stats,omitempty"`
	// Stats about the processors.
	ProcessorStats []*ProcessorStats `protobuf:"bytes,6,rep,name=processor_stats,json=processorStats,proto3" json:"processor_stats,omitempty"`
	// Stats about the exporters.
	ExporterStats []*ExporterStats `protobuf:"bytes,7,rep,name=exporter_stats,json=exporterStats,proto3" json:"exporter_stats,omitempty"`
	// CPU time spent on the process.
	ProcessCpuSeconds int64 `protobuf:"varint,8,opt,name=process_cpu_seconds,json=processCpuSeconds,proto3" json:"process_cpu_seconds,omitempty"`
	// Memory in kilobytes occupied by the process.
	ProcessMemoryRss int64 `protobuf:"varint,9,opt,name=process_memory_rss,json=processMemoryRss,proto3" json:"process_memory_rss,omitempty"`
	// Number of seconds from which the process is running.
	ProcessUptime int64 `protobuf:"varint,10,opt,name=process_uptime,json=processUptime,proto3" json:"process_uptime,omitempty"`
	// contains filtered or unexported fields
}

Stats about the collection agent. NEXT TAG: 11

func (*AgentStatsEvent) Descriptor deprecated 

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

Deprecated: Use AgentStatsEvent.ProtoReflect.Descriptor instead.

func (*AgentStatsEvent) GetAgentId 

func (x *AgentStatsEvent) GetAgentId() []byte

func (*AgentStatsEvent) GetExporterStats 

func (x *AgentStatsEvent) GetExporterStats() []*ExporterStats

func (*AgentStatsEvent) GetLastSuccessfulUploadTime 

func (x *AgentStatsEvent) GetLastSuccessfulUploadTime() *timestamppb.Timestamp

func (*AgentStatsEvent) GetProcessCpuSeconds 

func (x *AgentStatsEvent) GetProcessCpuSeconds() int64

func (*AgentStatsEvent) GetProcessMemoryRss 

func (x *AgentStatsEvent) GetProcessMemoryRss() int64

func (*AgentStatsEvent) GetProcessUptime 

func (x *AgentStatsEvent) GetProcessUptime() int64

func (*AgentStatsEvent) GetProcessorStats 

func (x *AgentStatsEvent) GetProcessorStats() []*ProcessorStats

func (*AgentStatsEvent) GetReceiverStats 

func (x *AgentStatsEvent) GetReceiverStats() []*ReceiverStats

func (*AgentStatsEvent) GetStartTime 

func (x *AgentStatsEvent) GetStartTime() *timestamppb.Timestamp

func (*AgentStatsEvent) GetWindowStartTime 

func (x *AgentStatsEvent) GetWindowStartTime() *timestamppb.Timestamp

func (*AgentStatsEvent) ProtoMessage 

func (*AgentStatsEvent) ProtoMessage()

func (*AgentStatsEvent) ProtoReflect 

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

func (*AgentStatsEvent) Reset 

func (x *AgentStatsEvent) Reset()

func (*AgentStatsEvent) String 

func (x *AgentStatsEvent) String() string

type BatchCreateEventsRequest 

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

func (*BatchCreateEventsRequest) Descriptor deprecated 

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

Deprecated: Use BatchCreateEventsRequest.ProtoReflect.Descriptor instead.

func (*BatchCreateEventsRequest) GetBatch 

func (x *BatchCreateEventsRequest) GetBatch() *EventBatch

func (*BatchCreateEventsRequest) ProtoMessage 

func (*BatchCreateEventsRequest) ProtoMessage()

func (*BatchCreateEventsRequest) ProtoReflect 

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

func (*BatchCreateEventsRequest) Reset 

func (x *BatchCreateEventsRequest) Reset()

func (*BatchCreateEventsRequest) String 

func (x *BatchCreateEventsRequest) String() string

type BatchCreateEventsResponse 

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

func (*BatchCreateEventsResponse) Descriptor deprecated 

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

Deprecated: Use BatchCreateEventsResponse.ProtoReflect.Descriptor instead.

func (*BatchCreateEventsResponse) ProtoMessage 

func (*BatchCreateEventsResponse) ProtoMessage()

func (*BatchCreateEventsResponse) ProtoReflect 

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

func (*BatchCreateEventsResponse) Reset 

func (x *BatchCreateEventsResponse) Reset()

func (*BatchCreateEventsResponse) String 

func (x *BatchCreateEventsResponse) String() string

type BatchCreateLogsRequest 

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

func (*BatchCreateLogsRequest) Descriptor deprecated 

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

Deprecated: Use BatchCreateLogsRequest.ProtoReflect.Descriptor instead.

func (*BatchCreateLogsRequest) GetBatch 

func (x *BatchCreateLogsRequest) GetBatch() *LogEntryBatch

func (*BatchCreateLogsRequest) ProtoMessage 

func (*BatchCreateLogsRequest) ProtoMessage()

func (*BatchCreateLogsRequest) ProtoReflect 

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

func (*BatchCreateLogsRequest) Reset 

func (x *BatchCreateLogsRequest) Reset()

func (*BatchCreateLogsRequest) String 

func (x *BatchCreateLogsRequest) String() string

type BatchCreateLogsResponse 

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

func (*BatchCreateLogsResponse) Descriptor deprecated 

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

Deprecated: Use BatchCreateLogsResponse.ProtoReflect.Descriptor instead.

func (*BatchCreateLogsResponse) ProtoMessage 

func (*BatchCreateLogsResponse) ProtoMessage()

func (*BatchCreateLogsResponse) ProtoReflect 

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

func (*BatchCreateLogsResponse) Reset 

func (x *BatchCreateLogsResponse) Reset()

func (*BatchCreateLogsResponse) String 

func (x *BatchCreateLogsResponse) String() string

type Event 

type Event struct {

	// The time in microseconds at which this event took place (as opposed to
	// the time at which this event was ingested).
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// The time in microseconds at which the event was collected.
	CollectionTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=collection_time,json=collectionTime,proto3" json:"collection_time,omitempty"`
	// Payload carries event-specific information.
	//
	// Types that are assignable to Payload:
	//
	//	*Event_AgentStats
	Payload isEvent_Payload `protobuf_oneof:"payload"`
	// Source info for this event, if not present batch source is effective.
	Source *EventSource `protobuf:"bytes,7,opt,name=source,proto3" json:"source,omitempty"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetAgentStats 

func (x *Event) GetAgentStats() *AgentStatsEvent

func (*Event) GetCollectionTime 

func (x *Event) GetCollectionTime() *timestamppb.Timestamp

func (*Event) GetPayload 

func (m *Event) GetPayload() isEvent_Payload

func (*Event) GetSource 

func (x *Event) GetSource() *EventSource

func (*Event) GetTimestamp 

func (x *Event) GetTimestamp() *timestamppb.Timestamp

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

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

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type EventBatch 

type EventBatch struct {

	// Unique id (used to de-duplicate the batch).
	Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Source info common to all events in this batch.
	Source *EventSource         `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	Type   EventBatch_EventType `protobuf:"varint,3,opt,name=type,proto3,enum=malachite.ingestion.v2.EventBatch_EventType" json:"type,omitempty"`
	// The actual events.
	// A single batch should contain no more than 10,000 events.
	Events []*Event `protobuf:"bytes,4,rep,name=events,proto3" json:"events,omitempty"`
	// Timestamp the collector started.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// contains filtered or unexported fields
}

A batch of events.

func (*EventBatch) Descriptor deprecated 

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

Deprecated: Use EventBatch.ProtoReflect.Descriptor instead.

func (*EventBatch) GetEvents 

func (x *EventBatch) GetEvents() []*Event

func (*EventBatch) GetId 

func (x *EventBatch) GetId() []byte

func (*EventBatch) GetSource 

func (x *EventBatch) GetSource() *EventSource

func (*EventBatch) GetStartTime 

func (x *EventBatch) GetStartTime() *timestamppb.Timestamp

func (*EventBatch) GetType 

func (x *EventBatch) GetType() EventBatch_EventType

func (*EventBatch) ProtoMessage 

func (*EventBatch) ProtoMessage()

func (*EventBatch) ProtoReflect 

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

func (*EventBatch) Reset 

func (x *EventBatch) Reset()

func (*EventBatch) String 

func (x *EventBatch) String() string

type EventBatch_EventType 

type EventBatch_EventType int32

Event type common to all events in this batch. 

const (
	EventBatch_UNSPECIFIED EventBatch_EventType = 0
	EventBatch_AGENT_STATS EventBatch_EventType = 25
)

func (EventBatch_EventType) Descriptor 

func (EventBatch_EventType) Descriptor() protoreflect.EnumDescriptor

func (EventBatch_EventType) Enum 

func (x EventBatch_EventType) Enum() *EventBatch_EventType

func (EventBatch_EventType) EnumDescriptor deprecated 

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

Deprecated: Use EventBatch_EventType.Descriptor instead.

func (EventBatch_EventType) Number 

func (x EventBatch_EventType) Number() protoreflect.EnumNumber

func (EventBatch_EventType) String 

func (x EventBatch_EventType) String() string

func (EventBatch_EventType) Type 

func (EventBatch_EventType) Type() protoreflect.EnumType

type EventSource 

type EventSource struct {

	// Customer GUID.
	CustomerId []byte `protobuf:"bytes,1,opt,name=customer_id,json=customerId,proto3" json:"customer_id,omitempty"`
	// Collector GUID.
	CollectorId []byte `protobuf:"bytes,2,opt,name=collector_id,json=collectorId,proto3" json:"collector_id,omitempty"`
	// Source file name.
	Filename string `protobuf:"bytes,3,opt,name=filename,proto3" json:"filename,omitempty"`
	// The user-configured environment namespace to identify the data domain the
	// logs originated from. This namespace will be used as a tag to identify the
	// appropriate data domain for indexing and enrichment functionality.
	Namespace string `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// The user-configured custom metadata labels required by the customer
	Labels []*Label `protobuf:"bytes,5,rep,name=labels,proto3" json:"labels,omitempty"`
	// contains filtered or unexported fields
}

Information about the source collection point. In the future we can extend this message to include additional metadata such as location, division, subnet, etc.

func (*EventSource) Descriptor deprecated 

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

Deprecated: Use EventSource.ProtoReflect.Descriptor instead.

func (*EventSource) GetCollectorId 

func (x *EventSource) GetCollectorId() []byte

func (*EventSource) GetCustomerId 

func (x *EventSource) GetCustomerId() []byte

func (*EventSource) GetFilename 

func (x *EventSource) GetFilename() string

func (*EventSource) GetLabels 

func (x *EventSource) GetLabels() []*Label

func (*EventSource) GetNamespace 

func (x *EventSource) GetNamespace() string

func (*EventSource) ProtoMessage 

func (*EventSource) ProtoMessage()

func (*EventSource) ProtoReflect 

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

func (*EventSource) Reset 

func (x *EventSource) Reset()

func (*EventSource) String 

func (x *EventSource) String() string

type Event_AgentStats 

type Event_AgentStats struct {
	// Stats about the collection agent.
	AgentStats *AgentStatsEvent `protobuf:"bytes,24,opt,name=agent_stats,json=agentStats,proto3,oneof"`
}

type ExporterStats 

type ExporterStats struct {

	// Name of the exporter.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Number of logs sent.
	AcceptedSpans int64 `protobuf:"varint,2,opt,name=accepted_spans,json=acceptedSpans,proto3" json:"accepted_spans,omitempty"`
	// Number of logs dropped.
	RefusedSpans int64 `protobuf:"varint,3,opt,name=refused_spans,json=refusedSpans,proto3" json:"refused_spans,omitempty"`
	// Capacity of the queue.
	QueueCapacity int64 `protobuf:"varint,4,opt,name=queue_capacity,json=queueCapacity,proto3" json:"queue_capacity,omitempty"`
	// Current size of the queue.
	QueueSize int64 `protobuf:"varint,5,opt,name=queue_size,json=queueSize,proto3" json:"queue_size,omitempty"`
	// contains filtered or unexported fields
}

Stats about the exporter. NEXT TAG: 6

func (*ExporterStats) Descriptor deprecated 

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

Deprecated: Use ExporterStats.ProtoReflect.Descriptor instead.

func (*ExporterStats) GetAcceptedSpans 

func (x *ExporterStats) GetAcceptedSpans() int64

func (*ExporterStats) GetName 

func (x *ExporterStats) GetName() string

func (*ExporterStats) GetQueueCapacity 

func (x *ExporterStats) GetQueueCapacity() int64

func (*ExporterStats) GetQueueSize 

func (x *ExporterStats) GetQueueSize() int64

func (*ExporterStats) GetRefusedSpans 

func (x *ExporterStats) GetRefusedSpans() int64

func (*ExporterStats) ProtoMessage 

func (*ExporterStats) ProtoMessage()

func (*ExporterStats) ProtoReflect 

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

func (*ExporterStats) Reset 

func (x *ExporterStats) Reset()

func (*ExporterStats) String 

func (x *ExporterStats) String() string

type ImportLogsRequest 

type ImportLogsRequest struct {

	// The parent, which owns this collection of logs.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Types that are assignable to Source:
	//
	//	*ImportLogsRequest_InlineSource
	Source isImportLogsRequest_Source `protobuf_oneof:"source"`
	// Opaque hint to help parsing the log.
	Hint string `protobuf:"bytes,4,opt,name=hint,proto3" json:"hint,omitempty"`
	// contains filtered or unexported fields
}

func (*ImportLogsRequest) Descriptor deprecated 

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

Deprecated: Use ImportLogsRequest.ProtoReflect.Descriptor instead.

func (*ImportLogsRequest) GetHint 

func (x *ImportLogsRequest) GetHint() string

func (*ImportLogsRequest) GetInlineSource 

func (x *ImportLogsRequest) GetInlineSource() *ImportLogsRequest_LogsInlineSource

func (*ImportLogsRequest) GetParent 

func (x *ImportLogsRequest) GetParent() string

func (*ImportLogsRequest) GetSource 

func (m *ImportLogsRequest) GetSource() isImportLogsRequest_Source

func (*ImportLogsRequest) ProtoMessage 

func (*ImportLogsRequest) ProtoMessage()

func (*ImportLogsRequest) ProtoReflect 

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

func (*ImportLogsRequest) Reset 

func (x *ImportLogsRequest) Reset()

func (*ImportLogsRequest) String 

func (x *ImportLogsRequest) String() string

type ImportLogsRequest_InlineSource 

type ImportLogsRequest_InlineSource struct {
	// Logs to be imported are specified inline.
	InlineSource *ImportLogsRequest_LogsInlineSource `protobuf:"bytes,2,opt,name=inline_source,json=inlineSource,proto3,oneof"`
}

type ImportLogsRequest_LogsInlineSource 

type ImportLogsRequest_LogsInlineSource struct {

	// The logs being imported.
	Logs []*Log `protobuf:"bytes,1,rep,name=logs,proto3" json:"logs,omitempty"`
	// The forwarder sending this import request.
	Forwarder string `protobuf:"bytes,2,opt,name=forwarder,proto3" json:"forwarder,omitempty"`
	// Source file name. Populated for certain types of files processed by the
	// outofband processor which may have metadata encoded in it for use by
	// the parser.
	SourceFilename string `protobuf:"bytes,3,opt,name=source_filename,json=sourceFilename,proto3" json:"source_filename,omitempty"`
	// contains filtered or unexported fields
}

A import source with the logs to import included inline.

func (*ImportLogsRequest_LogsInlineSource) Descriptor deprecated 

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

Deprecated: Use ImportLogsRequest_LogsInlineSource.ProtoReflect.Descriptor instead.

func (*ImportLogsRequest_LogsInlineSource) GetForwarder 

func (x *ImportLogsRequest_LogsInlineSource) GetForwarder() string

func (*ImportLogsRequest_LogsInlineSource) GetLogs 

func (x *ImportLogsRequest_LogsInlineSource) GetLogs() []*Log

func (*ImportLogsRequest_LogsInlineSource) GetSourceFilename 

func (x *ImportLogsRequest_LogsInlineSource) GetSourceFilename() string

func (*ImportLogsRequest_LogsInlineSource) ProtoMessage 

func (*ImportLogsRequest_LogsInlineSource) ProtoMessage()

func (*ImportLogsRequest_LogsInlineSource) ProtoReflect 

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

func (*ImportLogsRequest_LogsInlineSource) Reset 

func (x *ImportLogsRequest_LogsInlineSource) Reset()

func (*ImportLogsRequest_LogsInlineSource) String 

func (x *ImportLogsRequest_LogsInlineSource) String() string

type IngestionServiceV2Client 

type IngestionServiceV2Client interface {
	// Submit a batch of events.
	BatchCreateEvents(ctx context.Context, in *BatchCreateEventsRequest, opts ...grpc.CallOption) (*BatchCreateEventsResponse, error)
	// Submit a batch of log entries.
	BatchCreateLogs(ctx context.Context, in *BatchCreateLogsRequest, opts ...grpc.CallOption) (*BatchCreateLogsResponse, error)
}

IngestionServiceV2Client is the client API for IngestionServiceV2 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 NewIngestionServiceV2Client 

func NewIngestionServiceV2Client(cc grpc.ClientConnInterface) IngestionServiceV2Client

type IngestionServiceV2Server 

type IngestionServiceV2Server interface {
	// Submit a batch of events.
	BatchCreateEvents(context.Context, *BatchCreateEventsRequest) (*BatchCreateEventsResponse, error)
	// Submit a batch of log entries.
	BatchCreateLogs(context.Context, *BatchCreateLogsRequest) (*BatchCreateLogsResponse, error)
	// contains filtered or unexported methods
}

IngestionServiceV2Server is the server API for IngestionServiceV2 service. All implementations must embed UnimplementedIngestionServiceV2Server for forward compatibility

type Label 

type Label struct {

	// The key.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The value.
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Key value labels.

func (*Label) Descriptor deprecated 

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

Deprecated: Use Label.ProtoReflect.Descriptor instead.

func (*Label) GetKey 

func (x *Label) GetKey() string

func (*Label) GetValue 

func (x *Label) GetValue() string

func (*Label) ProtoMessage 

func (*Label) ProtoMessage()

func (*Label) ProtoReflect 

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

func (*Label) Reset 

func (x *Label) Reset()

func (*Label) String 

func (x *Label) String() string

type Log 

type Log struct {

	// The resource name of this log.
	// Format:
	// projects/{project}/locations/{region}/instances/{instance}/logTypes/{log_type}/logs
	// /{log}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Raw data for the log entry.
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// Timestamp of the log entry.
	LogEntryTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=log_entry_time,json=logEntryTime,proto3" json:"log_entry_time,omitempty"`
	// The time at which the log entry was collected. Must be after the
	// log_entry_time.
	CollectionTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=collection_time,json=collectionTime,proto3" json:"collection_time,omitempty"`
	// The user-configured environment namespace to identify the data
	// domain the logs originated from. This namespace will be used as a tag to
	// identify the appropriate data domain for indexing and enrichment
	// functionality.
	EnvironmentNamespace string `protobuf:"bytes,5,opt,name=environment_namespace,json=environmentNamespace,proto3" json:"environment_namespace,omitempty"`
	// The user-configured custom metadata labels.
	Labels map[string]*Log_LogLabel `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

Represents a telemetry log.

func (*Log) Descriptor deprecated 

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

Deprecated: Use Log.ProtoReflect.Descriptor instead.

func (*Log) GetCollectionTime 

func (x *Log) GetCollectionTime() *timestamppb.Timestamp

func (*Log) GetData 

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

func (*Log) GetEnvironmentNamespace 

func (x *Log) GetEnvironmentNamespace() string

func (*Log) GetLabels 

func (x *Log) GetLabels() map[string]*Log_LogLabel

func (*Log) GetLogEntryTime 

func (x *Log) GetLogEntryTime() *timestamppb.Timestamp

func (*Log) GetName 

func (x *Log) GetName() string

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

type LogEntry 

type LogEntry struct {

	// Raw data for the log entry.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// Timestamp of the log entry if not self contained.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// The time at which the log entry was collected.
	CollectionTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=collection_time,json=collectionTime,proto3" json:"collection_time,omitempty"`
	// Location for the log entry, given as the name of a file in the IANA time
	// zone database. This is used to determine the offset from UTC for the log
	// entry. If not supplied, times in the log entry are assumed to be UTC.
	// Ex: "America/New_York"
	// See: https://en.wikipedia.org/wiki/List_of_tz_database_time_zones
	Timezone string `protobuf:"bytes,5,opt,name=timezone,proto3" json:"timezone,omitempty"`
	// Source info for this log entry, if not present batch source is effective.
	// This allows logs within a batch to be from multiple sources.
	Source *EventSource `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"`
	// contains filtered or unexported fields
}

NEXT TAG: 6

func (*LogEntry) Descriptor deprecated 

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

Deprecated: Use LogEntry.ProtoReflect.Descriptor instead.

func (*LogEntry) GetCollectionTime 

func (x *LogEntry) GetCollectionTime() *timestamppb.Timestamp

func (*LogEntry) GetData 

func (x *LogEntry) GetData() []byte

func (*LogEntry) GetSource 

func (x *LogEntry) GetSource() *EventSource

func (*LogEntry) GetTimestamp 

func (x *LogEntry) GetTimestamp() *timestamppb.Timestamp

func (*LogEntry) GetTimezone 

func (x *LogEntry) GetTimezone() string

func (*LogEntry) ProtoMessage 

func (*LogEntry) ProtoMessage()

func (*LogEntry) ProtoReflect 

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

func (*LogEntry) Reset 

func (x *LogEntry) Reset()

func (*LogEntry) String 

func (x *LogEntry) String() string

type LogEntryBatch 

type LogEntryBatch struct {

	// Unique id.
	Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Source information.
	Source *EventSource `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	// Log type in string.
	LogType string `protobuf:"bytes,9,opt,name=log_type,json=logType,proto3" json:"log_type,omitempty"`
	// Opaque hint to help parsing the log.
	Hint string `protobuf:"bytes,4,opt,name=hint,proto3" json:"hint,omitempty"`
	// Log entries in this batch.
	Entries []*LogEntry `protobuf:"bytes,5,rep,name=entries,proto3" json:"entries,omitempty"`
	// Timestamp the collector started.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// contains filtered or unexported fields
}

NEXT TAG: 10

func (*LogEntryBatch) Descriptor deprecated 

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

Deprecated: Use LogEntryBatch.ProtoReflect.Descriptor instead.

func (*LogEntryBatch) GetEntries 

func (x *LogEntryBatch) GetEntries() []*LogEntry

func (*LogEntryBatch) GetHint 

func (x *LogEntryBatch) GetHint() string

func (*LogEntryBatch) GetId 

func (x *LogEntryBatch) GetId() []byte

func (*LogEntryBatch) GetLogType 

func (x *LogEntryBatch) GetLogType() string

func (*LogEntryBatch) GetSource 

func (x *LogEntryBatch) GetSource() *EventSource

func (*LogEntryBatch) GetStartTime 

func (x *LogEntryBatch) GetStartTime() *timestamppb.Timestamp

func (*LogEntryBatch) ProtoMessage 

func (*LogEntryBatch) ProtoMessage()

func (*LogEntryBatch) ProtoReflect 

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

func (*LogEntryBatch) Reset 

func (x *LogEntryBatch) Reset()

func (*LogEntryBatch) String 

func (x *LogEntryBatch) String() string

type Log_LogLabel 

type Log_LogLabel struct {

	// The value of the label.
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Indicates whether this label can be used for Data RBAC.
	RbacEnabled bool `protobuf:"varint,2,opt,name=rbac_enabled,json=rbacEnabled,proto3" json:"rbac_enabled,omitempty"`
	// contains filtered or unexported fields
}

Label for a user configured custom metadata key.

func (*Log_LogLabel) Descriptor deprecated 

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

Deprecated: Use Log_LogLabel.ProtoReflect.Descriptor instead.

func (*Log_LogLabel) GetRbacEnabled 

func (x *Log_LogLabel) GetRbacEnabled() bool

func (*Log_LogLabel) GetValue 

func (x *Log_LogLabel) GetValue() string

func (*Log_LogLabel) ProtoMessage 

func (*Log_LogLabel) ProtoMessage()

func (*Log_LogLabel) ProtoReflect 

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

func (*Log_LogLabel) Reset 

func (x *Log_LogLabel) Reset()

func (*Log_LogLabel) String 

func (x *Log_LogLabel) String() string

type ProcessorStats 

type ProcessorStats struct {

	// Name of the processor.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Number of logs processed.
	AcceptedSpans int64 `protobuf:"varint,2,opt,name=accepted_spans,json=acceptedSpans,proto3" json:"accepted_spans,omitempty"`
	// number of logs dropped.
	RefusedSpans int64 `protobuf:"varint,3,opt,name=refused_spans,json=refusedSpans,proto3" json:"refused_spans,omitempty"`
	// contains filtered or unexported fields
}

Stats about the processor. NEXT TAG: 4

func (*ProcessorStats) Descriptor deprecated 

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

Deprecated: Use ProcessorStats.ProtoReflect.Descriptor instead.

func (*ProcessorStats) GetAcceptedSpans 

func (x *ProcessorStats) GetAcceptedSpans() int64

func (*ProcessorStats) GetName 

func (x *ProcessorStats) GetName() string

func (*ProcessorStats) GetRefusedSpans 

func (x *ProcessorStats) GetRefusedSpans() int64

func (*ProcessorStats) ProtoMessage 

func (*ProcessorStats) ProtoMessage()

func (*ProcessorStats) ProtoReflect 

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

func (*ProcessorStats) Reset 

func (x *ProcessorStats) Reset()

func (*ProcessorStats) String 

func (x *ProcessorStats) String() string

type ReceiverStats 

type ReceiverStats struct {

	// Name of the receiver.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Number of logs received.
	AcceptedSpans int64 `protobuf:"varint,2,opt,name=accepted_spans,json=acceptedSpans,proto3" json:"accepted_spans,omitempty"`
	// Number of logs dropped.
	RefusedSpans int64 `protobuf:"varint,3,opt,name=refused_spans,json=refusedSpans,proto3" json:"refused_spans,omitempty"`
	// contains filtered or unexported fields
}

Stats about the receiver. NEXT TAG: 4

func (*ReceiverStats) Descriptor deprecated 

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

Deprecated: Use ReceiverStats.ProtoReflect.Descriptor instead.

func (*ReceiverStats) GetAcceptedSpans 

func (x *ReceiverStats) GetAcceptedSpans() int64

func (*ReceiverStats) GetName 

func (x *ReceiverStats) GetName() string

func (*ReceiverStats) GetRefusedSpans 

func (x *ReceiverStats) GetRefusedSpans() int64

func (*ReceiverStats) ProtoMessage 

func (*ReceiverStats) ProtoMessage()

func (*ReceiverStats) ProtoReflect 

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

func (*ReceiverStats) Reset 

func (x *ReceiverStats) Reset()

func (*ReceiverStats) String 

func (x *ReceiverStats) String() string

type UnimplementedIngestionServiceV2Server 

type UnimplementedIngestionServiceV2Server struct {
}

UnimplementedIngestionServiceV2Server must be embedded to have forward compatible implementations.

func (UnimplementedIngestionServiceV2Server) BatchCreateEvents 

func (UnimplementedIngestionServiceV2Server) BatchCreateEvents(context.Context, *BatchCreateEventsRequest) (*BatchCreateEventsResponse, error)

func (UnimplementedIngestionServiceV2Server) BatchCreateLogs 

func (UnimplementedIngestionServiceV2Server) BatchCreateLogs(context.Context, *BatchCreateLogsRequest) (*BatchCreateLogsResponse, error)

type UnsafeIngestionServiceV2Server 

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

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

Source Files

View all Source files

Directories

Path Synopsis
Package mocks is a generated GoMock package.
 Package mocks is a generated GoMock package.

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.