timelinev1

package
v0.410.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	EventType_name = map[int32]string{
		0: "EVENT_TYPE_UNSPECIFIED",
		1: "EVENT_TYPE_LOG",
		2: "EVENT_TYPE_CALL",
		3: "EVENT_TYPE_DEPLOYMENT_CREATED",
		4: "EVENT_TYPE_DEPLOYMENT_UPDATED",
		5: "EVENT_TYPE_INGRESS",
		6: "EVENT_TYPE_CRON_SCHEDULED",
		7: "EVENT_TYPE_ASYNC_EXECUTE",
		8: "EVENT_TYPE_PUBSUB_PUBLISH",
		9: "EVENT_TYPE_PUBSUB_CONSUME",
	}
	EventType_value = map[string]int32{
		"EVENT_TYPE_UNSPECIFIED":        0,
		"EVENT_TYPE_LOG":                1,
		"EVENT_TYPE_CALL":               2,
		"EVENT_TYPE_DEPLOYMENT_CREATED": 3,
		"EVENT_TYPE_DEPLOYMENT_UPDATED": 4,
		"EVENT_TYPE_INGRESS":            5,
		"EVENT_TYPE_CRON_SCHEDULED":     6,
		"EVENT_TYPE_ASYNC_EXECUTE":      7,
		"EVENT_TYPE_PUBSUB_PUBLISH":     8,
		"EVENT_TYPE_PUBSUB_CONSUME":     9,
	}
)

Enum value maps for EventType.

View Source 
var (
	AsyncExecuteEventType_name = map[int32]string{
		0: "ASYNC_EXECUTE_EVENT_TYPE_UNSPECIFIED",
		1: "ASYNC_EXECUTE_EVENT_TYPE_CRON",
		2: "ASYNC_EXECUTE_EVENT_TYPE_PUBSUB",
	}
	AsyncExecuteEventType_value = map[string]int32{
		"ASYNC_EXECUTE_EVENT_TYPE_UNSPECIFIED": 0,
		"ASYNC_EXECUTE_EVENT_TYPE_CRON":        1,
		"ASYNC_EXECUTE_EVENT_TYPE_PUBSUB":      2,
	}
)

Enum value maps for AsyncExecuteEventType.

View Source 
var (
	LogLevel_name = map[int32]string{
		0:  "LOG_LEVEL_UNSPECIFIED",
		1:  "LOG_LEVEL_TRACE",
		5:  "LOG_LEVEL_DEBUG",
		9:  "LOG_LEVEL_INFO",
		13: "LOG_LEVEL_WARN",
		17: "LOG_LEVEL_ERROR",
	}
	LogLevel_value = map[string]int32{
		"LOG_LEVEL_UNSPECIFIED": 0,
		"LOG_LEVEL_TRACE":       1,
		"LOG_LEVEL_DEBUG":       5,
		"LOG_LEVEL_INFO":        9,
		"LOG_LEVEL_WARN":        13,
		"LOG_LEVEL_ERROR":       17,
	}
)

Enum value maps for LogLevel.

View Source 
var (
	GetTimelineRequest_Order_name = map[int32]string{
		0: "ORDER_UNSPECIFIED",
		1: "ORDER_ASC",
		2: "ORDER_DESC",
	}
	GetTimelineRequest_Order_value = map[string]int32{
		"ORDER_UNSPECIFIED": 0,
		"ORDER_ASC":         1,
		"ORDER_DESC":        2,
	}
)

Enum value maps for GetTimelineRequest_Order.

View Source 
var File_xyz_block_ftl_timeline_v1_event_proto protoreflect.FileDescriptor
View Source 
var File_xyz_block_ftl_timeline_v1_timeline_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AsyncExecuteEvent 

