Documentation ¶
Index ¶
- Variables
- type AsyncExecuteEvent
- func (*AsyncExecuteEvent) Descriptor() ([]byte, []int)deprecated
- func (x *AsyncExecuteEvent) GetAsyncEventType() AsyncExecuteEventType
- func (x *AsyncExecuteEvent) GetDeploymentKey() string
- func (x *AsyncExecuteEvent) GetDuration() *durationpb.Duration
- func (x *AsyncExecuteEvent) GetError() string
- func (x *AsyncExecuteEvent) GetRequestKey() string
- func (x *AsyncExecuteEvent) GetTimeStamp() *timestamppb.Timestamp
- func (x *AsyncExecuteEvent) GetVerbRef() *schema.Ref
- func (*AsyncExecuteEvent) ProtoMessage()
- func (x *AsyncExecuteEvent) ProtoReflect() protoreflect.Message
- func (x *AsyncExecuteEvent) Reset()
- func (x *AsyncExecuteEvent) String() string
- type AsyncExecuteEventType
- func (AsyncExecuteEventType) Descriptor() protoreflect.EnumDescriptor
- func (x AsyncExecuteEventType) Enum() *AsyncExecuteEventType
- func (AsyncExecuteEventType) EnumDescriptor() ([]byte, []int)deprecated
- func (x AsyncExecuteEventType) Number() protoreflect.EnumNumber
- func (x AsyncExecuteEventType) String() string
- func (AsyncExecuteEventType) Type() protoreflect.EnumType
- type CallEvent
- func (*CallEvent) Descriptor() ([]byte, []int)deprecated
- func (x *CallEvent) GetDeploymentKey() string
- func (x *CallEvent) GetDestinationVerbRef() *schema.Ref
- func (x *CallEvent) GetDuration() *durationpb.Duration
- func (x *CallEvent) GetError() string
- func (x *CallEvent) GetRequest() string
- func (x *CallEvent) GetRequestKey() string
- func (x *CallEvent) GetResponse() string
- func (x *CallEvent) GetSourceVerbRef() *schema.Ref
- func (x *CallEvent) GetStack() string
- func (x *CallEvent) GetTimeStamp() *timestamppb.Timestamp
- func (*CallEvent) ProtoMessage()
- func (x *CallEvent) ProtoReflect() protoreflect.Message
- func (x *CallEvent) Reset()
- func (x *CallEvent) String() string
- type Config
- type CronScheduledEvent
- func (*CronScheduledEvent) Descriptor() ([]byte, []int)deprecated
- func (x *CronScheduledEvent) GetDeploymentKey() string
- func (x *CronScheduledEvent) GetDuration() *durationpb.Duration
- func (x *CronScheduledEvent) GetError() string
- func (x *CronScheduledEvent) GetSchedule() string
- func (x *CronScheduledEvent) GetScheduledAt() *timestamppb.Timestamp
- func (x *CronScheduledEvent) GetTimeStamp() *timestamppb.Timestamp
- func (x *CronScheduledEvent) GetVerbRef() *schema.Ref
- func (*CronScheduledEvent) ProtoMessage()
- func (x *CronScheduledEvent) ProtoReflect() protoreflect.Message
- func (x *CronScheduledEvent) Reset()
- func (x *CronScheduledEvent) String() string
- type Data
- func (*Data) Descriptor() ([]byte, []int)deprecated
- func (x *Data) GetData() *schema.Data
- func (x *Data) GetReferences() []*schema.Ref
- func (x *Data) GetSchema() string
- func (*Data) ProtoMessage()
- func (x *Data) ProtoReflect() protoreflect.Message
- func (x *Data) Reset()
- func (x *Data) String() string
- type Database
- func (*Database) Descriptor() ([]byte, []int)deprecated
- func (x *Database) GetDatabase() *schema.Database
- func (x *Database) GetReferences() []*schema.Ref
- func (*Database) ProtoMessage()
- func (x *Database) ProtoReflect() protoreflect.Message
- func (x *Database) Reset()
- func (x *Database) String() string
- type DeploymentCreatedEvent
- func (*DeploymentCreatedEvent) Descriptor() ([]byte, []int)deprecated
- func (x *DeploymentCreatedEvent) GetKey() string
- func (x *DeploymentCreatedEvent) GetLanguage() string
- func (x *DeploymentCreatedEvent) GetMinReplicas() int32
- func (x *DeploymentCreatedEvent) GetModuleName() string
- func (x *DeploymentCreatedEvent) GetReplaced() string
- func (*DeploymentCreatedEvent) ProtoMessage()
- func (x *DeploymentCreatedEvent) ProtoReflect() protoreflect.Message
- func (x *DeploymentCreatedEvent) Reset()
- func (x *DeploymentCreatedEvent) String() string
- type DeploymentUpdatedEvent
- func (*DeploymentUpdatedEvent) Descriptor() ([]byte, []int)deprecated
- func (x *DeploymentUpdatedEvent) GetKey() string
- func (x *DeploymentUpdatedEvent) GetMinReplicas() int32
- func (x *DeploymentUpdatedEvent) GetPrevMinReplicas() int32
- func (*DeploymentUpdatedEvent) ProtoMessage()
- func (x *DeploymentUpdatedEvent) ProtoReflect() protoreflect.Message
- func (x *DeploymentUpdatedEvent) Reset()
- func (x *DeploymentUpdatedEvent) String() string
- type Enum
- type Event
- func (*Event) Descriptor() ([]byte, []int)deprecated
- func (x *Event) GetAsyncExecute() *AsyncExecuteEvent
- func (x *Event) GetCall() *CallEvent
- func (x *Event) GetCronScheduled() *CronScheduledEvent
- func (x *Event) GetDeploymentCreated() *DeploymentCreatedEvent
- func (x *Event) GetDeploymentUpdated() *DeploymentUpdatedEvent
- func (m *Event) GetEntry() isEvent_Entry
- func (x *Event) GetId() int64
- func (x *Event) GetIngress() *IngressEvent
- func (x *Event) GetLog() *LogEvent
- func (x *Event) GetTimeStamp() *timestamppb.Timestamp
- func (*Event) ProtoMessage()
- func (x *Event) ProtoReflect() protoreflect.Message
- func (x *Event) Reset()
- func (x *Event) String() string
- type EventType
- type Event_AsyncExecute
- type Event_Call
- type Event_CronScheduled
- type Event_DeploymentCreated
- type Event_DeploymentUpdated
- type Event_Ingress
- type Event_Log
- type EventsQuery
- func (*EventsQuery) Descriptor() ([]byte, []int)deprecated
- func (x *EventsQuery) GetFilters() []*EventsQuery_Filter
- func (x *EventsQuery) GetLimit() int32
- func (x *EventsQuery) GetOrder() EventsQuery_Order
- func (*EventsQuery) ProtoMessage()
- func (x *EventsQuery) ProtoReflect() protoreflect.Message
- func (x *EventsQuery) Reset()
- func (x *EventsQuery) String() string
- type EventsQuery_CallFilter
- func (*EventsQuery_CallFilter) Descriptor() ([]byte, []int)deprecated
- func (x *EventsQuery_CallFilter) GetDestModule() string
- func (x *EventsQuery_CallFilter) GetDestVerb() string
- func (x *EventsQuery_CallFilter) GetSourceModule() string
- func (*EventsQuery_CallFilter) ProtoMessage()
- func (x *EventsQuery_CallFilter) ProtoReflect() protoreflect.Message
- func (x *EventsQuery_CallFilter) Reset()
- func (x *EventsQuery_CallFilter) String() string
- type EventsQuery_DeploymentFilter
- func (*EventsQuery_DeploymentFilter) Descriptor() ([]byte, []int)deprecated
- func (x *EventsQuery_DeploymentFilter) GetDeployments() []string
- func (*EventsQuery_DeploymentFilter) ProtoMessage()
- func (x *EventsQuery_DeploymentFilter) ProtoReflect() protoreflect.Message
- func (x *EventsQuery_DeploymentFilter) Reset()
- func (x *EventsQuery_DeploymentFilter) String() string
- type EventsQuery_EventTypeFilter
- func (*EventsQuery_EventTypeFilter) Descriptor() ([]byte, []int)deprecated
- func (x *EventsQuery_EventTypeFilter) GetEventTypes() []EventType
- func (*EventsQuery_EventTypeFilter) ProtoMessage()
- func (x *EventsQuery_EventTypeFilter) ProtoReflect() protoreflect.Message
- func (x *EventsQuery_EventTypeFilter) Reset()
- func (x *EventsQuery_EventTypeFilter) String() string
- type EventsQuery_Filter
- func (*EventsQuery_Filter) Descriptor() ([]byte, []int)deprecated
- func (x *EventsQuery_Filter) GetCall() *EventsQuery_CallFilter
- func (x *EventsQuery_Filter) GetDeployments() *EventsQuery_DeploymentFilter
- func (x *EventsQuery_Filter) GetEventTypes() *EventsQuery_EventTypeFilter
- func (m *EventsQuery_Filter) GetFilter() isEventsQuery_Filter_Filter
- func (x *EventsQuery_Filter) GetId() *EventsQuery_IDFilter
- func (x *EventsQuery_Filter) GetLimit() *EventsQuery_LimitFilter
- func (x *EventsQuery_Filter) GetLogLevel() *EventsQuery_LogLevelFilter
- func (x *EventsQuery_Filter) GetModule() *EventsQuery_ModuleFilter
- func (x *EventsQuery_Filter) GetRequests() *EventsQuery_RequestFilter
- func (x *EventsQuery_Filter) GetTime() *EventsQuery_TimeFilter
- func (*EventsQuery_Filter) ProtoMessage()
- func (x *EventsQuery_Filter) ProtoReflect() protoreflect.Message
- func (x *EventsQuery_Filter) Reset()
- func (x *EventsQuery_Filter) String() string
- type EventsQuery_Filter_Call
- type EventsQuery_Filter_Deployments
- type EventsQuery_Filter_EventTypes
- type EventsQuery_Filter_Id
- type EventsQuery_Filter_Limit
- type EventsQuery_Filter_LogLevel
- type EventsQuery_Filter_Module
- type EventsQuery_Filter_Requests
- type EventsQuery_Filter_Time
- type EventsQuery_IDFilter
- func (*EventsQuery_IDFilter) Descriptor() ([]byte, []int)deprecated
- func (x *EventsQuery_IDFilter) GetHigherThan() int64
- func (x *EventsQuery_IDFilter) GetLowerThan() int64
- func (*EventsQuery_IDFilter) ProtoMessage()
- func (x *EventsQuery_IDFilter) ProtoReflect() protoreflect.Message
- func (x *EventsQuery_IDFilter) Reset()
- func (x *EventsQuery_IDFilter) String() string
- type EventsQuery_LimitFilter
- func (*EventsQuery_LimitFilter) Descriptor() ([]byte, []int)deprecated
- func (x *EventsQuery_LimitFilter) GetLimit() int32
- func (*EventsQuery_LimitFilter) ProtoMessage()
- func (x *EventsQuery_LimitFilter) ProtoReflect() protoreflect.Message
- func (x *EventsQuery_LimitFilter) Reset()
- func (x *EventsQuery_LimitFilter) String() string
- type EventsQuery_LogLevelFilter
- func (*EventsQuery_LogLevelFilter) Descriptor() ([]byte, []int)deprecated
- func (x *EventsQuery_LogLevelFilter) GetLogLevel() LogLevel
- func (*EventsQuery_LogLevelFilter) ProtoMessage()
- func (x *EventsQuery_LogLevelFilter) ProtoReflect() protoreflect.Message
- func (x *EventsQuery_LogLevelFilter) Reset()
- func (x *EventsQuery_LogLevelFilter) String() string
- type EventsQuery_ModuleFilter
- func (*EventsQuery_ModuleFilter) Descriptor() ([]byte, []int)deprecated
- func (x *EventsQuery_ModuleFilter) GetModule() string
- func (x *EventsQuery_ModuleFilter) GetVerb() string
- func (*EventsQuery_ModuleFilter) ProtoMessage()
- func (x *EventsQuery_ModuleFilter) ProtoReflect() protoreflect.Message
- func (x *EventsQuery_ModuleFilter) Reset()
- func (x *EventsQuery_ModuleFilter) String() string
- type EventsQuery_Order
- func (EventsQuery_Order) Descriptor() protoreflect.EnumDescriptor
- func (x EventsQuery_Order) Enum() *EventsQuery_Order
- func (EventsQuery_Order) EnumDescriptor() ([]byte, []int)deprecated
- func (x EventsQuery_Order) Number() protoreflect.EnumNumber
- func (x EventsQuery_Order) String() string
- func (EventsQuery_Order) Type() protoreflect.EnumType
- type EventsQuery_RequestFilter
- func (*EventsQuery_RequestFilter) Descriptor() ([]byte, []int)deprecated
- func (x *EventsQuery_RequestFilter) GetRequests() []string
- func (*EventsQuery_RequestFilter) ProtoMessage()
- func (x *EventsQuery_RequestFilter) ProtoReflect() protoreflect.Message
- func (x *EventsQuery_RequestFilter) Reset()
- func (x *EventsQuery_RequestFilter) String() string
- type EventsQuery_TimeFilter
- func (*EventsQuery_TimeFilter) Descriptor() ([]byte, []int)deprecated
- func (x *EventsQuery_TimeFilter) GetNewerThan() *timestamppb.Timestamp
- func (x *EventsQuery_TimeFilter) GetOlderThan() *timestamppb.Timestamp
- func (*EventsQuery_TimeFilter) ProtoMessage()
- func (x *EventsQuery_TimeFilter) ProtoReflect() protoreflect.Message
- func (x *EventsQuery_TimeFilter) Reset()
- func (x *EventsQuery_TimeFilter) String() string
- type GetEventsResponse
- func (*GetEventsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetEventsResponse) GetCursor() int64
- func (x *GetEventsResponse) GetEvents() []*Event
- func (*GetEventsResponse) ProtoMessage()
- func (x *GetEventsResponse) ProtoReflect() protoreflect.Message
- func (x *GetEventsResponse) Reset()
- func (x *GetEventsResponse) String() string
- type GetModulesRequest
- type GetModulesResponse
- func (*GetModulesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetModulesResponse) GetModules() []*Module
- func (x *GetModulesResponse) GetTopology() *Topology
- func (*GetModulesResponse) ProtoMessage()
- func (x *GetModulesResponse) ProtoReflect() protoreflect.Message
- func (x *GetModulesResponse) Reset()
- func (x *GetModulesResponse) String() string
- type IngressEvent
- func (*IngressEvent) Descriptor() ([]byte, []int)deprecated
- func (x *IngressEvent) GetDeploymentKey() string
- func (x *IngressEvent) GetDuration() *durationpb.Duration
- func (x *IngressEvent) GetError() string
- func (x *IngressEvent) GetMethod() string
- func (x *IngressEvent) GetPath() string
- func (x *IngressEvent) GetRequest() string
- func (x *IngressEvent) GetRequestHeader() string
- func (x *IngressEvent) GetRequestKey() string
- func (x *IngressEvent) GetResponse() string
- func (x *IngressEvent) GetResponseHeader() string
- func (x *IngressEvent) GetStatusCode() int32
- func (x *IngressEvent) GetTimeStamp() *timestamppb.Timestamp
- func (x *IngressEvent) GetVerbRef() *schema.Ref
- func (*IngressEvent) ProtoMessage()
- func (x *IngressEvent) ProtoReflect() protoreflect.Message
- func (x *IngressEvent) Reset()
- func (x *IngressEvent) String() string
- type LogEvent
- func (*LogEvent) Descriptor() ([]byte, []int)deprecated
- func (x *LogEvent) GetAttributes() map[string]string
- func (x *LogEvent) GetDeploymentKey() string
- func (x *LogEvent) GetError() string
- func (x *LogEvent) GetLogLevel() int32
- func (x *LogEvent) GetMessage() string
- func (x *LogEvent) GetRequestKey() string
- func (x *LogEvent) GetStack() string
- func (x *LogEvent) GetTimeStamp() *timestamppb.Timestamp
- func (*LogEvent) ProtoMessage()
- func (x *LogEvent) ProtoReflect() protoreflect.Message
- func (x *LogEvent) Reset()
- func (x *LogEvent) String() string
- type LogLevel
- type Module
- func (*Module) Descriptor() ([]byte, []int)deprecated
- func (x *Module) GetConfigs() []*Config
- func (x *Module) GetData() []*Data
- func (x *Module) GetDatabases() []*Database
- func (x *Module) GetDeploymentKey() string
- func (x *Module) GetEnums() []*Enum
- func (x *Module) GetLanguage() string
- func (x *Module) GetName() string
- func (x *Module) GetSchema() string
- func (x *Module) GetSecrets() []*Secret
- func (x *Module) GetSubscriptions() []*Subscription
- func (x *Module) GetTopics() []*Topic
- func (x *Module) GetTypealiases() []*TypeAlias
- func (x *Module) GetVerbs() []*Verb
- func (*Module) ProtoMessage()
- func (x *Module) ProtoReflect() protoreflect.Message
- func (x *Module) Reset()
- func (x *Module) String() string
- type Secret
- type StreamEventsRequest
- func (*StreamEventsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamEventsRequest) GetQuery() *EventsQuery
- func (x *StreamEventsRequest) GetUpdateInterval() *durationpb.Duration
- func (*StreamEventsRequest) ProtoMessage()
- func (x *StreamEventsRequest) ProtoReflect() protoreflect.Message
- func (x *StreamEventsRequest) Reset()
- func (x *StreamEventsRequest) String() string
- type StreamEventsResponse
- func (*StreamEventsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StreamEventsResponse) GetEvents() []*Event
- func (*StreamEventsResponse) ProtoMessage()
- func (x *StreamEventsResponse) ProtoReflect() protoreflect.Message
- func (x *StreamEventsResponse) Reset()
- func (x *StreamEventsResponse) String() string
- type StreamModulesRequest
- type StreamModulesResponse
- func (*StreamModulesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StreamModulesResponse) GetModules() []*Module
- func (*StreamModulesResponse) ProtoMessage()
- func (x *StreamModulesResponse) ProtoReflect() protoreflect.Message
- func (x *StreamModulesResponse) Reset()
- func (x *StreamModulesResponse) String() string
- type Subscription
- func (*Subscription) Descriptor() ([]byte, []int)deprecated
- func (x *Subscription) GetReferences() []*schema.Ref
- func (x *Subscription) GetSubscription() *schema.Subscription
- func (*Subscription) ProtoMessage()
- func (x *Subscription) ProtoReflect() protoreflect.Message
- func (x *Subscription) Reset()
- func (x *Subscription) String() string
- type Topic
- type Topology
- type TopologyGroup
- type TypeAlias
- func (*TypeAlias) Descriptor() ([]byte, []int)deprecated
- func (x *TypeAlias) GetReferences() []*schema.Ref
- func (x *TypeAlias) GetTypealias() *schema.TypeAlias
- func (*TypeAlias) ProtoMessage()
- func (x *TypeAlias) ProtoReflect() protoreflect.Message
- func (x *TypeAlias) Reset()
- func (x *TypeAlias) String() string
- type Verb
- func (*Verb) Descriptor() ([]byte, []int)deprecated
- func (x *Verb) GetJsonRequestSchema() string
- func (x *Verb) GetReferences() []*schema.Ref
- func (x *Verb) GetSchema() string
- func (x *Verb) GetVerb() *schema.Verb
- func (*Verb) ProtoMessage()
- func (x *Verb) ProtoReflect() protoreflect.Message
- func (x *Verb) Reset()
- func (x *Verb) String() string
Constants ¶
This section is empty.
Variables ¶
var ( EventType_name = map[int32]string{ 0: "EVENT_TYPE_UNKNOWN", 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", } EventType_value = map[string]int32{ "EVENT_TYPE_UNKNOWN": 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, } )
Enum value maps for EventType.
var ( AsyncExecuteEventType_name = map[int32]string{ 0: "ASYNC_EXECUTE_EVENT_TYPE_UNKNOWN", 1: "ASYNC_EXECUTE_EVENT_TYPE_CRON", 2: "ASYNC_EXECUTE_EVENT_TYPE_FSM", 3: "ASYNC_EXECUTE_EVENT_TYPE_PUBSUB", } AsyncExecuteEventType_value = map[string]int32{ "ASYNC_EXECUTE_EVENT_TYPE_UNKNOWN": 0, "ASYNC_EXECUTE_EVENT_TYPE_CRON": 1, "ASYNC_EXECUTE_EVENT_TYPE_FSM": 2, "ASYNC_EXECUTE_EVENT_TYPE_PUBSUB": 3, } )
Enum value maps for AsyncExecuteEventType.
var ( LogLevel_name = map[int32]string{ 0: "LOG_LEVEL_UNKNOWN", 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_UNKNOWN": 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.
var ( EventsQuery_Order_name = map[int32]string{ 0: "ASC", 1: "DESC", } EventsQuery_Order_value = map[string]int32{ "ASC": 0, "DESC": 1, } )
Enum value maps for EventsQuery_Order.
var File_xyz_block_ftl_v1_console_console_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type AsyncExecuteEvent ¶ added in v0.393.0
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 *schema.Ref `protobuf:"bytes,3,opt,name=verb_ref,json=verbRef,proto3" json:"verb_ref,omitempty"` TimeStamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=time_stamp,json=timeStamp,proto3" json:"time_stamp,omitempty"` Duration *durationpb.Duration `protobuf:"bytes,5,opt,name=duration,proto3" json:"duration,omitempty"` AsyncEventType AsyncExecuteEventType `` /* 158-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
added in
v0.393.0
func (*AsyncExecuteEvent) Descriptor() ([]byte, []int)
Deprecated: Use AsyncExecuteEvent.ProtoReflect.Descriptor instead.
func (*AsyncExecuteEvent) GetAsyncEventType ¶ added in v0.393.0
func (x *AsyncExecuteEvent) GetAsyncEventType() AsyncExecuteEventType
func (*AsyncExecuteEvent) GetDeploymentKey ¶ added in v0.393.0
func (x *AsyncExecuteEvent) GetDeploymentKey() string
func (*AsyncExecuteEvent) GetDuration ¶ added in v0.393.0
func (x *AsyncExecuteEvent) GetDuration() *durationpb.Duration
func (*AsyncExecuteEvent) GetError ¶ added in v0.393.0
func (x *AsyncExecuteEvent) GetError() string
func (*AsyncExecuteEvent) GetRequestKey ¶ added in v0.393.0
func (x *AsyncExecuteEvent) GetRequestKey() string
func (*AsyncExecuteEvent) GetTimeStamp ¶ added in v0.393.0
func (x *AsyncExecuteEvent) GetTimeStamp() *timestamppb.Timestamp
func (*AsyncExecuteEvent) GetVerbRef ¶ added in v0.393.0
func (x *AsyncExecuteEvent) GetVerbRef() *schema.Ref
func (*AsyncExecuteEvent) ProtoMessage ¶ added in v0.393.0
func (*AsyncExecuteEvent) ProtoMessage()
func (*AsyncExecuteEvent) ProtoReflect ¶ added in v0.393.0
func (x *AsyncExecuteEvent) ProtoReflect() protoreflect.Message
func (*AsyncExecuteEvent) Reset ¶ added in v0.393.0
func (x *AsyncExecuteEvent) Reset()
func (*AsyncExecuteEvent) String ¶ added in v0.393.0
func (x *AsyncExecuteEvent) String() string
type AsyncExecuteEventType ¶ added in v0.393.0
type AsyncExecuteEventType int32
const ( AsyncExecuteEventType_ASYNC_EXECUTE_EVENT_TYPE_UNKNOWN AsyncExecuteEventType = 0 AsyncExecuteEventType_ASYNC_EXECUTE_EVENT_TYPE_CRON AsyncExecuteEventType = 1 AsyncExecuteEventType_ASYNC_EXECUTE_EVENT_TYPE_FSM AsyncExecuteEventType = 2 AsyncExecuteEventType_ASYNC_EXECUTE_EVENT_TYPE_PUBSUB AsyncExecuteEventType = 3 )
func (AsyncExecuteEventType) Descriptor ¶ added in v0.393.0
func (AsyncExecuteEventType) Descriptor() protoreflect.EnumDescriptor
func (AsyncExecuteEventType) Enum ¶ added in v0.393.0
func (x AsyncExecuteEventType) Enum() *AsyncExecuteEventType
func (AsyncExecuteEventType) EnumDescriptor
deprecated
added in
v0.393.0
func (AsyncExecuteEventType) EnumDescriptor() ([]byte, []int)
Deprecated: Use AsyncExecuteEventType.Descriptor instead.
func (AsyncExecuteEventType) Number ¶ added in v0.393.0
func (x AsyncExecuteEventType) Number() protoreflect.EnumNumber
func (AsyncExecuteEventType) String ¶ added in v0.393.0
func (x AsyncExecuteEventType) String() string
func (AsyncExecuteEventType) Type ¶ added in v0.393.0
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=time_stamp,json=timeStamp,proto3" json:"time_stamp,omitempty"` SourceVerbRef *schema.Ref `protobuf:"bytes,11,opt,name=source_verb_ref,json=sourceVerbRef,proto3,oneof" json:"source_verb_ref,omitempty"` DestinationVerbRef *schema.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) GetDeploymentKey ¶ added in v0.151.0
func (*CallEvent) GetDestinationVerbRef ¶
func (*CallEvent) GetDuration ¶
func (x *CallEvent) GetDuration() *durationpb.Duration
func (*CallEvent) GetRequest ¶
func (*CallEvent) GetRequestKey ¶ added in v0.165.1
func (*CallEvent) GetResponse ¶
func (*CallEvent) GetSourceVerbRef ¶
func (*CallEvent) GetTimeStamp ¶
func (x *CallEvent) GetTimeStamp() *timestamppb.Timestamp
func (*CallEvent) ProtoMessage ¶
func (*CallEvent) ProtoMessage()
func (*CallEvent) ProtoReflect ¶
func (x *CallEvent) ProtoReflect() protoreflect.Message
type Config ¶ added in v0.157.0
type Config struct { Config *schema.Config `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"` References []*schema.Ref `protobuf:"bytes,2,rep,name=references,proto3" json:"references,omitempty"` // contains filtered or unexported fields }
func (*Config) Descriptor
deprecated
added in
v0.157.0
func (*Config) GetReferences ¶ added in v0.389.0
func (*Config) ProtoMessage ¶ added in v0.157.0
func (*Config) ProtoMessage()
func (*Config) ProtoReflect ¶ added in v0.157.0
func (x *Config) ProtoReflect() protoreflect.Message
type CronScheduledEvent ¶ added in v0.377.0
type CronScheduledEvent struct { DeploymentKey string `protobuf:"bytes,1,opt,name=deployment_key,json=deploymentKey,proto3" json:"deployment_key,omitempty"` VerbRef *schema.Ref `protobuf:"bytes,2,opt,name=verb_ref,json=verbRef,proto3" json:"verb_ref,omitempty"` TimeStamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=time_stamp,json=timeStamp,proto3" json:"time_stamp,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
added in
v0.377.0
func (*CronScheduledEvent) Descriptor() ([]byte, []int)
Deprecated: Use CronScheduledEvent.ProtoReflect.Descriptor instead.
func (*CronScheduledEvent) GetDeploymentKey ¶ added in v0.377.0
func (x *CronScheduledEvent) GetDeploymentKey() string
func (*CronScheduledEvent) GetDuration ¶ added in v0.377.0
func (x *CronScheduledEvent) GetDuration() *durationpb.Duration
func (*CronScheduledEvent) GetError ¶ added in v0.377.0
func (x *CronScheduledEvent) GetError() string
func (*CronScheduledEvent) GetSchedule ¶ added in v0.377.0
func (x *CronScheduledEvent) GetSchedule() string
func (*CronScheduledEvent) GetScheduledAt ¶ added in v0.377.0
func (x *CronScheduledEvent) GetScheduledAt() *timestamppb.Timestamp
func (*CronScheduledEvent) GetTimeStamp ¶ added in v0.377.0
func (x *CronScheduledEvent) GetTimeStamp() *timestamppb.Timestamp
func (*CronScheduledEvent) GetVerbRef ¶ added in v0.377.0
func (x *CronScheduledEvent) GetVerbRef() *schema.Ref
func (*CronScheduledEvent) ProtoMessage ¶ added in v0.377.0
func (*CronScheduledEvent) ProtoMessage()
func (*CronScheduledEvent) ProtoReflect ¶ added in v0.377.0
func (x *CronScheduledEvent) ProtoReflect() protoreflect.Message
func (*CronScheduledEvent) Reset ¶ added in v0.377.0
func (x *CronScheduledEvent) Reset()
func (*CronScheduledEvent) String ¶ added in v0.377.0
func (x *CronScheduledEvent) String() string
type Data ¶
type Data struct { Data *schema.Data `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` Schema string `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"` References []*schema.Ref `protobuf:"bytes,3,rep,name=references,proto3" json:"references,omitempty"` // contains filtered or unexported fields }
func (*Data) Descriptor
deprecated
func (*Data) GetReferences ¶ added in v0.389.0
func (*Data) ProtoMessage ¶
func (*Data) ProtoMessage()
func (*Data) ProtoReflect ¶
func (x *Data) ProtoReflect() protoreflect.Message
type Database ¶ added in v0.375.0
type Database struct { Database *schema.Database `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"` References []*schema.Ref `protobuf:"bytes,2,rep,name=references,proto3" json:"references,omitempty"` // contains filtered or unexported fields }
func (*Database) Descriptor
deprecated
added in
v0.375.0
func (*Database) GetDatabase ¶ added in v0.375.0
func (*Database) GetReferences ¶ added in v0.389.0
func (*Database) ProtoMessage ¶ added in v0.375.0
func (*Database) ProtoMessage()
func (*Database) ProtoReflect ¶ added in v0.375.0
func (x *Database) ProtoReflect() protoreflect.Message
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 ¶ added in v0.151.0
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 ¶ added in v0.151.0
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 Enum ¶ added in v0.375.0
type Enum struct { Enum *schema.Enum `protobuf:"bytes,1,opt,name=enum,proto3" json:"enum,omitempty"` References []*schema.Ref `protobuf:"bytes,2,rep,name=references,proto3" json:"references,omitempty"` // contains filtered or unexported fields }
func (*Enum) Descriptor
deprecated
added in
v0.375.0
func (*Enum) GetReferences ¶ added in v0.389.0
func (*Enum) ProtoMessage ¶ added in v0.375.0
func (*Enum) ProtoMessage()
func (*Enum) ProtoReflect ¶ added in v0.375.0
func (x *Enum) ProtoReflect() protoreflect.Message
type Event ¶
type Event struct { TimeStamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=time_stamp,json=timeStamp,proto3" json:"time_stamp,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 Entry isEvent_Entry `protobuf_oneof:"entry"` // contains filtered or unexported fields }
func (*Event) Descriptor
deprecated
func (*Event) GetAsyncExecute ¶ added in v0.393.0
func (x *Event) GetAsyncExecute() *AsyncExecuteEvent
func (*Event) GetCronScheduled ¶ added in v0.377.0
func (x *Event) GetCronScheduled() *CronScheduledEvent
func (*Event) GetDeploymentCreated ¶
func (x *Event) GetDeploymentCreated() *DeploymentCreatedEvent
func (*Event) GetDeploymentUpdated ¶
func (x *Event) GetDeploymentUpdated() *DeploymentUpdatedEvent
func (*Event) GetIngress ¶ added in v0.368.0
func (x *Event) GetIngress() *IngressEvent
func (*Event) GetTimeStamp ¶
func (x *Event) GetTimeStamp() *timestamppb.Timestamp
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) ProtoReflect ¶
func (x *Event) ProtoReflect() protoreflect.Message
type EventType ¶
type EventType int32
const ( EventType_EVENT_TYPE_UNKNOWN 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 )
func (EventType) Descriptor ¶
func (EventType) Descriptor() protoreflect.EnumDescriptor
func (EventType) EnumDescriptor
deprecated
func (EventType) Number ¶
func (x EventType) Number() protoreflect.EnumNumber
func (EventType) Type ¶
func (EventType) Type() protoreflect.EnumType
type Event_AsyncExecute ¶ added in v0.393.0
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 ¶ added in v0.377.0
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 ¶ added in v0.368.0
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 EventsQuery ¶
type EventsQuery struct { Filters []*EventsQuery_Filter `protobuf:"bytes,1,rep,name=filters,proto3" json:"filters,omitempty"` Limit int32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` Order EventsQuery_Order `protobuf:"varint,3,opt,name=order,proto3,enum=xyz.block.ftl.v1.console.EventsQuery_Order" json:"order,omitempty"` // contains filtered or unexported fields }
Query for events.
func (*EventsQuery) Descriptor
deprecated
func (*EventsQuery) Descriptor() ([]byte, []int)
Deprecated: Use EventsQuery.ProtoReflect.Descriptor instead.
func (*EventsQuery) GetFilters ¶
func (x *EventsQuery) GetFilters() []*EventsQuery_Filter
func (*EventsQuery) GetLimit ¶
func (x *EventsQuery) GetLimit() int32
func (*EventsQuery) GetOrder ¶
func (x *EventsQuery) GetOrder() EventsQuery_Order
func (*EventsQuery) ProtoMessage ¶
func (*EventsQuery) ProtoMessage()
func (*EventsQuery) ProtoReflect ¶
func (x *EventsQuery) ProtoReflect() protoreflect.Message
func (*EventsQuery) Reset ¶
func (x *EventsQuery) Reset()
func (*EventsQuery) String ¶
func (x *EventsQuery) String() string
type EventsQuery_CallFilter ¶
type EventsQuery_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 (*EventsQuery_CallFilter) Descriptor
deprecated
func (*EventsQuery_CallFilter) Descriptor() ([]byte, []int)
Deprecated: Use EventsQuery_CallFilter.ProtoReflect.Descriptor instead.
func (*EventsQuery_CallFilter) GetDestModule ¶
func (x *EventsQuery_CallFilter) GetDestModule() string
func (*EventsQuery_CallFilter) GetDestVerb ¶
func (x *EventsQuery_CallFilter) GetDestVerb() string
func (*EventsQuery_CallFilter) GetSourceModule ¶
func (x *EventsQuery_CallFilter) GetSourceModule() string
func (*EventsQuery_CallFilter) ProtoMessage ¶
func (*EventsQuery_CallFilter) ProtoMessage()
func (*EventsQuery_CallFilter) ProtoReflect ¶
func (x *EventsQuery_CallFilter) ProtoReflect() protoreflect.Message
func (*EventsQuery_CallFilter) Reset ¶
func (x *EventsQuery_CallFilter) Reset()
func (*EventsQuery_CallFilter) String ¶
func (x *EventsQuery_CallFilter) String() string
type EventsQuery_DeploymentFilter ¶
type EventsQuery_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 (*EventsQuery_DeploymentFilter) Descriptor
deprecated
func (*EventsQuery_DeploymentFilter) Descriptor() ([]byte, []int)
Deprecated: Use EventsQuery_DeploymentFilter.ProtoReflect.Descriptor instead.
func (*EventsQuery_DeploymentFilter) GetDeployments ¶
func (x *EventsQuery_DeploymentFilter) GetDeployments() []string
func (*EventsQuery_DeploymentFilter) ProtoMessage ¶
func (*EventsQuery_DeploymentFilter) ProtoMessage()
func (*EventsQuery_DeploymentFilter) ProtoReflect ¶
func (x *EventsQuery_DeploymentFilter) ProtoReflect() protoreflect.Message
func (*EventsQuery_DeploymentFilter) Reset ¶
func (x *EventsQuery_DeploymentFilter) Reset()
func (*EventsQuery_DeploymentFilter) String ¶
func (x *EventsQuery_DeploymentFilter) String() string
type EventsQuery_EventTypeFilter ¶
type EventsQuery_EventTypeFilter struct { EventTypes []EventType `` /* 139-byte string literal not displayed */ // contains filtered or unexported fields }
Filters events by event type.
func (*EventsQuery_EventTypeFilter) Descriptor
deprecated
func (*EventsQuery_EventTypeFilter) Descriptor() ([]byte, []int)
Deprecated: Use EventsQuery_EventTypeFilter.ProtoReflect.Descriptor instead.
func (*EventsQuery_EventTypeFilter) GetEventTypes ¶
func (x *EventsQuery_EventTypeFilter) GetEventTypes() []EventType
func (*EventsQuery_EventTypeFilter) ProtoMessage ¶
func (*EventsQuery_EventTypeFilter) ProtoMessage()
func (*EventsQuery_EventTypeFilter) ProtoReflect ¶
func (x *EventsQuery_EventTypeFilter) ProtoReflect() protoreflect.Message
func (*EventsQuery_EventTypeFilter) Reset ¶
func (x *EventsQuery_EventTypeFilter) Reset()
func (*EventsQuery_EventTypeFilter) String ¶
func (x *EventsQuery_EventTypeFilter) String() string
type EventsQuery_Filter ¶
type EventsQuery_Filter struct { // These map 1:1 with filters in backend/controller/internal/dal/events.go // // Types that are assignable to Filter: // // *EventsQuery_Filter_Limit // *EventsQuery_Filter_LogLevel // *EventsQuery_Filter_Deployments // *EventsQuery_Filter_Requests // *EventsQuery_Filter_EventTypes // *EventsQuery_Filter_Time // *EventsQuery_Filter_Id // *EventsQuery_Filter_Call // *EventsQuery_Filter_Module Filter isEventsQuery_Filter_Filter `protobuf_oneof:"filter"` // contains filtered or unexported fields }
func (*EventsQuery_Filter) Descriptor
deprecated
func (*EventsQuery_Filter) Descriptor() ([]byte, []int)
Deprecated: Use EventsQuery_Filter.ProtoReflect.Descriptor instead.
func (*EventsQuery_Filter) GetCall ¶
func (x *EventsQuery_Filter) GetCall() *EventsQuery_CallFilter
func (*EventsQuery_Filter) GetDeployments ¶
func (x *EventsQuery_Filter) GetDeployments() *EventsQuery_DeploymentFilter
func (*EventsQuery_Filter) GetEventTypes ¶
func (x *EventsQuery_Filter) GetEventTypes() *EventsQuery_EventTypeFilter
func (*EventsQuery_Filter) GetFilter ¶
func (m *EventsQuery_Filter) GetFilter() isEventsQuery_Filter_Filter
func (*EventsQuery_Filter) GetId ¶
func (x *EventsQuery_Filter) GetId() *EventsQuery_IDFilter
func (*EventsQuery_Filter) GetLimit ¶
func (x *EventsQuery_Filter) GetLimit() *EventsQuery_LimitFilter
func (*EventsQuery_Filter) GetLogLevel ¶
func (x *EventsQuery_Filter) GetLogLevel() *EventsQuery_LogLevelFilter
func (*EventsQuery_Filter) GetModule ¶ added in v0.375.0
func (x *EventsQuery_Filter) GetModule() *EventsQuery_ModuleFilter
func (*EventsQuery_Filter) GetRequests ¶
func (x *EventsQuery_Filter) GetRequests() *EventsQuery_RequestFilter
func (*EventsQuery_Filter) GetTime ¶
func (x *EventsQuery_Filter) GetTime() *EventsQuery_TimeFilter
func (*EventsQuery_Filter) ProtoMessage ¶
func (*EventsQuery_Filter) ProtoMessage()
func (*EventsQuery_Filter) ProtoReflect ¶
func (x *EventsQuery_Filter) ProtoReflect() protoreflect.Message
func (*EventsQuery_Filter) Reset ¶
func (x *EventsQuery_Filter) Reset()
func (*EventsQuery_Filter) String ¶
func (x *EventsQuery_Filter) String() string
type EventsQuery_Filter_Call ¶
type EventsQuery_Filter_Call struct {
Call *EventsQuery_CallFilter `protobuf:"bytes,8,opt,name=call,proto3,oneof"`
}
type EventsQuery_Filter_Deployments ¶
type EventsQuery_Filter_Deployments struct {
Deployments *EventsQuery_DeploymentFilter `protobuf:"bytes,3,opt,name=deployments,proto3,oneof"`
}
type EventsQuery_Filter_EventTypes ¶
type EventsQuery_Filter_EventTypes struct {
EventTypes *EventsQuery_EventTypeFilter `protobuf:"bytes,5,opt,name=event_types,json=eventTypes,proto3,oneof"`
}
type EventsQuery_Filter_Id ¶
type EventsQuery_Filter_Id struct {
Id *EventsQuery_IDFilter `protobuf:"bytes,7,opt,name=id,proto3,oneof"`
}
type EventsQuery_Filter_Limit ¶
type EventsQuery_Filter_Limit struct {
Limit *EventsQuery_LimitFilter `protobuf:"bytes,1,opt,name=limit,proto3,oneof"`
}
type EventsQuery_Filter_LogLevel ¶
type EventsQuery_Filter_LogLevel struct {
LogLevel *EventsQuery_LogLevelFilter `protobuf:"bytes,2,opt,name=log_level,json=logLevel,proto3,oneof"`
}
type EventsQuery_Filter_Module ¶ added in v0.375.0
type EventsQuery_Filter_Module struct {
Module *EventsQuery_ModuleFilter `protobuf:"bytes,9,opt,name=module,proto3,oneof"`
}
type EventsQuery_Filter_Requests ¶
type EventsQuery_Filter_Requests struct {
Requests *EventsQuery_RequestFilter `protobuf:"bytes,4,opt,name=requests,proto3,oneof"`
}
type EventsQuery_Filter_Time ¶
type EventsQuery_Filter_Time struct {
Time *EventsQuery_TimeFilter `protobuf:"bytes,6,opt,name=time,proto3,oneof"`
}
type EventsQuery_IDFilter ¶
type EventsQuery_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 (*EventsQuery_IDFilter) Descriptor
deprecated
func (*EventsQuery_IDFilter) Descriptor() ([]byte, []int)
Deprecated: Use EventsQuery_IDFilter.ProtoReflect.Descriptor instead.
func (*EventsQuery_IDFilter) GetHigherThan ¶
func (x *EventsQuery_IDFilter) GetHigherThan() int64
func (*EventsQuery_IDFilter) GetLowerThan ¶
func (x *EventsQuery_IDFilter) GetLowerThan() int64
func (*EventsQuery_IDFilter) ProtoMessage ¶
func (*EventsQuery_IDFilter) ProtoMessage()
func (*EventsQuery_IDFilter) ProtoReflect ¶
func (x *EventsQuery_IDFilter) ProtoReflect() protoreflect.Message
func (*EventsQuery_IDFilter) Reset ¶
func (x *EventsQuery_IDFilter) Reset()
func (*EventsQuery_IDFilter) String ¶
func (x *EventsQuery_IDFilter) String() string
type EventsQuery_LimitFilter ¶
type EventsQuery_LimitFilter struct { Limit int32 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"` // contains filtered or unexported fields }
Limit the number of events returned.
func (*EventsQuery_LimitFilter) Descriptor
deprecated
func (*EventsQuery_LimitFilter) Descriptor() ([]byte, []int)
Deprecated: Use EventsQuery_LimitFilter.ProtoReflect.Descriptor instead.
func (*EventsQuery_LimitFilter) GetLimit ¶
func (x *EventsQuery_LimitFilter) GetLimit() int32
func (*EventsQuery_LimitFilter) ProtoMessage ¶
func (*EventsQuery_LimitFilter) ProtoMessage()
func (*EventsQuery_LimitFilter) ProtoReflect ¶
func (x *EventsQuery_LimitFilter) ProtoReflect() protoreflect.Message
func (*EventsQuery_LimitFilter) Reset ¶
func (x *EventsQuery_LimitFilter) Reset()
func (*EventsQuery_LimitFilter) String ¶
func (x *EventsQuery_LimitFilter) String() string
type EventsQuery_LogLevelFilter ¶
type EventsQuery_LogLevelFilter struct { LogLevel LogLevel `protobuf:"varint,1,opt,name=log_level,json=logLevel,proto3,enum=xyz.block.ftl.v1.console.LogLevel" json:"log_level,omitempty"` // contains filtered or unexported fields }
Filters events by log level.
func (*EventsQuery_LogLevelFilter) Descriptor
deprecated
func (*EventsQuery_LogLevelFilter) Descriptor() ([]byte, []int)
Deprecated: Use EventsQuery_LogLevelFilter.ProtoReflect.Descriptor instead.
func (*EventsQuery_LogLevelFilter) GetLogLevel ¶
func (x *EventsQuery_LogLevelFilter) GetLogLevel() LogLevel
func (*EventsQuery_LogLevelFilter) ProtoMessage ¶
func (*EventsQuery_LogLevelFilter) ProtoMessage()
func (*EventsQuery_LogLevelFilter) ProtoReflect ¶
func (x *EventsQuery_LogLevelFilter) ProtoReflect() protoreflect.Message
func (*EventsQuery_LogLevelFilter) Reset ¶
func (x *EventsQuery_LogLevelFilter) Reset()
func (*EventsQuery_LogLevelFilter) String ¶
func (x *EventsQuery_LogLevelFilter) String() string
type EventsQuery_ModuleFilter ¶ added in v0.375.0
type EventsQuery_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 (*EventsQuery_ModuleFilter) Descriptor
deprecated
added in
v0.375.0
func (*EventsQuery_ModuleFilter) Descriptor() ([]byte, []int)
Deprecated: Use EventsQuery_ModuleFilter.ProtoReflect.Descriptor instead.
func (*EventsQuery_ModuleFilter) GetModule ¶ added in v0.375.0
func (x *EventsQuery_ModuleFilter) GetModule() string
func (*EventsQuery_ModuleFilter) GetVerb ¶ added in v0.375.0
func (x *EventsQuery_ModuleFilter) GetVerb() string
func (*EventsQuery_ModuleFilter) ProtoMessage ¶ added in v0.375.0
func (*EventsQuery_ModuleFilter) ProtoMessage()
func (*EventsQuery_ModuleFilter) ProtoReflect ¶ added in v0.375.0
func (x *EventsQuery_ModuleFilter) ProtoReflect() protoreflect.Message
func (*EventsQuery_ModuleFilter) Reset ¶ added in v0.375.0
func (x *EventsQuery_ModuleFilter) Reset()
func (*EventsQuery_ModuleFilter) String ¶ added in v0.375.0
func (x *EventsQuery_ModuleFilter) String() string
type EventsQuery_Order ¶
type EventsQuery_Order int32
const ( EventsQuery_ASC EventsQuery_Order = 0 EventsQuery_DESC EventsQuery_Order = 1 )
func (EventsQuery_Order) Descriptor ¶
func (EventsQuery_Order) Descriptor() protoreflect.EnumDescriptor
func (EventsQuery_Order) Enum ¶
func (x EventsQuery_Order) Enum() *EventsQuery_Order
func (EventsQuery_Order) EnumDescriptor
deprecated
func (EventsQuery_Order) EnumDescriptor() ([]byte, []int)
Deprecated: Use EventsQuery_Order.Descriptor instead.
func (EventsQuery_Order) Number ¶
func (x EventsQuery_Order) Number() protoreflect.EnumNumber
func (EventsQuery_Order) String ¶
func (x EventsQuery_Order) String() string
func (EventsQuery_Order) Type ¶
func (EventsQuery_Order) Type() protoreflect.EnumType
type EventsQuery_RequestFilter ¶
type EventsQuery_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 (*EventsQuery_RequestFilter) Descriptor
deprecated
func (*EventsQuery_RequestFilter) Descriptor() ([]byte, []int)
Deprecated: Use EventsQuery_RequestFilter.ProtoReflect.Descriptor instead.
func (*EventsQuery_RequestFilter) GetRequests ¶
func (x *EventsQuery_RequestFilter) GetRequests() []string
func (*EventsQuery_RequestFilter) ProtoMessage ¶
func (*EventsQuery_RequestFilter) ProtoMessage()
func (*EventsQuery_RequestFilter) ProtoReflect ¶
func (x *EventsQuery_RequestFilter) ProtoReflect() protoreflect.Message
func (*EventsQuery_RequestFilter) Reset ¶
func (x *EventsQuery_RequestFilter) Reset()
func (*EventsQuery_RequestFilter) String ¶
func (x *EventsQuery_RequestFilter) String() string
type EventsQuery_TimeFilter ¶
type EventsQuery_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 (*EventsQuery_TimeFilter) Descriptor
deprecated
func (*EventsQuery_TimeFilter) Descriptor() ([]byte, []int)
Deprecated: Use EventsQuery_TimeFilter.ProtoReflect.Descriptor instead.
func (*EventsQuery_TimeFilter) GetNewerThan ¶
func (x *EventsQuery_TimeFilter) GetNewerThan() *timestamppb.Timestamp
func (*EventsQuery_TimeFilter) GetOlderThan ¶
func (x *EventsQuery_TimeFilter) GetOlderThan() *timestamppb.Timestamp
func (*EventsQuery_TimeFilter) ProtoMessage ¶
func (*EventsQuery_TimeFilter) ProtoMessage()
func (*EventsQuery_TimeFilter) ProtoReflect ¶
func (x *EventsQuery_TimeFilter) ProtoReflect() protoreflect.Message
func (*EventsQuery_TimeFilter) Reset ¶
func (x *EventsQuery_TimeFilter) Reset()
func (*EventsQuery_TimeFilter) String ¶
func (x *EventsQuery_TimeFilter) String() string
type GetEventsResponse ¶
type GetEventsResponse 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 (*GetEventsResponse) Descriptor
deprecated
func (*GetEventsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetEventsResponse.ProtoReflect.Descriptor instead.
func (*GetEventsResponse) GetCursor ¶
func (x *GetEventsResponse) GetCursor() int64
func (*GetEventsResponse) GetEvents ¶
func (x *GetEventsResponse) GetEvents() []*Event
func (*GetEventsResponse) ProtoMessage ¶
func (*GetEventsResponse) ProtoMessage()
func (*GetEventsResponse) ProtoReflect ¶
func (x *GetEventsResponse) ProtoReflect() protoreflect.Message
func (*GetEventsResponse) Reset ¶
func (x *GetEventsResponse) Reset()
func (*GetEventsResponse) String ¶
func (x *GetEventsResponse) String() string
type GetModulesRequest ¶
type GetModulesRequest struct {
// contains filtered or unexported fields
}
func (*GetModulesRequest) Descriptor
deprecated
func (*GetModulesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetModulesRequest.ProtoReflect.Descriptor instead.
func (*GetModulesRequest) ProtoMessage ¶
func (*GetModulesRequest) ProtoMessage()
func (*GetModulesRequest) ProtoReflect ¶
func (x *GetModulesRequest) ProtoReflect() protoreflect.Message
func (*GetModulesRequest) Reset ¶
func (x *GetModulesRequest) Reset()
func (*GetModulesRequest) String ¶
func (x *GetModulesRequest) String() string
type GetModulesResponse ¶
type GetModulesResponse struct { Modules []*Module `protobuf:"bytes,1,rep,name=modules,proto3" json:"modules,omitempty"` Topology *Topology `protobuf:"bytes,2,opt,name=topology,proto3" json:"topology,omitempty"` // contains filtered or unexported fields }
func (*GetModulesResponse) Descriptor
deprecated
func (*GetModulesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetModulesResponse.ProtoReflect.Descriptor instead.
func (*GetModulesResponse) GetModules ¶
func (x *GetModulesResponse) GetModules() []*Module
func (*GetModulesResponse) GetTopology ¶ added in v0.157.0
func (x *GetModulesResponse) GetTopology() *Topology
func (*GetModulesResponse) ProtoMessage ¶
func (*GetModulesResponse) ProtoMessage()
func (*GetModulesResponse) ProtoReflect ¶
func (x *GetModulesResponse) ProtoReflect() protoreflect.Message
func (*GetModulesResponse) Reset ¶
func (x *GetModulesResponse) Reset()
func (*GetModulesResponse) String ¶
func (x *GetModulesResponse) String() string
type IngressEvent ¶ added in v0.368.0
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 *schema.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=time_stamp,json=timeStamp,proto3" json:"time_stamp,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
added in
v0.368.0
func (*IngressEvent) Descriptor() ([]byte, []int)
Deprecated: Use IngressEvent.ProtoReflect.Descriptor instead.
func (*IngressEvent) GetDeploymentKey ¶ added in v0.368.0
func (x *IngressEvent) GetDeploymentKey() string
func (*IngressEvent) GetDuration ¶ added in v0.368.0
func (x *IngressEvent) GetDuration() *durationpb.Duration
func (*IngressEvent) GetError ¶ added in v0.368.0
func (x *IngressEvent) GetError() string
func (*IngressEvent) GetMethod ¶ added in v0.368.0
func (x *IngressEvent) GetMethod() string
func (*IngressEvent) GetPath ¶ added in v0.368.0
func (x *IngressEvent) GetPath() string
func (*IngressEvent) GetRequest ¶ added in v0.368.0
func (x *IngressEvent) GetRequest() string
func (*IngressEvent) GetRequestHeader ¶ added in v0.368.0
func (x *IngressEvent) GetRequestHeader() string
func (*IngressEvent) GetRequestKey ¶ added in v0.368.0
func (x *IngressEvent) GetRequestKey() string
func (*IngressEvent) GetResponse ¶ added in v0.368.0
func (x *IngressEvent) GetResponse() string
func (*IngressEvent) GetResponseHeader ¶ added in v0.368.0
func (x *IngressEvent) GetResponseHeader() string
func (*IngressEvent) GetStatusCode ¶ added in v0.368.0
func (x *IngressEvent) GetStatusCode() int32
func (*IngressEvent) GetTimeStamp ¶ added in v0.368.0
func (x *IngressEvent) GetTimeStamp() *timestamppb.Timestamp
func (*IngressEvent) GetVerbRef ¶ added in v0.368.0
func (x *IngressEvent) GetVerbRef() *schema.Ref
func (*IngressEvent) ProtoMessage ¶ added in v0.368.0
func (*IngressEvent) ProtoMessage()
func (*IngressEvent) ProtoReflect ¶ added in v0.368.0
func (x *IngressEvent) ProtoReflect() protoreflect.Message
func (*IngressEvent) Reset ¶ added in v0.368.0
func (x *IngressEvent) Reset()
func (*IngressEvent) String ¶ added in v0.368.0
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=time_stamp,json=timeStamp,proto3" json:"time_stamp,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) GetAttributes ¶
func (*LogEvent) GetDeploymentKey ¶ added in v0.151.0
func (*LogEvent) GetLogLevel ¶
func (*LogEvent) GetMessage ¶
func (*LogEvent) GetRequestKey ¶ added in v0.165.1
func (*LogEvent) GetTimeStamp ¶
func (x *LogEvent) GetTimeStamp() *timestamppb.Timestamp
func (*LogEvent) ProtoMessage ¶
func (*LogEvent) ProtoMessage()
func (*LogEvent) ProtoReflect ¶
func (x *LogEvent) ProtoReflect() protoreflect.Message
type LogLevel ¶
type LogLevel int32
func (LogLevel) Descriptor ¶
func (LogLevel) Descriptor() protoreflect.EnumDescriptor
func (LogLevel) EnumDescriptor
deprecated
func (LogLevel) Number ¶
func (x LogLevel) Number() protoreflect.EnumNumber
func (LogLevel) Type ¶
func (LogLevel) Type() protoreflect.EnumType
type Module ¶
type Module struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` DeploymentKey string `protobuf:"bytes,2,opt,name=deployment_key,json=deploymentKey,proto3" json:"deployment_key,omitempty"` Language string `protobuf:"bytes,3,opt,name=language,proto3" json:"language,omitempty"` Schema string `protobuf:"bytes,4,opt,name=schema,proto3" json:"schema,omitempty"` Verbs []*Verb `protobuf:"bytes,5,rep,name=verbs,proto3" json:"verbs,omitempty"` Data []*Data `protobuf:"bytes,6,rep,name=data,proto3" json:"data,omitempty"` Secrets []*Secret `protobuf:"bytes,7,rep,name=secrets,proto3" json:"secrets,omitempty"` Configs []*Config `protobuf:"bytes,8,rep,name=configs,proto3" json:"configs,omitempty"` Databases []*Database `protobuf:"bytes,9,rep,name=databases,proto3" json:"databases,omitempty"` Enums []*Enum `protobuf:"bytes,10,rep,name=enums,proto3" json:"enums,omitempty"` Topics []*Topic `protobuf:"bytes,11,rep,name=topics,proto3" json:"topics,omitempty"` Typealiases []*TypeAlias `protobuf:"bytes,12,rep,name=typealiases,proto3" json:"typealiases,omitempty"` Subscriptions []*Subscription `protobuf:"bytes,13,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"` // contains filtered or unexported fields }
func (*Module) Descriptor
deprecated
func (*Module) GetConfigs ¶ added in v0.157.0
func (*Module) GetDatabases ¶ added in v0.377.0
func (*Module) GetDeploymentKey ¶ added in v0.151.0
func (*Module) GetLanguage ¶
func (*Module) GetSecrets ¶ added in v0.157.0
func (*Module) GetSubscriptions ¶ added in v0.377.0
func (x *Module) GetSubscriptions() []*Subscription
func (*Module) GetTypealiases ¶ added in v0.377.0
func (*Module) ProtoMessage ¶
func (*Module) ProtoMessage()
func (*Module) ProtoReflect ¶
func (x *Module) ProtoReflect() protoreflect.Message
type Secret ¶ added in v0.157.0
type Secret struct { Secret *schema.Secret `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"` References []*schema.Ref `protobuf:"bytes,2,rep,name=references,proto3" json:"references,omitempty"` // contains filtered or unexported fields }
func (*Secret) Descriptor
deprecated
added in
v0.157.0
func (*Secret) GetReferences ¶ added in v0.389.0
func (*Secret) ProtoMessage ¶ added in v0.157.0
func (*Secret) ProtoMessage()
func (*Secret) ProtoReflect ¶ added in v0.157.0
func (x *Secret) ProtoReflect() protoreflect.Message
type StreamEventsRequest ¶
type StreamEventsRequest struct { UpdateInterval *durationpb.Duration `protobuf:"bytes,1,opt,name=update_interval,json=updateInterval,proto3,oneof" json:"update_interval,omitempty"` Query *EventsQuery `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"` // contains filtered or unexported fields }
func (*StreamEventsRequest) Descriptor
deprecated
func (*StreamEventsRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamEventsRequest.ProtoReflect.Descriptor instead.
func (*StreamEventsRequest) GetQuery ¶
func (x *StreamEventsRequest) GetQuery() *EventsQuery
func (*StreamEventsRequest) GetUpdateInterval ¶
func (x *StreamEventsRequest) GetUpdateInterval() *durationpb.Duration
func (*StreamEventsRequest) ProtoMessage ¶
func (*StreamEventsRequest) ProtoMessage()
func (*StreamEventsRequest) ProtoReflect ¶
func (x *StreamEventsRequest) ProtoReflect() protoreflect.Message
func (*StreamEventsRequest) Reset ¶
func (x *StreamEventsRequest) Reset()
func (*StreamEventsRequest) String ¶
func (x *StreamEventsRequest) String() string
type StreamEventsResponse ¶
type StreamEventsResponse struct { Events []*Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"` // contains filtered or unexported fields }
func (*StreamEventsResponse) Descriptor
deprecated
func (*StreamEventsResponse) Descriptor() ([]byte, []int)
Deprecated: Use StreamEventsResponse.ProtoReflect.Descriptor instead.
func (*StreamEventsResponse) GetEvents ¶
func (x *StreamEventsResponse) GetEvents() []*Event
func (*StreamEventsResponse) ProtoMessage ¶
func (*StreamEventsResponse) ProtoMessage()
func (*StreamEventsResponse) ProtoReflect ¶
func (x *StreamEventsResponse) ProtoReflect() protoreflect.Message
func (*StreamEventsResponse) Reset ¶
func (x *StreamEventsResponse) Reset()
func (*StreamEventsResponse) String ¶
func (x *StreamEventsResponse) String() string
type StreamModulesRequest ¶ added in v0.377.0
type StreamModulesRequest struct {
// contains filtered or unexported fields
}
func (*StreamModulesRequest) Descriptor
deprecated
added in
v0.377.0
func (*StreamModulesRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamModulesRequest.ProtoReflect.Descriptor instead.
func (*StreamModulesRequest) ProtoMessage ¶ added in v0.377.0
func (*StreamModulesRequest) ProtoMessage()
func (*StreamModulesRequest) ProtoReflect ¶ added in v0.377.0
func (x *StreamModulesRequest) ProtoReflect() protoreflect.Message
func (*StreamModulesRequest) Reset ¶ added in v0.377.0
func (x *StreamModulesRequest) Reset()
func (*StreamModulesRequest) String ¶ added in v0.377.0
func (x *StreamModulesRequest) String() string
type StreamModulesResponse ¶ added in v0.377.0
type StreamModulesResponse struct { Modules []*Module `protobuf:"bytes,1,rep,name=modules,proto3" json:"modules,omitempty"` // contains filtered or unexported fields }
func (*StreamModulesResponse) Descriptor
deprecated
added in
v0.377.0
func (*StreamModulesResponse) Descriptor() ([]byte, []int)
Deprecated: Use StreamModulesResponse.ProtoReflect.Descriptor instead.
func (*StreamModulesResponse) GetModules ¶ added in v0.377.0
func (x *StreamModulesResponse) GetModules() []*Module
func (*StreamModulesResponse) ProtoMessage ¶ added in v0.377.0
func (*StreamModulesResponse) ProtoMessage()
func (*StreamModulesResponse) ProtoReflect ¶ added in v0.377.0
func (x *StreamModulesResponse) ProtoReflect() protoreflect.Message
func (*StreamModulesResponse) Reset ¶ added in v0.377.0
func (x *StreamModulesResponse) Reset()
func (*StreamModulesResponse) String ¶ added in v0.377.0
func (x *StreamModulesResponse) String() string
type Subscription ¶ added in v0.375.0
type Subscription struct { Subscription *schema.Subscription `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"` References []*schema.Ref `protobuf:"bytes,2,rep,name=references,proto3" json:"references,omitempty"` // contains filtered or unexported fields }
func (*Subscription) Descriptor
deprecated
added in
v0.375.0
func (*Subscription) Descriptor() ([]byte, []int)
Deprecated: Use Subscription.ProtoReflect.Descriptor instead.
func (*Subscription) GetReferences ¶ added in v0.389.0
func (x *Subscription) GetReferences() []*schema.Ref
func (*Subscription) GetSubscription ¶ added in v0.375.0
func (x *Subscription) GetSubscription() *schema.Subscription
func (*Subscription) ProtoMessage ¶ added in v0.375.0
func (*Subscription) ProtoMessage()
func (*Subscription) ProtoReflect ¶ added in v0.375.0
func (x *Subscription) ProtoReflect() protoreflect.Message
func (*Subscription) Reset ¶ added in v0.375.0
func (x *Subscription) Reset()
func (*Subscription) String ¶ added in v0.375.0
func (x *Subscription) String() string
type Topic ¶ added in v0.375.0
type Topic struct { Topic *schema.Topic `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` References []*schema.Ref `protobuf:"bytes,2,rep,name=references,proto3" json:"references,omitempty"` // contains filtered or unexported fields }
func (*Topic) Descriptor
deprecated
added in
v0.375.0
func (*Topic) GetReferences ¶ added in v0.389.0
func (*Topic) ProtoMessage ¶ added in v0.375.0
func (*Topic) ProtoMessage()
func (*Topic) ProtoReflect ¶ added in v0.375.0
func (x *Topic) ProtoReflect() protoreflect.Message
type Topology ¶ added in v0.157.0
type Topology struct { Levels []*TopologyGroup `protobuf:"bytes,1,rep,name=levels,proto3" json:"levels,omitempty"` // contains filtered or unexported fields }
func (*Topology) Descriptor
deprecated
added in
v0.157.0
func (*Topology) GetLevels ¶ added in v0.157.0
func (x *Topology) GetLevels() []*TopologyGroup
func (*Topology) ProtoMessage ¶ added in v0.157.0
func (*Topology) ProtoMessage()
func (*Topology) ProtoReflect ¶ added in v0.157.0
func (x *Topology) ProtoReflect() protoreflect.Message
type TopologyGroup ¶ added in v0.157.0
type TopologyGroup struct { Modules []string `protobuf:"bytes,1,rep,name=modules,proto3" json:"modules,omitempty"` // contains filtered or unexported fields }
func (*TopologyGroup) Descriptor
deprecated
added in
v0.157.0
func (*TopologyGroup) Descriptor() ([]byte, []int)
Deprecated: Use TopologyGroup.ProtoReflect.Descriptor instead.
func (*TopologyGroup) GetModules ¶ added in v0.157.0
func (x *TopologyGroup) GetModules() []string
func (*TopologyGroup) ProtoMessage ¶ added in v0.157.0
func (*TopologyGroup) ProtoMessage()
func (*TopologyGroup) ProtoReflect ¶ added in v0.157.0
func (x *TopologyGroup) ProtoReflect() protoreflect.Message
func (*TopologyGroup) Reset ¶ added in v0.157.0
func (x *TopologyGroup) Reset()
func (*TopologyGroup) String ¶ added in v0.157.0
func (x *TopologyGroup) String() string
type TypeAlias ¶ added in v0.375.0
type TypeAlias struct { Typealias *schema.TypeAlias `protobuf:"bytes,1,opt,name=typealias,proto3" json:"typealias,omitempty"` References []*schema.Ref `protobuf:"bytes,2,rep,name=references,proto3" json:"references,omitempty"` // contains filtered or unexported fields }
func (*TypeAlias) Descriptor
deprecated
added in
v0.375.0
func (*TypeAlias) GetReferences ¶ added in v0.389.0
func (*TypeAlias) GetTypealias ¶ added in v0.375.0
func (*TypeAlias) ProtoMessage ¶ added in v0.375.0
func (*TypeAlias) ProtoMessage()
func (*TypeAlias) ProtoReflect ¶ added in v0.375.0
func (x *TypeAlias) ProtoReflect() protoreflect.Message
type Verb ¶
type Verb struct { Verb *schema.Verb `protobuf:"bytes,1,opt,name=verb,proto3" json:"verb,omitempty"` Schema string `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"` JsonRequestSchema string `protobuf:"bytes,3,opt,name=json_request_schema,json=jsonRequestSchema,proto3" json:"json_request_schema,omitempty"` References []*schema.Ref `protobuf:"bytes,4,rep,name=references,proto3" json:"references,omitempty"` // contains filtered or unexported fields }
func (*Verb) Descriptor
deprecated
func (*Verb) GetJsonRequestSchema ¶
func (*Verb) GetReferences ¶ added in v0.389.0
func (*Verb) ProtoMessage ¶
func (*Verb) ProtoMessage()
func (*Verb) ProtoReflect ¶
func (x *Verb) ProtoReflect() protoreflect.Message