api

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
}

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

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

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

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

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
}

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
}

type EventBatch_EventType int32

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
}

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

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
}

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)
}

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
}

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
}

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
}

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
}

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
}

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
}

type UnimplementedIngestionServiceV2Server struct {
}

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