Module: Streamdal::Protos

Defined in:
lib/sp_kv_pb.rb,
lib/sp_bus_pb.rb,
lib/sp_sdk_pb.rb,
lib/sp_wsm_pb.rb,
lib/sp_info_pb.rb,
lib/sp_common_pb.rb,
lib/sp_notify_pb.rb,
lib/sp_command_pb.rb,
lib/sp_external_pb.rb,
lib/sp_internal_pb.rb,
lib/sp_pipeline_pb.rb,
lib/shared/sp_shared_pb.rb,
lib/steps/sp_steps_kv_pb.rb,
lib/sp_external_services_pb.rb,
lib/sp_internal_services_pb.rb,
lib/steps/sp_steps_custom_pb.rb,
lib/steps/sp_steps_decode_pb.rb,
lib/steps/sp_steps_encode_pb.rb,
lib/steps/sp_steps_detective_pb.rb,
lib/steps/sp_steps_transform_pb.rb,
lib/steps/sp_steps_valid_json_pb.rb,
lib/steps/sp_steps_httprequest_pb.rb,
lib/steps/sp_steps_inferschema_pb.rb,
lib/steps/sp_steps_schema_validation_pb.rb

Defined Under Namespace

Modules: External, Internal

Constant Summary collapse

KVObject = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.KVObject").msgclass
KVInstruction = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.KVInstruction").msgclass
KVRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.KVRequest").msgclass
KVCreateHTTPRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.KVCreateHTTPRequest").msgclass
KVUpdateHTTPRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.KVUpdateHTTPRequest").msgclass
BusEvent = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.BusEvent").msgclass
SDKResponse = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.SDKResponse").msgclass
PipelineStatus = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.PipelineStatus").msgclass
StepStatus = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.StepStatus").msgclass
ExecStatus = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.ExecStatus").enummodule
SDKMode = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.SDKMode").enummodule
WASMRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.WASMRequest").msgclass
WASMResponse = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.WASMResponse").msgclass
InterStepResult = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.InterStepResult").msgclass
WASMExitCode = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.WASMExitCode").enummodule
LiveInfo = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.LiveInfo").msgclass
PipelineInfo = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.PipelineInfo").msgclass
ClientInfo = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.ClientInfo").msgclass
ClientType = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.ClientType").enummodule
StandardResponse = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.StandardResponse").msgclass
Audience = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.Audience").msgclass
Metric = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.Metric").msgclass
TailRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.TailRequest").msgclass
TailResponse = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.TailResponse").msgclass
AudienceRate = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.AudienceRate").msgclass
Schema = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.Schema").msgclass
SampleOptions = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.SampleOptions").msgclass
Config = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.Config").msgclass
ResponseCode = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.ResponseCode").enummodule
OperationType = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.OperationType").enummodule
TailResponseType = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.TailResponseType").enummodule
TailRequestType = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.TailRequestType").enummodule
NotificationConfig = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.NotificationConfig").msgclass
NotificationSlack = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.NotificationSlack").msgclass
NotificationEmail = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.NotificationEmail").msgclass
NotificationEmailSMTP = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.NotificationEmailSMTP").msgclass
NotificationEmailSES = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.NotificationEmailSES").msgclass
NotificationPagerDuty = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.NotificationPagerDuty").msgclass
NotificationType = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.NotificationType").enummodule
Command = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.Command").msgclass
SetPipelinesCommand = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.SetPipelinesCommand").msgclass
KeepAliveCommand = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.KeepAliveCommand").msgclass
KVCommand = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.KVCommand").msgclass
TailCommand = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.TailCommand").msgclass
GetAllRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.GetAllRequest").msgclass
GetAllResponse = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.GetAllResponse").msgclass
GetPipelinesRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.GetPipelinesRequest").msgclass
GetPipelinesResponse = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.GetPipelinesResponse").msgclass
GetPipelineRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.GetPipelineRequest").msgclass
GetPipelineResponse = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.GetPipelineResponse").msgclass
CreatePipelineRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.CreatePipelineRequest").msgclass
CreatePipelineResponse = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.CreatePipelineResponse").msgclass
UpdatePipelineRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.UpdatePipelineRequest").msgclass
DeletePipelineRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.DeletePipelineRequest").msgclass
SetPipelinesRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.SetPipelinesRequest").msgclass
PausePipelineRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.PausePipelineRequest").msgclass
ResumePipelineRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.ResumePipelineRequest").msgclass
CreateNotificationRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.CreateNotificationRequest").msgclass
CreateNotificationResponse = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.CreateNotificationResponse").msgclass
UpdateNotificationRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.UpdateNotificationRequest").msgclass
DeleteNotificationRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.DeleteNotificationRequest").msgclass
GetNotificationsRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.GetNotificationsRequest").msgclass
GetNotificationsResponse = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.GetNotificationsResponse").msgclass
GetNotificationRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.GetNotificationRequest").msgclass
GetNotificationResponse = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.GetNotificationResponse").msgclass
AttachNotificationRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.AttachNotificationRequest").msgclass
DetachNotificationRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.DetachNotificationRequest").msgclass
CreateAudienceRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.CreateAudienceRequest").msgclass
DeleteAudienceRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.DeleteAudienceRequest").msgclass
DeleteServiceRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.DeleteServiceRequest").msgclass
GetMetricsRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.GetMetricsRequest").msgclass
GetMetricsResponse = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.GetMetricsResponse").msgclass
GetAudienceRatesRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.GetAudienceRatesRequest").msgclass
GetAudienceRatesResponse = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.GetAudienceRatesResponse").msgclass
GetSchemaRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.GetSchemaRequest").msgclass
GetSchemaResponse = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.GetSchemaResponse").msgclass
AppRegistrationStatusRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.AppRegistrationStatusRequest").msgclass
AppRegistrationStatusResponse = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.AppRegistrationStatusResponse").msgclass
AppRegistrationRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.AppRegistrationRequest").msgclass
AppVerifyRegistrationRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.AppVerifyRegistrationRequest").msgclass
AppRegisterRejectRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.AppRegisterRejectRequest").msgclass
PauseTailRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.PauseTailRequest").msgclass
ResumeTailRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.ResumeTailRequest").msgclass
GetWasmRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.GetWasmRequest").msgclass
GetWasmResponse = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.GetWasmResponse").msgclass
GetAllWasmRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.GetAllWasmRequest").msgclass
GetAllWasmResponse = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.GetAllWasmResponse").msgclass
CreateWasmRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.CreateWasmRequest").msgclass
CreateWasmResponse = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.CreateWasmResponse").msgclass
UpdateWasmRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.UpdateWasmRequest").msgclass
DeleteWasmRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.DeleteWasmRequest").msgclass
TestRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.TestRequest").msgclass
TestResponse = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.TestResponse").msgclass
GetConfigRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.GetConfigRequest").msgclass
GetConfigResponse = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.GetConfigResponse").msgclass
NewAudienceRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.NewAudienceRequest").msgclass
HeartbeatRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.HeartbeatRequest").msgclass
NotifyRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.NotifyRequest").msgclass
MetricsRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.MetricsRequest").msgclass
RegisterRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.RegisterRequest").msgclass
DeregisterRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.DeregisterRequest").msgclass
GetSetPipelinesCommandsByServiceRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.GetSetPipelinesCommandsByServiceRequest").msgclass
GetSetPipelinesCommandsByServiceResponse = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.GetSetPipelinesCommandsByServiceResponse").msgclass
SendSchemaRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.SendSchemaRequest").msgclass
Pipeline = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.Pipeline").msgclass
PipelineStepConditions = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.PipelineStepConditions").msgclass
PipelineStepNotification = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.PipelineStepNotification").msgclass
PipelineStep = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.PipelineStep").msgclass
PipelineConfigs = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.PipelineConfigs").msgclass
PipelineConfig = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.PipelineConfig").msgclass
AbortCondition = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.AbortCondition").enummodule
WasmModule = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.shared.WasmModule").msgclass
KVAction = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.shared.KVAction").enummodule
KVStepResponse = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.KVStepResponse").msgclass
KVStep = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.KVStep").msgclass
KVMode = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.KVMode").enummodule
KVStatus = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.KVStatus").enummodule
CustomStep = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.CustomStep").msgclass
DecodeStep = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.DecodeStep").msgclass
EncodeStep = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.EncodeStep").msgclass
DetectiveStep = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.DetectiveStep").msgclass
DetectiveStepResultMatch = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.DetectiveStepResultMatch").msgclass
DetectiveStepResult = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.DetectiveStepResult").msgclass
DetectiveType = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.DetectiveType").enummodule
DetectiveTypePIIKeywordMode = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.DetectiveTypePIIKeywordMode").enummodule
TransformStep = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.TransformStep").msgclass
TransformTruncateOptions = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.TransformTruncateOptions").msgclass
TransformDeleteFieldOptions = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.TransformDeleteFieldOptions").msgclass
TransformReplaceValueOptions = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.TransformReplaceValueOptions").msgclass
TransformObfuscateOptions = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.TransformObfuscateOptions").msgclass
TransformMaskOptions = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.TransformMaskOptions").msgclass
TransformExtractOptions = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.TransformExtractOptions").msgclass
TransformType = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.TransformType").enummodule
TransformTruncateType = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.TransformTruncateType").enummodule
ValidJSONStep = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.ValidJSONStep").msgclass
HttpRequest = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.HttpRequest").msgclass
HttpResponse = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.HttpResponse").msgclass
HttpRequestStep = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.HttpRequestStep").msgclass
HttpRequestMethod = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.HttpRequestMethod").enummodule
HttpRequestBodyMode = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.HttpRequestBodyMode").enummodule
InferSchemaStep = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.InferSchemaStep").msgclass
SchemaValidationStep = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.SchemaValidationStep").msgclass
SchemaValidationJSONSchema = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.SchemaValidationJSONSchema").msgclass
SchemaValidationType = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.SchemaValidationType").enummodule
SchemaValidationCondition = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.SchemaValidationCondition").enummodule
JSONSchemaDraft = 
::Google::Protobuf::DescriptorPool.generated_pool.lookup("protos.steps.JSONSchemaDraft").enummodule