type AsyncExecuteEvent struct {
	DeploymentKey  string                 `protobuf:"bytes,1,opt,name=deployment_key,json=deploymentKey,proto3" json:"deployment_key,omitempty"`
	RequestKey     *string                `protobuf:"bytes,2,opt,name=request_key,json=requestKey,proto3,oneof" json:"request_key,omitempty"`
	VerbRef        *v1.Ref                `protobuf:"bytes,3,opt,name=verb_ref,json=verbRef,proto3" json:"verb_ref,omitempty"`
	Timestamp      *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Duration       *durationpb.Duration   `protobuf:"bytes,5,opt,name=duration,proto3" json:"duration,omitempty"`
	AsyncEventType AsyncExecuteEventType  `` /* 159-byte string literal not displayed */
	Error          *string                `protobuf:"bytes,7,opt,name=error,proto3,oneof" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*AsyncExecuteEvent) Descriptor deprecated 

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

Deprecated: Use AsyncExecuteEvent.ProtoReflect.Descriptor instead.

func (*AsyncExecuteEvent) GetAsyncEventType 

func (x *AsyncExecuteEvent) GetAsyncEventType() AsyncExecuteEventType

func (*AsyncExecuteEvent) GetDeploymentKey 

func (x *AsyncExecuteEvent) GetDeploymentKey() string

func (*AsyncExecuteEvent) GetDuration 

func (x *AsyncExecuteEvent) GetDuration() *durationpb.Duration

func (*AsyncExecuteEvent) GetError 

func (x *AsyncExecuteEvent) GetError() string

func (*AsyncExecuteEvent) GetRequestKey 

func (x *AsyncExecuteEvent) GetRequestKey() string

func (*AsyncExecuteEvent) GetTimestamp 

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

func (*AsyncExecuteEvent) GetVerbRef 

func (x *AsyncExecuteEvent) GetVerbRef() *v1.Ref

func (*AsyncExecuteEvent) ProtoMessage 

func (*AsyncExecuteEvent) ProtoMessage()

func (*AsyncExecuteEvent) ProtoReflect 

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

func (*AsyncExecuteEvent) Reset 

func (x *AsyncExecuteEvent) Reset()

func (*AsyncExecuteEvent) String 

func (x *AsyncExecuteEvent) String() string

type AsyncExecuteEventType 

type AsyncExecuteEventType int32
const (
	AsyncExecuteEventType_ASYNC_EXECUTE_EVENT_TYPE_UNSPECIFIED AsyncExecuteEventType = 0
	AsyncExecuteEventType_ASYNC_EXECUTE_EVENT_TYPE_CRON        AsyncExecuteEventType = 1
	AsyncExecuteEventType_ASYNC_EXECUTE_EVENT_TYPE_PUBSUB      AsyncExecuteEventType = 2
)

func (AsyncExecuteEventType) Descriptor 

func (AsyncExecuteEventType) Descriptor() protoreflect.EnumDescriptor

func (AsyncExecuteEventType) Enum 

func (x AsyncExecuteEventType) Enum() *AsyncExecuteEventType

func (AsyncExecuteEventType) EnumDescriptor deprecated 

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

Deprecated: Use AsyncExecuteEventType.Descriptor instead.

func (AsyncExecuteEventType) Number 

func (x AsyncExecuteEventType) Number() protoreflect.EnumNumber

func (AsyncExecuteEventType) String 

func (x AsyncExecuteEventType) String() string

func (AsyncExecuteEventType) Type 

func (AsyncExecuteEventType) Type() protoreflect.EnumType

type CallEvent 

type CallEvent struct {
	RequestKey         *string                `protobuf:"bytes,1,opt,name=request_key,json=requestKey,proto3,oneof" json:"request_key,omitempty"`
	DeploymentKey      string                 `protobuf:"bytes,2,opt,name=deployment_key,json=deploymentKey,proto3" json:"deployment_key,omitempty"`
	Timestamp          *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	SourceVerbRef      *v1.Ref                `protobuf:"bytes,11,opt,name=source_verb_ref,json=sourceVerbRef,proto3,oneof" json:"source_verb_ref,omitempty"`
	DestinationVerbRef *v1.Ref                `protobuf:"bytes,12,opt,name=destination_verb_ref,json=destinationVerbRef,proto3" json:"destination_verb_ref,omitempty"`
	Duration           *durationpb.Duration   `protobuf:"bytes,6,opt,name=duration,proto3" json:"duration,omitempty"`
	Request            string                 `protobuf:"bytes,7,opt,name=request,proto3" json:"request,omitempty"`
	Response           string                 `protobuf:"bytes,8,opt,name=response,proto3" json:"response,omitempty"`
	Error              *string                `protobuf:"bytes,9,opt,name=error,proto3,oneof" json:"error,omitempty"`
	Stack              *string                `protobuf:"bytes,10,opt,name=stack,proto3,oneof" json:"stack,omitempty"`
	// contains filtered or unexported fields
}

func (*CallEvent) Descriptor deprecated 

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

Deprecated: Use CallEvent.ProtoReflect.Descriptor instead.

func (*CallEvent) GetDeploymentKey 

func (x *CallEvent) GetDeploymentKey() string

func (*CallEvent) GetDestinationVerbRef 

func (x *CallEvent) GetDestinationVerbRef() *v1.Ref

func (*CallEvent) GetDuration 

func (x *CallEvent) GetDuration() *durationpb.Duration

func (*CallEvent) GetError 

func (x *CallEvent) GetError() string

func (*CallEvent) GetRequest 

func (x *CallEvent) GetRequest() string

func (*CallEvent) GetRequestKey 

func (x *CallEvent) GetRequestKey() string

func (*CallEvent) GetResponse 

func (x *CallEvent) GetResponse() string

func (*CallEvent) GetSourceVerbRef 

func (x *CallEvent) GetSourceVerbRef() *v1.Ref

func (*CallEvent) GetStack 

func (x *CallEvent) GetStack() string

func (*CallEvent) GetTimestamp 

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

func (*CallEvent) ProtoMessage 

func (*CallEvent) ProtoMessage()

func (*CallEvent) ProtoReflect 

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

func (*CallEvent) Reset 

func (x *CallEvent) Reset()

func (*CallEvent) String 

func (x *CallEvent) String() string

type CreateEventsRequest added in v0.410.0 

type CreateEventsRequest struct {
	Entries []*CreateEventsRequest_EventEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateEventsRequest) Descriptor deprecated added in v0.410.0 

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

Deprecated: Use CreateEventsRequest.ProtoReflect.Descriptor instead.

func (*CreateEventsRequest) GetEntries added in v0.410.0 

func (x *CreateEventsRequest) GetEntries() []*CreateEventsRequest_EventEntry

func (*CreateEventsRequest) ProtoMessage added in v0.410.0 

func (*CreateEventsRequest) ProtoMessage()

func (*CreateEventsRequest) ProtoReflect added in v0.410.0 

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

func (*CreateEventsRequest) Reset added in v0.410.0 

func (x *CreateEventsRequest) Reset()

func (*CreateEventsRequest) String added in v0.410.0 

func (x *CreateEventsRequest) String() string

type CreateEventsRequest_EventEntry added in v0.410.0 

type CreateEventsRequest_EventEntry struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Types that are assignable to Entry:
	//
	//	*CreateEventsRequest_EventEntry_Log
	//	*CreateEventsRequest_EventEntry_Call
	//	*CreateEventsRequest_EventEntry_DeploymentCreated
	//	*CreateEventsRequest_EventEntry_DeploymentUpdated
	//	*CreateEventsRequest_EventEntry_Ingress
	//	*CreateEventsRequest_EventEntry_CronScheduled
	//	*CreateEventsRequest_EventEntry_AsyncExecute
	//	*CreateEventsRequest_EventEntry_PubsubPublish
	//	*CreateEventsRequest_EventEntry_PubsubConsume
	Entry isCreateEventsRequest_EventEntry_Entry `protobuf_oneof:"entry"`
	// contains filtered or unexported fields
}

func (*CreateEventsRequest_EventEntry) Descriptor deprecated added in v0.410.0 

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

Deprecated: Use CreateEventsRequest_EventEntry.ProtoReflect.Descriptor instead.

func (*CreateEventsRequest_EventEntry) GetAsyncExecute added in v0.410.0 

func (x *CreateEventsRequest_EventEntry) GetAsyncExecute() *AsyncExecuteEvent

func (*CreateEventsRequest_EventEntry) GetCall added in v0.410.0 

func (x *CreateEventsRequest_EventEntry) GetCall() *CallEvent

func (*CreateEventsRequest_EventEntry) GetCronScheduled added in v0.410.0 

func (x *CreateEventsRequest_EventEntry) GetCronScheduled() *CronScheduledEvent

func (*CreateEventsRequest_EventEntry) GetDeploymentCreated added in v0.410.0 

func (x *CreateEventsRequest_EventEntry) GetDeploymentCreated() *DeploymentCreatedEvent

func (*CreateEventsRequest_EventEntry) GetDeploymentUpdated added in v0.410.0 

func (x *CreateEventsRequest_EventEntry) GetDeploymentUpdated() *DeploymentUpdatedEvent

func (*CreateEventsRequest_EventEntry) GetEntry added in v0.410.0 

func (m *CreateEventsRequest_EventEntry) GetEntry() isCreateEventsRequest_EventEntry_Entry

func (*CreateEventsRequest_EventEntry) GetIngress added in v0.410.0 

func (x *CreateEventsRequest_EventEntry) GetIngress() *IngressEvent

func (*CreateEventsRequest_EventEntry) GetLog added in v0.410.0 

func (x *CreateEventsRequest_EventEntry) GetLog() *LogEvent

func (*CreateEventsRequest_EventEntry) GetPubsubConsume added in v0.410.0 

func (x *CreateEventsRequest_EventEntry) GetPubsubConsume() *PubSubConsumeEvent

func (*CreateEventsRequest_EventEntry) GetPubsubPublish added in v0.410.0 

func (x *CreateEventsRequest_EventEntry) GetPubsubPublish() *PubSubPublishEvent

func (*CreateEventsRequest_EventEntry) GetTimestamp added in v0.410.0 

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

func (*CreateEventsRequest_EventEntry) ProtoMessage added in v0.410.0 

func (*CreateEventsRequest_EventEntry) ProtoMessage()

func (*CreateEventsRequest_EventEntry) ProtoReflect added in v0.410.0 

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

func (*CreateEventsRequest_EventEntry) Reset added in v0.410.0 

func (x *CreateEventsRequest_EventEntry) Reset()

func (*CreateEventsRequest_EventEntry) String added in v0.410.0 

func (x *CreateEventsRequest_EventEntry) String() string

type CreateEventsRequest_EventEntry_AsyncExecute added in v0.410.0 

type CreateEventsRequest_EventEntry_AsyncExecute struct {
	AsyncExecute *AsyncExecuteEvent `protobuf:"bytes,8,opt,name=async_execute,json=asyncExecute,proto3,oneof"`
}

type CreateEventsRequest_EventEntry_Call added in v0.410.0 

type CreateEventsRequest_EventEntry_Call struct {
	Call *CallEvent `protobuf:"bytes,3,opt,name=call,proto3,oneof"`
}

type CreateEventsRequest_EventEntry_CronScheduled added in v0.410.0 

type CreateEventsRequest_EventEntry_CronScheduled struct {
	CronScheduled *CronScheduledEvent `protobuf:"bytes,7,opt,name=cron_scheduled,json=cronScheduled,proto3,oneof"`
}

type CreateEventsRequest_EventEntry_DeploymentCreated added in v0.410.0 

type CreateEventsRequest_EventEntry_DeploymentCreated struct {
	DeploymentCreated *DeploymentCreatedEvent `protobuf:"bytes,4,opt,name=deployment_created,json=deploymentCreated,proto3,oneof"`
}

type CreateEventsRequest_EventEntry_DeploymentUpdated added in v0.410.0 

type CreateEventsRequest_EventEntry_DeploymentUpdated struct {
	DeploymentUpdated *DeploymentUpdatedEvent `protobuf:"bytes,5,opt,name=deployment_updated,json=deploymentUpdated,proto3,oneof"`
}

type CreateEventsRequest_EventEntry_Ingress added in v0.410.0 

type CreateEventsRequest_EventEntry_Ingress struct {
	Ingress *IngressEvent `protobuf:"bytes,6,opt,name=ingress,proto3,oneof"`
}

type CreateEventsRequest_EventEntry_Log added in v0.410.0 

type CreateEventsRequest_EventEntry_Log struct {
	Log *LogEvent `protobuf:"bytes,2,opt,name=log,proto3,oneof"`
}

type CreateEventsRequest_EventEntry_PubsubConsume added in v0.410.0 

type CreateEventsRequest_EventEntry_PubsubConsume struct {
	PubsubConsume *PubSubConsumeEvent `protobuf:"bytes,10,opt,name=pubsub_consume,json=pubsubConsume,proto3,oneof"`
}

type CreateEventsRequest_EventEntry_PubsubPublish added in v0.410.0 

type CreateEventsRequest_EventEntry_PubsubPublish struct {
	PubsubPublish *PubSubPublishEvent `protobuf:"bytes,9,opt,name=pubsub_publish,json=pubsubPublish,proto3,oneof"`
}

type CreateEventsResponse added in v0.410.0 

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

func (*CreateEventsResponse) Descriptor deprecated added in v0.410.0 

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

Deprecated: Use CreateEventsResponse.ProtoReflect.Descriptor instead.

func (*CreateEventsResponse) ProtoMessage added in v0.410.0 

func (*CreateEventsResponse) ProtoMessage()

func (*CreateEventsResponse) ProtoReflect added in v0.410.0 

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

func (*CreateEventsResponse) Reset added in v0.410.0 

func (x *CreateEventsResponse) Reset()

func (*CreateEventsResponse) String added in v0.410.0 

func (x *CreateEventsResponse) String() string

type CronScheduledEvent 

type CronScheduledEvent struct {
	DeploymentKey string                 `protobuf:"bytes,1,opt,name=deployment_key,json=deploymentKey,proto3" json:"deployment_key,omitempty"`
	VerbRef       *v1.Ref                `protobuf:"bytes,2,opt,name=verb_ref,json=verbRef,proto3" json:"verb_ref,omitempty"`
	Timestamp     *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Duration      *durationpb.Duration   `protobuf:"bytes,4,opt,name=duration,proto3" json:"duration,omitempty"`
	ScheduledAt   *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=scheduled_at,json=scheduledAt,proto3" json:"scheduled_at,omitempty"`
	Schedule      string                 `protobuf:"bytes,6,opt,name=schedule,proto3" json:"schedule,omitempty"`
	Error         *string                `protobuf:"bytes,7,opt,name=error,proto3,oneof" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*CronScheduledEvent) Descriptor deprecated 

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

Deprecated: Use CronScheduledEvent.ProtoReflect.Descriptor instead.

func (*CronScheduledEvent) GetDeploymentKey 

func (x *CronScheduledEvent) GetDeploymentKey() string

func (*CronScheduledEvent) GetDuration 

func (x *CronScheduledEvent) GetDuration() *durationpb.Duration

func (*CronScheduledEvent) GetError 

func (x *CronScheduledEvent) GetError() string

func (*CronScheduledEvent) GetSchedule 

func (x *CronScheduledEvent) GetSchedule() string

func (*CronScheduledEvent) GetScheduledAt 

func (x *CronScheduledEvent) GetScheduledAt() *timestamppb.Timestamp

func (*CronScheduledEvent) GetTimestamp 

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

func (*CronScheduledEvent) GetVerbRef 

func (x *CronScheduledEvent) GetVerbRef() *v1.Ref

func (*CronScheduledEvent) ProtoMessage 

func (*CronScheduledEvent) ProtoMessage()

func (*CronScheduledEvent) ProtoReflect 

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

func (*CronScheduledEvent) Reset 

func (x *CronScheduledEvent) Reset()

func (*CronScheduledEvent) String 

func (x *CronScheduledEvent) String() string

type DeleteOldEventsRequest 

type DeleteOldEventsRequest struct {
	EventType  EventType `` /* 130-byte string literal not displayed */
	AgeSeconds int64     `protobuf:"varint,2,opt,name=age_seconds,json=ageSeconds,proto3" json:"age_seconds,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteOldEventsRequest) Descriptor deprecated 

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

Deprecated: Use DeleteOldEventsRequest.ProtoReflect.Descriptor instead.

func (*DeleteOldEventsRequest) GetAgeSeconds 

func (x *DeleteOldEventsRequest) GetAgeSeconds() int64

func (*DeleteOldEventsRequest) GetEventType 

func (x *DeleteOldEventsRequest) GetEventType() EventType

func (*DeleteOldEventsRequest) ProtoMessage 

func (*DeleteOldEventsRequest) ProtoMessage()

func (*DeleteOldEventsRequest) ProtoReflect 

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

func (*DeleteOldEventsRequest) Reset 

func (x *DeleteOldEventsRequest) Reset()

func (*DeleteOldEventsRequest) String 

func (x *DeleteOldEventsRequest) String() string

type DeleteOldEventsResponse 

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

func (*DeleteOldEventsResponse) Descriptor deprecated 

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

Deprecated: Use DeleteOldEventsResponse.ProtoReflect.Descriptor instead.

func (*DeleteOldEventsResponse) GetDeletedCount 

func (x *DeleteOldEventsResponse) GetDeletedCount() int64

func (*DeleteOldEventsResponse) ProtoMessage 

func (*DeleteOldEventsResponse) ProtoMessage()

func (*DeleteOldEventsResponse) ProtoReflect 

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

func (*DeleteOldEventsResponse) Reset 

func (x *DeleteOldEventsResponse) Reset()

func (*DeleteOldEventsResponse) String 

func (x *DeleteOldEventsResponse) String() string

type DeploymentCreatedEvent 

type DeploymentCreatedEvent struct {
	Key         string  `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Language    string  `protobuf:"bytes,2,opt,name=language,proto3" json:"language,omitempty"`
	ModuleName  string  `protobuf:"bytes,3,opt,name=module_name,json=moduleName,proto3" json:"module_name,omitempty"`
	MinReplicas int32   `protobuf:"varint,4,opt,name=min_replicas,json=minReplicas,proto3" json:"min_replicas,omitempty"`
	Replaced    *string `protobuf:"bytes,5,opt,name=replaced,proto3,oneof" json:"replaced,omitempty"`
	// contains filtered or unexported fields
}

func (*DeploymentCreatedEvent) Descriptor deprecated 

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

Deprecated: Use DeploymentCreatedEvent.ProtoReflect.Descriptor instead.

func (*DeploymentCreatedEvent) GetKey 

func (x *DeploymentCreatedEvent) GetKey() string

func (*DeploymentCreatedEvent) GetLanguage 

func (x *DeploymentCreatedEvent) GetLanguage() string

func (*DeploymentCreatedEvent) GetMinReplicas 

func (x *DeploymentCreatedEvent) GetMinReplicas() int32

func (*DeploymentCreatedEvent) GetModuleName 

func (x *DeploymentCreatedEvent) GetModuleName() string

func (*DeploymentCreatedEvent) GetReplaced 

func (x *DeploymentCreatedEvent) GetReplaced() string

func (*DeploymentCreatedEvent) ProtoMessage 

func (*DeploymentCreatedEvent) ProtoMessage()

func (*DeploymentCreatedEvent) ProtoReflect 

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

func (*DeploymentCreatedEvent) Reset 

func (x *DeploymentCreatedEvent) Reset()

func (*DeploymentCreatedEvent) String 

func (x *DeploymentCreatedEvent) String() string

type DeploymentUpdatedEvent 

type DeploymentUpdatedEvent struct {
	Key             string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	MinReplicas     int32  `protobuf:"varint,2,opt,name=min_replicas,json=minReplicas,proto3" json:"min_replicas,omitempty"`
	PrevMinReplicas int32  `protobuf:"varint,3,opt,name=prev_min_replicas,json=prevMinReplicas,proto3" json:"prev_min_replicas,omitempty"`
	// contains filtered or unexported fields
}

func (*DeploymentUpdatedEvent) Descriptor deprecated 

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

Deprecated: Use DeploymentUpdatedEvent.ProtoReflect.Descriptor instead.

func (*DeploymentUpdatedEvent) GetKey 

func (x *DeploymentUpdatedEvent) GetKey() string

func (*DeploymentUpdatedEvent) GetMinReplicas 

func (x *DeploymentUpdatedEvent) GetMinReplicas() int32

func (*DeploymentUpdatedEvent) GetPrevMinReplicas 

func (x *DeploymentUpdatedEvent) GetPrevMinReplicas() int32

func (*DeploymentUpdatedEvent) ProtoMessage 

func (*DeploymentUpdatedEvent) ProtoMessage()

func (*DeploymentUpdatedEvent) ProtoReflect 

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

func (*DeploymentUpdatedEvent) Reset 

func (x *DeploymentUpdatedEvent) Reset()

func (*DeploymentUpdatedEvent) String 

func (x *DeploymentUpdatedEvent) String() string

type Event 

type Event struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Unique ID for event.
	Id int64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Entry:
	//
	//	*Event_Log
	//	*Event_Call
	//	*Event_DeploymentCreated
	//	*Event_DeploymentUpdated
	//	*Event_Ingress
	//	*Event_CronScheduled
	//	*Event_AsyncExecute
	//	*Event_PubsubPublish
	//	*Event_PubsubConsume
	Entry isEvent_Entry `protobuf_oneof:"entry"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetAsyncExecute 

func (x *Event) GetAsyncExecute() *AsyncExecuteEvent

func (*Event) GetCall 

func (x *Event) GetCall() *CallEvent

func (*Event) GetCronScheduled 

func (x *Event) GetCronScheduled() *CronScheduledEvent

func (*Event) GetDeploymentCreated 

func (x *Event) GetDeploymentCreated() *DeploymentCreatedEvent

func (*Event) GetDeploymentUpdated 

func (x *Event) GetDeploymentUpdated() *DeploymentUpdatedEvent

func (*Event) GetEntry 

func (m *Event) GetEntry() isEvent_Entry

func (*Event) GetId 

func (x *Event) GetId() int64

func (*Event) GetIngress 

func (x *Event) GetIngress() *IngressEvent

func (*Event) GetLog 

func (x *Event) GetLog() *LogEvent

func (*Event) GetPubsubConsume 

func (x *Event) GetPubsubConsume() *PubSubConsumeEvent

func (*Event) GetPubsubPublish 

func (x *Event) GetPubsubPublish() *PubSubPublishEvent

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 EventType 

type EventType int32
const (
	EventType_EVENT_TYPE_UNSPECIFIED        EventType = 0
	EventType_EVENT_TYPE_LOG                EventType = 1
	EventType_EVENT_TYPE_CALL               EventType = 2
	EventType_EVENT_TYPE_DEPLOYMENT_CREATED EventType = 3
	EventType_EVENT_TYPE_DEPLOYMENT_UPDATED EventType = 4
	EventType_EVENT_TYPE_INGRESS            EventType = 5
	EventType_EVENT_TYPE_CRON_SCHEDULED     EventType = 6
	EventType_EVENT_TYPE_ASYNC_EXECUTE      EventType = 7
	EventType_EVENT_TYPE_PUBSUB_PUBLISH     EventType = 8
	EventType_EVENT_TYPE_PUBSUB_CONSUME     EventType = 9
)

func (EventType) Descriptor 

func (EventType) Descriptor() protoreflect.EnumDescriptor

func (EventType) Enum 

func (x EventType) Enum() *EventType

func (EventType) EnumDescriptor deprecated 

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

Deprecated: Use EventType.Descriptor instead.

func (EventType) Number 

func (x EventType) Number() protoreflect.EnumNumber

func (EventType) String 

func (x EventType) String() string

func (EventType) Type 

func (EventType) Type() protoreflect.EnumType

type Event_AsyncExecute 

type Event_AsyncExecute struct {
	AsyncExecute *AsyncExecuteEvent `protobuf:"bytes,9,opt,name=async_execute,json=asyncExecute,proto3,oneof"`
}

type Event_Call 

type Event_Call struct {
	Call *CallEvent `protobuf:"bytes,4,opt,name=call,proto3,oneof"`
}

type Event_CronScheduled 

type Event_CronScheduled struct {
	CronScheduled *CronScheduledEvent `protobuf:"bytes,8,opt,name=cron_scheduled,json=cronScheduled,proto3,oneof"`
}

type Event_DeploymentCreated 

type Event_DeploymentCreated struct {
	DeploymentCreated *DeploymentCreatedEvent `protobuf:"bytes,5,opt,name=deployment_created,json=deploymentCreated,proto3,oneof"`
}

type Event_DeploymentUpdated 

type Event_DeploymentUpdated struct {
	DeploymentUpdated *DeploymentUpdatedEvent `protobuf:"bytes,6,opt,name=deployment_updated,json=deploymentUpdated,proto3,oneof"`
}

type Event_Ingress 

type Event_Ingress struct {
	Ingress *IngressEvent `protobuf:"bytes,7,opt,name=ingress,proto3,oneof"`
}

type Event_Log 

type Event_Log struct {
	Log *LogEvent `protobuf:"bytes,3,opt,name=log,proto3,oneof"`
}

type Event_PubsubConsume 

type Event_PubsubConsume struct {
	PubsubConsume *PubSubConsumeEvent `protobuf:"bytes,11,opt,name=pubsub_consume,json=pubsubConsume,proto3,oneof"`
}

type Event_PubsubPublish 

type Event_PubsubPublish struct {
	PubsubPublish *PubSubPublishEvent `protobuf:"bytes,10,opt,name=pubsub_publish,json=pubsubPublish,proto3,oneof"`
}

type GetTimelineRequest 

type GetTimelineRequest struct {
	Filters []*GetTimelineRequest_Filter `protobuf:"bytes,1,rep,name=filters,proto3" json:"filters,omitempty"`
	Limit   int32                        `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// Ordering is done by id which matches publication order.
	// This roughly corresponds to the time of the event, but not strictly.
	Order GetTimelineRequest_Order `protobuf:"varint,3,opt,name=order,proto3,enum=xyz.block.ftl.timeline.v1.GetTimelineRequest_Order" json:"order,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTimelineRequest) Descriptor deprecated 

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

Deprecated: Use GetTimelineRequest.ProtoReflect.Descriptor instead.

func (*GetTimelineRequest) GetFilters 

func (x *GetTimelineRequest) GetFilters() []*GetTimelineRequest_Filter

func (*GetTimelineRequest) GetLimit 

func (x *GetTimelineRequest) GetLimit() int32

func (*GetTimelineRequest) GetOrder 

func (x *GetTimelineRequest) GetOrder() GetTimelineRequest_Order

func (*GetTimelineRequest) ProtoMessage 

func (*GetTimelineRequest) ProtoMessage()

func (*GetTimelineRequest) ProtoReflect 

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

func (*GetTimelineRequest) Reset 

func (x *GetTimelineRequest) Reset()

func (*GetTimelineRequest) String 

func (x *GetTimelineRequest) String() string

type GetTimelineRequest_CallFilter 

type GetTimelineRequest_CallFilter struct {
	DestModule   string  `protobuf:"bytes,1,opt,name=dest_module,json=destModule,proto3" json:"dest_module,omitempty"`
	DestVerb     *string `protobuf:"bytes,2,opt,name=dest_verb,json=destVerb,proto3,oneof" json:"dest_verb,omitempty"`
	SourceModule *string `protobuf:"bytes,3,opt,name=source_module,json=sourceModule,proto3,oneof" json:"source_module,omitempty"`
	// contains filtered or unexported fields
}

Filters events by call.

func (*GetTimelineRequest_CallFilter) Descriptor deprecated 

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

Deprecated: Use GetTimelineRequest_CallFilter.ProtoReflect.Descriptor instead.

func (*GetTimelineRequest_CallFilter) GetDestModule 

func (x *GetTimelineRequest_CallFilter) GetDestModule() string

func (*GetTimelineRequest_CallFilter) GetDestVerb 

func (x *GetTimelineRequest_CallFilter) GetDestVerb() string

func (*GetTimelineRequest_CallFilter) GetSourceModule 

func (x *GetTimelineRequest_CallFilter) GetSourceModule() string

func (*GetTimelineRequest_CallFilter) ProtoMessage 

func (*GetTimelineRequest_CallFilter) ProtoMessage()

func (*GetTimelineRequest_CallFilter) ProtoReflect 

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

func (*GetTimelineRequest_CallFilter) Reset 

func (x *GetTimelineRequest_CallFilter) Reset()

func (*GetTimelineRequest_CallFilter) String 

func (x *GetTimelineRequest_CallFilter) String() string

type GetTimelineRequest_DeploymentFilter 

type GetTimelineRequest_DeploymentFilter struct {
	Deployments []string `protobuf:"bytes,1,rep,name=deployments,proto3" json:"deployments,omitempty"`
	// contains filtered or unexported fields
}

Filters events by deployment key.

func (*GetTimelineRequest_DeploymentFilter) Descriptor deprecated 

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

Deprecated: Use GetTimelineRequest_DeploymentFilter.ProtoReflect.Descriptor instead.

func (*GetTimelineRequest_DeploymentFilter) GetDeployments 

func (x *GetTimelineRequest_DeploymentFilter) GetDeployments() []string

func (*GetTimelineRequest_DeploymentFilter) ProtoMessage 

func (*GetTimelineRequest_DeploymentFilter) ProtoMessage()

func (*GetTimelineRequest_DeploymentFilter) ProtoReflect 

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

func (*GetTimelineRequest_DeploymentFilter) Reset 

func (x *GetTimelineRequest_DeploymentFilter) Reset()

func (*GetTimelineRequest_DeploymentFilter) String 

func (x *GetTimelineRequest_DeploymentFilter) String() string

type GetTimelineRequest_EventTypeFilter 

type GetTimelineRequest_EventTypeFilter struct {
	EventTypes []EventType `` /* 140-byte string literal not displayed */
	// contains filtered or unexported fields
}

Filters events by event type.

func (*GetTimelineRequest_EventTypeFilter) Descriptor deprecated 

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

Deprecated: Use GetTimelineRequest_EventTypeFilter.ProtoReflect.Descriptor instead.

func (*GetTimelineRequest_EventTypeFilter) GetEventTypes 

func (x *GetTimelineRequest_EventTypeFilter) GetEventTypes() []EventType

func (*GetTimelineRequest_EventTypeFilter) ProtoMessage 

func (*GetTimelineRequest_EventTypeFilter) ProtoMessage()

func (*GetTimelineRequest_EventTypeFilter) ProtoReflect 

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

func (*GetTimelineRequest_EventTypeFilter) Reset 

func (x *GetTimelineRequest_EventTypeFilter) Reset()

func (*GetTimelineRequest_EventTypeFilter) String 

func (x *GetTimelineRequest_EventTypeFilter) String() string

type GetTimelineRequest_Filter 

type GetTimelineRequest_Filter struct {

	// These map 1:1 with filters in backend/timeline/filters.go
	//
	// Types that are assignable to Filter:
	//
	//	*GetTimelineRequest_Filter_LogLevel
	//	*GetTimelineRequest_Filter_Deployments
	//	*GetTimelineRequest_Filter_Requests
	//	*GetTimelineRequest_Filter_EventTypes
	//	*GetTimelineRequest_Filter_Time
	//	*GetTimelineRequest_Filter_Id
	//	*GetTimelineRequest_Filter_Call
	//	*GetTimelineRequest_Filter_Module
	Filter isGetTimelineRequest_Filter_Filter `protobuf_oneof:"filter"`
	// contains filtered or unexported fields
}

func (*GetTimelineRequest_Filter) Descriptor deprecated 

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

Deprecated: Use GetTimelineRequest_Filter.ProtoReflect.Descriptor instead.

func (*GetTimelineRequest_Filter) GetCall 

func (x *GetTimelineRequest_Filter) GetCall() *GetTimelineRequest_CallFilter

func (*GetTimelineRequest_Filter) GetDeployments 

func (x *GetTimelineRequest_Filter) GetDeployments() *GetTimelineRequest_DeploymentFilter

func (*GetTimelineRequest_Filter) GetEventTypes 

func (x *GetTimelineRequest_Filter) GetEventTypes() *GetTimelineRequest_EventTypeFilter

func (*GetTimelineRequest_Filter) GetFilter 

func (m *GetTimelineRequest_Filter) GetFilter() isGetTimelineRequest_Filter_Filter

func (*GetTimelineRequest_Filter) GetId 

func (x *GetTimelineRequest_Filter) GetId() *GetTimelineRequest_IDFilter

func (*GetTimelineRequest_Filter) GetLogLevel 

func (x *GetTimelineRequest_Filter) GetLogLevel() *GetTimelineRequest_LogLevelFilter

func (*GetTimelineRequest_Filter) GetModule 

func (x *GetTimelineRequest_Filter) GetModule() *GetTimelineRequest_ModuleFilter

func (*GetTimelineRequest_Filter) GetRequests 

func (x *GetTimelineRequest_Filter) GetRequests() *GetTimelineRequest_RequestFilter

func (*GetTimelineRequest_Filter) GetTime 

func (x *GetTimelineRequest_Filter) GetTime() *GetTimelineRequest_TimeFilter

func (*GetTimelineRequest_Filter) ProtoMessage 

func (*GetTimelineRequest_Filter) ProtoMessage()

func (*GetTimelineRequest_Filter) ProtoReflect 

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

func (*GetTimelineRequest_Filter) Reset 

func (x *GetTimelineRequest_Filter) Reset()

func (*GetTimelineRequest_Filter) String 

func (x *GetTimelineRequest_Filter) String() string

type GetTimelineRequest_Filter_Call 

type GetTimelineRequest_Filter_Call struct {
	Call *GetTimelineRequest_CallFilter `protobuf:"bytes,7,opt,name=call,proto3,oneof"`
}

type GetTimelineRequest_Filter_Deployments 

type GetTimelineRequest_Filter_Deployments struct {
	Deployments *GetTimelineRequest_DeploymentFilter `protobuf:"bytes,2,opt,name=deployments,proto3,oneof"`
}

type GetTimelineRequest_Filter_EventTypes 

type GetTimelineRequest_Filter_EventTypes struct {
	EventTypes *GetTimelineRequest_EventTypeFilter `protobuf:"bytes,4,opt,name=event_types,json=eventTypes,proto3,oneof"`
}

type GetTimelineRequest_Filter_Id 

type GetTimelineRequest_Filter_Id struct {
	Id *GetTimelineRequest_IDFilter `protobuf:"bytes,6,opt,name=id,proto3,oneof"`
}

type GetTimelineRequest_Filter_LogLevel 

type GetTimelineRequest_Filter_LogLevel struct {
	LogLevel *GetTimelineRequest_LogLevelFilter `protobuf:"bytes,1,opt,name=log_level,json=logLevel,proto3,oneof"`
}

type GetTimelineRequest_Filter_Module 

type GetTimelineRequest_Filter_Module struct {
	Module *GetTimelineRequest_ModuleFilter `protobuf:"bytes,8,opt,name=module,proto3,oneof"`
}

type GetTimelineRequest_Filter_Requests 

type GetTimelineRequest_Filter_Requests struct {
	Requests *GetTimelineRequest_RequestFilter `protobuf:"bytes,3,opt,name=requests,proto3,oneof"`
}

type GetTimelineRequest_Filter_Time 

type GetTimelineRequest_Filter_Time struct {
	Time *GetTimelineRequest_TimeFilter `protobuf:"bytes,5,opt,name=time,proto3,oneof"`
}

type GetTimelineRequest_IDFilter 

type GetTimelineRequest_IDFilter struct {
	LowerThan  *int64 `protobuf:"varint,1,opt,name=lower_than,json=lowerThan,proto3,oneof" json:"lower_than,omitempty"`
	HigherThan *int64 `protobuf:"varint,2,opt,name=higher_than,json=higherThan,proto3,oneof" json:"higher_than,omitempty"`
	// contains filtered or unexported fields
}

Filters events by ID.

Either end of the ID range can be omitted to indicate no bound.

func (*GetTimelineRequest_IDFilter) Descriptor deprecated 

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

Deprecated: Use GetTimelineRequest_IDFilter.ProtoReflect.Descriptor instead.

func (*GetTimelineRequest_IDFilter) GetHigherThan 

func (x *GetTimelineRequest_IDFilter) GetHigherThan() int64

func (*GetTimelineRequest_IDFilter) GetLowerThan 

func (x *GetTimelineRequest_IDFilter) GetLowerThan() int64

func (*GetTimelineRequest_IDFilter) ProtoMessage 

func (*GetTimelineRequest_IDFilter) ProtoMessage()

func (*GetTimelineRequest_IDFilter) ProtoReflect 

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

func (*GetTimelineRequest_IDFilter) Reset 

func (x *GetTimelineRequest_IDFilter) Reset()

func (*GetTimelineRequest_IDFilter) String 

func (x *GetTimelineRequest_IDFilter) String() string

type GetTimelineRequest_LogLevelFilter 

type GetTimelineRequest_LogLevelFilter struct {
	LogLevel LogLevel `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

Filters events by log level.

func (*GetTimelineRequest_LogLevelFilter) Descriptor deprecated 

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

Deprecated: Use GetTimelineRequest_LogLevelFilter.ProtoReflect.Descriptor instead.

func (*GetTimelineRequest_LogLevelFilter) GetLogLevel 

func (x *GetTimelineRequest_LogLevelFilter) GetLogLevel() LogLevel

func (*GetTimelineRequest_LogLevelFilter) ProtoMessage 

func (*GetTimelineRequest_LogLevelFilter) ProtoMessage()

func (*GetTimelineRequest_LogLevelFilter) ProtoReflect 

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

func (*GetTimelineRequest_LogLevelFilter) Reset 

func (x *GetTimelineRequest_LogLevelFilter) Reset()

func (*GetTimelineRequest_LogLevelFilter) String 

func (x *GetTimelineRequest_LogLevelFilter) String() string

type GetTimelineRequest_ModuleFilter 

type GetTimelineRequest_ModuleFilter struct {
	Module string  `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	Verb   *string `protobuf:"bytes,2,opt,name=verb,proto3,oneof" json:"verb,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTimelineRequest_ModuleFilter) Descriptor deprecated 

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

Deprecated: Use GetTimelineRequest_ModuleFilter.ProtoReflect.Descriptor instead.

func (*GetTimelineRequest_ModuleFilter) GetModule 

func (x *GetTimelineRequest_ModuleFilter) GetModule() string

func (*GetTimelineRequest_ModuleFilter) GetVerb 

func (x *GetTimelineRequest_ModuleFilter) GetVerb() string

func (*GetTimelineRequest_ModuleFilter) ProtoMessage 

func (*GetTimelineRequest_ModuleFilter) ProtoMessage()

func (*GetTimelineRequest_ModuleFilter) ProtoReflect 

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

func (*GetTimelineRequest_ModuleFilter) Reset 

func (x *GetTimelineRequest_ModuleFilter) Reset()

func (*GetTimelineRequest_ModuleFilter) String 

func (x *GetTimelineRequest_ModuleFilter) String() string

type GetTimelineRequest_Order 

type GetTimelineRequest_Order int32
const (
	GetTimelineRequest_ORDER_UNSPECIFIED GetTimelineRequest_Order = 0
	GetTimelineRequest_ORDER_ASC         GetTimelineRequest_Order = 1
	GetTimelineRequest_ORDER_DESC        GetTimelineRequest_Order = 2
)

func (GetTimelineRequest_Order) Descriptor 

func (GetTimelineRequest_Order) Descriptor() protoreflect.EnumDescriptor

func (GetTimelineRequest_Order) Enum 

func (x GetTimelineRequest_Order) Enum() *GetTimelineRequest_Order

func (GetTimelineRequest_Order) EnumDescriptor deprecated 

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

Deprecated: Use GetTimelineRequest_Order.Descriptor instead.

func (GetTimelineRequest_Order) Number 

func (x GetTimelineRequest_Order) Number() protoreflect.EnumNumber

func (GetTimelineRequest_Order) String 

func (x GetTimelineRequest_Order) String() string

func (GetTimelineRequest_Order) Type 

func (GetTimelineRequest_Order) Type() protoreflect.EnumType

type GetTimelineRequest_RequestFilter 

type GetTimelineRequest_RequestFilter struct {
	Requests []string `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

Filters events by request key.

func (*GetTimelineRequest_RequestFilter) Descriptor deprecated 

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

Deprecated: Use GetTimelineRequest_RequestFilter.ProtoReflect.Descriptor instead.

func (*GetTimelineRequest_RequestFilter) GetRequests 

func (x *GetTimelineRequest_RequestFilter) GetRequests() []string

func (*GetTimelineRequest_RequestFilter) ProtoMessage 

func (*GetTimelineRequest_RequestFilter) ProtoMessage()

func (*GetTimelineRequest_RequestFilter) ProtoReflect 

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

func (*GetTimelineRequest_RequestFilter) Reset 

func (x *GetTimelineRequest_RequestFilter) Reset()

func (*GetTimelineRequest_RequestFilter) String 

func (x *GetTimelineRequest_RequestFilter) String() string

type GetTimelineRequest_TimeFilter 

type GetTimelineRequest_TimeFilter struct {
	OlderThan *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=older_than,json=olderThan,proto3,oneof" json:"older_than,omitempty"`
	NewerThan *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=newer_than,json=newerThan,proto3,oneof" json:"newer_than,omitempty"`
	// contains filtered or unexported fields
}

Filters events by time.

Either end of the time range can be omitted to indicate no bound.

func (*GetTimelineRequest_TimeFilter) Descriptor deprecated 

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

Deprecated: Use GetTimelineRequest_TimeFilter.ProtoReflect.Descriptor instead.

func (*GetTimelineRequest_TimeFilter) GetNewerThan 

func (x *GetTimelineRequest_TimeFilter) GetNewerThan() *timestamppb.Timestamp

func (*GetTimelineRequest_TimeFilter) GetOlderThan 

func (x *GetTimelineRequest_TimeFilter) GetOlderThan() *timestamppb.Timestamp

func (*GetTimelineRequest_TimeFilter) ProtoMessage 

func (*GetTimelineRequest_TimeFilter) ProtoMessage()

func (*GetTimelineRequest_TimeFilter) ProtoReflect 

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

func (*GetTimelineRequest_TimeFilter) Reset 

func (x *GetTimelineRequest_TimeFilter) Reset()

func (*GetTimelineRequest_TimeFilter) String 

func (x *GetTimelineRequest_TimeFilter) String() string

type GetTimelineResponse 

type GetTimelineResponse struct {
	Events []*Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// For pagination, this cursor is where we should start our next query
	Cursor *int64 `protobuf:"varint,2,opt,name=cursor,proto3,oneof" json:"cursor,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTimelineResponse) Descriptor deprecated 

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

Deprecated: Use GetTimelineResponse.ProtoReflect.Descriptor instead.

func (*GetTimelineResponse) GetCursor 

func (x *GetTimelineResponse) GetCursor() int64

func (*GetTimelineResponse) GetEvents 

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

func (*GetTimelineResponse) ProtoMessage 

func (*GetTimelineResponse) ProtoMessage()

func (*GetTimelineResponse) ProtoReflect 

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

func (*GetTimelineResponse) Reset 

func (x *GetTimelineResponse) Reset()

func (*GetTimelineResponse) String 

func (x *GetTimelineResponse) String() string

type IngressEvent 

type IngressEvent struct {
	DeploymentKey  string                 `protobuf:"bytes,1,opt,name=deployment_key,json=deploymentKey,proto3" json:"deployment_key,omitempty"`
	RequestKey     *string                `protobuf:"bytes,2,opt,name=request_key,json=requestKey,proto3,oneof" json:"request_key,omitempty"`
	VerbRef        *v1.Ref                `protobuf:"bytes,3,opt,name=verb_ref,json=verbRef,proto3" json:"verb_ref,omitempty"`
	Method         string                 `protobuf:"bytes,4,opt,name=method,proto3" json:"method,omitempty"`
	Path           string                 `protobuf:"bytes,5,opt,name=path,proto3" json:"path,omitempty"`
	StatusCode     int32                  `protobuf:"varint,7,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	Timestamp      *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Duration       *durationpb.Duration   `protobuf:"bytes,9,opt,name=duration,proto3" json:"duration,omitempty"`
	Request        string                 `protobuf:"bytes,10,opt,name=request,proto3" json:"request,omitempty"`
	RequestHeader  string                 `protobuf:"bytes,11,opt,name=request_header,json=requestHeader,proto3" json:"request_header,omitempty"`
	Response       string                 `protobuf:"bytes,12,opt,name=response,proto3" json:"response,omitempty"`
	ResponseHeader string                 `protobuf:"bytes,13,opt,name=response_header,json=responseHeader,proto3" json:"response_header,omitempty"`
	Error          *string                `protobuf:"bytes,14,opt,name=error,proto3,oneof" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*IngressEvent) Descriptor deprecated 

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

Deprecated: Use IngressEvent.ProtoReflect.Descriptor instead.

func (*IngressEvent) GetDeploymentKey 

func (x *IngressEvent) GetDeploymentKey() string

func (*IngressEvent) GetDuration 

func (x *IngressEvent) GetDuration() *durationpb.Duration

func (*IngressEvent) GetError 

func (x *IngressEvent) GetError() string

func (*IngressEvent) GetMethod 

func (x *IngressEvent) GetMethod() string

func (*IngressEvent) GetPath 

func (x *IngressEvent) GetPath() string

func (*IngressEvent) GetRequest 

func (x *IngressEvent) GetRequest() string

func (*IngressEvent) GetRequestHeader 

func (x *IngressEvent) GetRequestHeader() string

func (*IngressEvent) GetRequestKey 

func (x *IngressEvent) GetRequestKey() string

func (*IngressEvent) GetResponse 

func (x *IngressEvent) GetResponse() string

func (*IngressEvent) GetResponseHeader 

func (x *IngressEvent) GetResponseHeader() string

func (*IngressEvent) GetStatusCode 

func (x *IngressEvent) GetStatusCode() int32

func (*IngressEvent) GetTimestamp 

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

func (*IngressEvent) GetVerbRef 

func (x *IngressEvent) GetVerbRef() *v1.Ref

func (*IngressEvent) ProtoMessage 

func (*IngressEvent) ProtoMessage()

func (*IngressEvent) ProtoReflect 

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

func (*IngressEvent) Reset 

func (x *IngressEvent) Reset()

func (*IngressEvent) String 

func (x *IngressEvent) String() string

type LogEvent 

type LogEvent struct {
	DeploymentKey string                 `protobuf:"bytes,1,opt,name=deployment_key,json=deploymentKey,proto3" json:"deployment_key,omitempty"`
	RequestKey    *string                `protobuf:"bytes,2,opt,name=request_key,json=requestKey,proto3,oneof" json:"request_key,omitempty"`
	Timestamp     *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	LogLevel      int32                  `protobuf:"varint,4,opt,name=log_level,json=logLevel,proto3" json:"log_level,omitempty"`
	Attributes    map[string]string      `` /* 161-byte string literal not displayed */
	Message       string                 `protobuf:"bytes,6,opt,name=message,proto3" json:"message,omitempty"`
	Error         *string                `protobuf:"bytes,7,opt,name=error,proto3,oneof" json:"error,omitempty"`
	Stack         *string                `protobuf:"bytes,8,opt,name=stack,proto3,oneof" json:"stack,omitempty"`
	// contains filtered or unexported fields
}

func (*LogEvent) Descriptor deprecated 

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

Deprecated: Use LogEvent.ProtoReflect.Descriptor instead.

func (*LogEvent) GetAttributes 

func (x *LogEvent) GetAttributes() map[string]string

func (*LogEvent) GetDeploymentKey 

func (x *LogEvent) GetDeploymentKey() string

func (*LogEvent) GetError 

func (x *LogEvent) GetError() string

func (*LogEvent) GetLogLevel 

func (x *LogEvent) GetLogLevel() int32

func (*LogEvent) GetMessage 

func (x *LogEvent) GetMessage() string

func (*LogEvent) GetRequestKey 

func (x *LogEvent) GetRequestKey() string

func (*LogEvent) GetStack 

func (x *LogEvent) GetStack() string

func (*LogEvent) GetTimestamp 

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

func (*LogEvent) ProtoMessage 

func (*LogEvent) ProtoMessage()

func (*LogEvent) ProtoReflect 

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

func (*LogEvent) Reset 

func (x *LogEvent) Reset()

func (*LogEvent) String 

func (x *LogEvent) String() string

type LogLevel 

type LogLevel int32
const (
	LogLevel_LOG_LEVEL_UNSPECIFIED LogLevel = 0
	LogLevel_LOG_LEVEL_TRACE       LogLevel = 1
	LogLevel_LOG_LEVEL_DEBUG       LogLevel = 5
	LogLevel_LOG_LEVEL_INFO        LogLevel = 9
	LogLevel_LOG_LEVEL_WARN        LogLevel = 13
	LogLevel_LOG_LEVEL_ERROR       LogLevel = 17
)

func (LogLevel) Descriptor 

func (LogLevel) Descriptor() protoreflect.EnumDescriptor

func (LogLevel) Enum 

func (x LogLevel) Enum() *LogLevel

func (LogLevel) EnumDescriptor deprecated 

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

Deprecated: Use LogLevel.Descriptor instead.

func (LogLevel) Number 

func (x LogLevel) Number() protoreflect.EnumNumber

func (LogLevel) String 

func (x LogLevel) String() string

func (LogLevel) Type 

func (LogLevel) Type() protoreflect.EnumType

type PubSubConsumeEvent 

type PubSubConsumeEvent struct {
	DeploymentKey  string                 `protobuf:"bytes,1,opt,name=deployment_key,json=deploymentKey,proto3" json:"deployment_key,omitempty"`
	RequestKey     *string                `protobuf:"bytes,2,opt,name=request_key,json=requestKey,proto3,oneof" json:"request_key,omitempty"`
	DestVerbModule *string                `protobuf:"bytes,3,opt,name=dest_verb_module,json=destVerbModule,proto3,oneof" json:"dest_verb_module,omitempty"`
	DestVerbName   *string                `protobuf:"bytes,4,opt,name=dest_verb_name,json=destVerbName,proto3,oneof" json:"dest_verb_name,omitempty"`
	Timestamp      *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Duration       *durationpb.Duration   `protobuf:"bytes,6,opt,name=duration,proto3" json:"duration,omitempty"`
	Topic          string                 `protobuf:"bytes,7,opt,name=topic,proto3" json:"topic,omitempty"`
	Error          *string                `protobuf:"bytes,8,opt,name=error,proto3,oneof" json:"error,omitempty"`
	Partition      int32                  `protobuf:"varint,9,opt,name=partition,proto3" json:"partition,omitempty"`
	Offset         int64                  `protobuf:"varint,10,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*PubSubConsumeEvent) Descriptor deprecated 

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

Deprecated: Use PubSubConsumeEvent.ProtoReflect.Descriptor instead.

func (*PubSubConsumeEvent) GetDeploymentKey 

func (x *PubSubConsumeEvent) GetDeploymentKey() string

func (*PubSubConsumeEvent) GetDestVerbModule 

func (x *PubSubConsumeEvent) GetDestVerbModule() string

func (*PubSubConsumeEvent) GetDestVerbName 

func (x *PubSubConsumeEvent) GetDestVerbName() string

func (*PubSubConsumeEvent) GetDuration 

func (x *PubSubConsumeEvent) GetDuration() *durationpb.Duration

func (*PubSubConsumeEvent) GetError 

func (x *PubSubConsumeEvent) GetError() string

func (*PubSubConsumeEvent) GetOffset added in v0.410.0 

func (x *PubSubConsumeEvent) GetOffset() int64

func (*PubSubConsumeEvent) GetPartition added in v0.410.0 

func (x *PubSubConsumeEvent) GetPartition() int32

func (*PubSubConsumeEvent) GetRequestKey 

func (x *PubSubConsumeEvent) GetRequestKey() string

func (*PubSubConsumeEvent) GetTimestamp 

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

func (*PubSubConsumeEvent) GetTopic 

func (x *PubSubConsumeEvent) GetTopic() string

func (*PubSubConsumeEvent) ProtoMessage 

func (*PubSubConsumeEvent) ProtoMessage()

func (*PubSubConsumeEvent) ProtoReflect 

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

func (*PubSubConsumeEvent) Reset 

func (x *PubSubConsumeEvent) Reset()

func (*PubSubConsumeEvent) String 

func (x *PubSubConsumeEvent) String() string

type PubSubPublishEvent 

type PubSubPublishEvent struct {
	DeploymentKey string                 `protobuf:"bytes,1,opt,name=deployment_key,json=deploymentKey,proto3" json:"deployment_key,omitempty"`
	RequestKey    *string                `protobuf:"bytes,2,opt,name=request_key,json=requestKey,proto3,oneof" json:"request_key,omitempty"`
	VerbRef       *v1.Ref                `protobuf:"bytes,3,opt,name=verb_ref,json=verbRef,proto3" json:"verb_ref,omitempty"`
	Timestamp     *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Duration      *durationpb.Duration   `protobuf:"bytes,5,opt,name=duration,proto3" json:"duration,omitempty"`
	Topic         string                 `protobuf:"bytes,6,opt,name=topic,proto3" json:"topic,omitempty"`
	Request       string                 `protobuf:"bytes,7,opt,name=request,proto3" json:"request,omitempty"`
	Error         *string                `protobuf:"bytes,8,opt,name=error,proto3,oneof" json:"error,omitempty"`
	Partition     int32                  `protobuf:"varint,9,opt,name=partition,proto3" json:"partition,omitempty"`
	Offset        int64                  `protobuf:"varint,10,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*PubSubPublishEvent) Descriptor deprecated 

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

Deprecated: Use PubSubPublishEvent.ProtoReflect.Descriptor instead.

func (*PubSubPublishEvent) GetDeploymentKey 

func (x *PubSubPublishEvent) GetDeploymentKey() string

func (*PubSubPublishEvent) GetDuration 

func (x *PubSubPublishEvent) GetDuration() *durationpb.Duration

func (*PubSubPublishEvent) GetError 

func (x *PubSubPublishEvent) GetError() string

func (*PubSubPublishEvent) GetOffset added in v0.410.0 

func (x *PubSubPublishEvent) GetOffset() int64

func (*PubSubPublishEvent) GetPartition added in v0.410.0 

func (x *PubSubPublishEvent) GetPartition() int32

func (*PubSubPublishEvent) GetRequest 

func (x *PubSubPublishEvent) GetRequest() string

func (*PubSubPublishEvent) GetRequestKey 

func (x *PubSubPublishEvent) GetRequestKey() string

func (*PubSubPublishEvent) GetTimestamp 

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

func (*PubSubPublishEvent) GetTopic 

func (x *PubSubPublishEvent) GetTopic() string

func (*PubSubPublishEvent) GetVerbRef 

func (x *PubSubPublishEvent) GetVerbRef() *v1.Ref

func (*PubSubPublishEvent) ProtoMessage 

func (*PubSubPublishEvent) ProtoMessage()

func (*PubSubPublishEvent) ProtoReflect 

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

func (*PubSubPublishEvent) Reset 

func (x *PubSubPublishEvent) Reset()

func (*PubSubPublishEvent) String 

func (x *PubSubPublishEvent) String() string

type StreamTimelineRequest 

type StreamTimelineRequest struct {
	UpdateInterval *durationpb.Duration `protobuf:"bytes,1,opt,name=update_interval,json=updateInterval,proto3,oneof" json:"update_interval,omitempty"`
	Query          *GetTimelineRequest  `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamTimelineRequest) Descriptor deprecated 

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

Deprecated: Use StreamTimelineRequest.ProtoReflect.Descriptor instead.

func (*StreamTimelineRequest) GetQuery 

func (x *StreamTimelineRequest) GetQuery() *GetTimelineRequest

func (*StreamTimelineRequest) GetUpdateInterval 

func (x *StreamTimelineRequest) GetUpdateInterval() *durationpb.Duration

func (*StreamTimelineRequest) ProtoMessage 

func (*StreamTimelineRequest) ProtoMessage()

func (*StreamTimelineRequest) ProtoReflect 

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

func (*StreamTimelineRequest) Reset 

func (x *StreamTimelineRequest) Reset()

func (*StreamTimelineRequest) String 

func (x *StreamTimelineRequest) String() string

type StreamTimelineResponse 

type StreamTimelineResponse struct {
	Events []*Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamTimelineResponse) Descriptor deprecated 

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

Deprecated: Use StreamTimelineResponse.ProtoReflect.Descriptor instead.

func (*StreamTimelineResponse) GetEvents 

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

func (*StreamTimelineResponse) ProtoMessage 

func (*StreamTimelineResponse) ProtoMessage()

func (*StreamTimelineResponse) ProtoReflect 

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

func (*StreamTimelineResponse) Reset 

func (x *StreamTimelineResponse) Reset()

func (*StreamTimelineResponse) String 

func (x *StreamTimelineResponse) String() string

Source Files

View all Source files

Directories

Path Synopsis

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.