protos

type AbortCondition int32

type AppRegisterRejectRequest struct {
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// contains filtered or unexported fields
}

type AppRegistrationRequest struct {
	Email     string `protobuf:"bytes,1,opt,name=email,proto3" json:"email,omitempty"`
	ClusterId string `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Used for storage on ui-bff backend
	XCode string `protobuf:"bytes,100,opt,name=_code,json=Code,proto3" json:"_code,omitempty"` // protolint:disable:this FIELD_NAMES_LOWER_SNAKE_CASE
	// contains filtered or unexported fields
}

type AppRegistrationStatusRequest struct {
	Email string `protobuf:"bytes,1,opt,name=email,proto3" json:"email,omitempty"`
	// contains filtered or unexported fields
}

type AppRegistrationStatusResponse struct {
	Status AppRegistrationStatusResponse_Status `protobuf:"varint,1,opt,name=status,proto3,enum=protos.AppRegistrationStatusResponse_Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type AppRegistrationStatusResponse_Status int32

type AppVerifyRegistrationRequest struct {
	Email string `protobuf:"bytes,1,opt,name=email,proto3" json:"email,omitempty"`
	Code  string `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

type Audience struct {

	// Name of the service -- let's include the service name on all calls, we can
	// optimize later ~DS
	ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// Name of the component the SDK is interacting with (ie. kafka-$topic-name)
	ComponentName string `protobuf:"bytes,2,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"`
	// Consumer or Producer
	OperationType OperationType `` /* 127-byte string literal not displayed */
	// Name for the consumer or producer
	OperationName string `protobuf:"bytes,4,opt,name=operation_name,json=operationName,proto3" json:"operation_name,omitempty"`
	// Used internally by server and k8s operator to determine who manages this resource
	XCreatedBy *string `protobuf:"bytes,1000,opt,name=_created_by,json=CreatedBy,proto3,oneof" json:"_created_by,omitempty"` // protolint:disable:this FIELD_NAMES_LOWER_SNAKE_CASE
	// contains filtered or unexported fields
}

type AudienceRate struct {
	Bytes     float64 `protobuf:"fixed64,1,opt,name=bytes,proto3" json:"bytes,omitempty"`
	Processed float64 `protobuf:"fixed64,2,opt,name=processed,proto3" json:"processed,omitempty"`
	// contains filtered or unexported fields
}

type BusEvent struct {
	Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	// This _should_ contain request messages - each server can determine
	// how to interpret and handle the message.
	//
	// NOTE: The bus _should not_ be used for transmitting commands to SDKs. The
	// consumer in each SDK should receive a request and potentially craft a new
	// command to send to the appropriate SDK(s).
	//
	// Types that are assignable to Event:
	//
	//	*BusEvent_RegisterRequest
	//	*BusEvent_DeregisterRequest
	//	*BusEvent_CreatePipelineRequest
	//	*BusEvent_DeletePipelineRequest
	//	*BusEvent_UpdatePipelineRequest
	//	*BusEvent_PausePipelineRequest
	//	*BusEvent_ResumePipelineRequest
	//	*BusEvent_MetricsRequest
	//	*BusEvent_KvRequest
	//	*BusEvent_DeleteAudienceRequest
	//	*BusEvent_NewAudienceRequest
	//	*BusEvent_TailRequest
	//	*BusEvent_TailResponse
	//	*BusEvent_SetPipelinesRequest
	Event isBusEvent_Event `protobuf_oneof:"event"`
	// All gRPC metadata is stored in ctx; when request goes outside of gRPC
	// bounds, we will translate ctx metadata into this field.
	//
	// Example:
	//  1. Request comes into server via external gRPC to set new pipeline
	//  2. server has to send SetPipeline cmd to SDK via gRPC - it passes
	//     on original metadata in request.
	//  3. server has to broadcast SetPipeline cmd to other services via bus
	//  4. Since this is not a gRPC call, server translates ctx metadata to
	//     this field and includes it in the bus event.
	XMetadata map[string]string `` // protolint:disable:this FIELD_NAMES_LOWER_SNAKE_CASE
	/* 176-byte string literal not displayed */
	// contains filtered or unexported fields
}

type BusEvent_CreatePipelineRequest struct {
	CreatePipelineRequest *CreatePipelineRequest `protobuf:"bytes,102,opt,name=create_pipeline_request,json=createPipelineRequest,proto3,oneof"`
}

type BusEvent_DeleteAudienceRequest struct {
	DeleteAudienceRequest *DeleteAudienceRequest `protobuf:"bytes,111,opt,name=delete_audience_request,json=deleteAudienceRequest,proto3,oneof"`
}

type BusEvent_DeletePipelineRequest struct {
	DeletePipelineRequest *DeletePipelineRequest `protobuf:"bytes,103,opt,name=delete_pipeline_request,json=deletePipelineRequest,proto3,oneof"`
}

type BusEvent_DeregisterRequest struct {
	DeregisterRequest *DeregisterRequest `protobuf:"bytes,101,opt,name=deregister_request,json=deregisterRequest,proto3,oneof"`
}

type BusEvent_KvRequest struct {
	KvRequest *KVRequest `protobuf:"bytes,110,opt,name=kv_request,json=kvRequest,proto3,oneof"`
}

type BusEvent_MetricsRequest struct {
	MetricsRequest *MetricsRequest `protobuf:"bytes,109,opt,name=metrics_request,json=metricsRequest,proto3,oneof"`
}

type BusEvent_NewAudienceRequest struct {
	NewAudienceRequest *NewAudienceRequest `protobuf:"bytes,112,opt,name=new_audience_request,json=newAudienceRequest,proto3,oneof"`
}

type BusEvent_PausePipelineRequest struct {
	PausePipelineRequest *PausePipelineRequest `protobuf:"bytes,107,opt,name=pause_pipeline_request,json=pausePipelineRequest,proto3,oneof"`
}

type BusEvent_RegisterRequest struct {
	RegisterRequest *RegisterRequest `protobuf:"bytes,100,opt,name=register_request,json=registerRequest,proto3,oneof"`
}

type BusEvent_ResumePipelineRequest struct {
	ResumePipelineRequest *ResumePipelineRequest `protobuf:"bytes,108,opt,name=resume_pipeline_request,json=resumePipelineRequest,proto3,oneof"`
}

type BusEvent_SetPipelinesRequest struct {
	SetPipelinesRequest *SetPipelinesRequest `protobuf:"bytes,115,opt,name=set_pipelines_request,json=setPipelinesRequest,proto3,oneof"`
}

type BusEvent_TailRequest struct {
	TailRequest *TailRequest `protobuf:"bytes,113,opt,name=tail_request,json=tailRequest,proto3,oneof"`
}

type BusEvent_TailResponse struct {
	TailResponse *TailResponse `protobuf:"bytes,114,opt,name=tail_response,json=tailResponse,proto3,oneof"`
}

type BusEvent_UpdatePipelineRequest struct {
	UpdatePipelineRequest *UpdatePipelineRequest `protobuf:"bytes,104,opt,name=update_pipeline_request,json=updatePipelineRequest,proto3,oneof"`
}

type ClientInfo struct {
	ClientType     ClientType `protobuf:"varint,1,opt,name=client_type,json=clientType,proto3,enum=protos.ClientType" json:"client_type,omitempty"`
	LibraryName    string     `protobuf:"bytes,2,opt,name=library_name,json=libraryName,proto3" json:"library_name,omitempty"`
	LibraryVersion string     `protobuf:"bytes,3,opt,name=library_version,json=libraryVersion,proto3" json:"library_version,omitempty"`
	Language       string     `protobuf:"bytes,4,opt,name=language,proto3" json:"language,omitempty"`
	Arch           string     `protobuf:"bytes,5,opt,name=arch,proto3" json:"arch,omitempty"`
	Os             string     `protobuf:"bytes,6,opt,name=os,proto3" json:"os,omitempty"`
	// Filled out by server on GetAll()
	XSessionId   *string `protobuf:"bytes,7,opt,name=_session_id,json=SessionId,proto3,oneof" json:"_session_id,omitempty"`       // protolint:disable:this FIELD_NAMES_LOWER_SNAKE_CASE
	XServiceName *string `protobuf:"bytes,8,opt,name=_service_name,json=ServiceName,proto3,oneof" json:"_service_name,omitempty"` // protolint:disable:this FIELD_NAMES_LOWER_SNAKE_CASE
	XNodeName    *string `protobuf:"bytes,9,opt,name=_node_name,json=NodeName,proto3,oneof" json:"_node_name,omitempty"`          // protolint:disable:this FIELD_NAMES_LOWER_SNAKE_CASE
	// contains filtered or unexported fields
}

type ClientType int32

type Command struct {

	// Who is this command intended for?
	// NOTE: Some commands (such as KeepAliveCommand, KVCommand) do NOT use audience and will ignore it
	Audience *Audience `protobuf:"bytes,1,opt,name=audience,proto3" json:"audience,omitempty"`
	// Types that are assignable to Command:
	//
	//	*Command_SetPipelines
	//	*Command_KeepAlive
	//	*Command_Kv
	//	*Command_Tail
	Command isCommand_Command `protobuf_oneof:"command"`
	// contains filtered or unexported fields
}

type Command_KeepAlive struct {
	// Server sends this periodically to SDKs to keep the connection alive
	KeepAlive *KeepAliveCommand `protobuf:"bytes,101,opt,name=keep_alive,json=keepAlive,proto3,oneof"`
}

type Command_Kv struct {
	// Server will emit this when a user makes changes to the KV store
	// via the KV HTTP API.
	Kv *KVCommand `protobuf:"bytes,102,opt,name=kv,proto3,oneof"`
}

type Command_SetPipelines struct {
	// Emitted by server when a user makes a pause, resume, delete or update
	// pipeline and set pipelines external grpc API call.
	// NOTE: This was introduced during ordered pipeline updates.
	SetPipelines *SetPipelinesCommand `protobuf:"bytes,100,opt,name=set_pipelines,json=setPipelines,proto3,oneof"`
}

type Command_Tail struct {
	// Emitted by server when a user makes a Tail() call
	// Consumed by all server instances and by SDKs
	Tail *TailCommand `protobuf:"bytes,103,opt,name=tail,proto3,oneof"`
}

type Config struct {
	Audiences        []*Audience                 `protobuf:"bytes,1,rep,name=audiences,proto3" json:"audiences,omitempty"`
	Pipelines        []*Pipeline                 `protobuf:"bytes,2,rep,name=pipelines,proto3" json:"pipelines,omitempty"`
	Notifications    []*NotificationConfig       `protobuf:"bytes,3,rep,name=notifications,proto3" json:"notifications,omitempty"`
	WasmModules      []*shared.WasmModule        `protobuf:"bytes,4,rep,name=wasm_modules,json=wasmModules,proto3" json:"wasm_modules,omitempty"`
	AudienceMappings map[string]*PipelineConfigs `` // key == audience as string
	/* 197-byte string literal not displayed */
	// contains filtered or unexported fields
}

type CreateAudienceRequest struct {
	Audience *Audience `protobuf:"bytes,1,opt,name=audience,proto3" json:"audience,omitempty"`
	// contains filtered or unexported fields
}

type CreateNotificationRequest struct {
	Notification *NotificationConfig `protobuf:"bytes,1,opt,name=notification,proto3" json:"notification,omitempty"`
	// contains filtered or unexported fields
}

type CreateNotificationResponse struct {
	Notification *NotificationConfig `protobuf:"bytes,1,opt,name=notification,proto3" json:"notification,omitempty"`
	// contains filtered or unexported fields
}

type CreatePipelineRequest struct {
	Pipeline     *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	PipelineJson []byte    `protobuf:"bytes,2,opt,name=pipeline_json,json=pipelineJson,proto3,oneof" json:"pipeline_json,omitempty"`
	// contains filtered or unexported fields
}

type CreatePipelineResponse struct {
	Message    string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	PipelineId string `protobuf:"bytes,2,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	// contains filtered or unexported fields
}

type CreateWasmRequest struct {
	Wasm *shared.WasmModule `protobuf:"bytes,1,opt,name=wasm,proto3" json:"wasm,omitempty"`
	// contains filtered or unexported fields
}

type CreateWasmResponse struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Id      string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type DeleteAudienceRequest struct {
	Audience *Audience `protobuf:"bytes,1,opt,name=audience,proto3" json:"audience,omitempty"`
	// If true, will also detach all pipelines from the audience (if it has any)
	Force *bool `protobuf:"varint,2,opt,name=force,proto3,oneof" json:"force,omitempty"`
	// contains filtered or unexported fields
}

type DeleteNotificationRequest struct {
	NotificationId string `protobuf:"bytes,1,opt,name=notification_id,json=notificationId,proto3" json:"notification_id,omitempty"`
	// contains filtered or unexported fields
}

type DeletePipelineRequest struct {
	PipelineId string `protobuf:"bytes,1,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	// This field is for internal usage only by the server. It is used to indicate
	// to the bus handler who this pipeline was used by so the handler can decide
	// who we need to emit a SetPipelines cmd to.
	XAudiences []*Audience `protobuf:"bytes,1000,rep,name=_audiences,json=Audiences,proto3" json:"_audiences,omitempty"` // protolint:disable:this FIELD_NAMES_LOWER_SNAKE_CASE
	// contains filtered or unexported fields
}

type DeleteServiceRequest struct {
	ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	Force       *bool  `protobuf:"varint,2,opt,name=force,proto3,oneof" json:"force,omitempty"`
	// contains filtered or unexported fields
}

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

type DeregisterRequest struct {
	ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	SessionId   string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

type ExecStatus int32

type ExternalClient interface {
	// Returns all data needed for UI; called on initial console load
	GetAll(ctx context.Context, in *GetAllRequest, opts ...grpc.CallOption) (*GetAllResponse, error)
	// Returns the current _full_ configuration of the server
	GetConfig(ctx context.Context, in *GetConfigRequest, opts ...grpc.CallOption) (*GetConfigResponse, error)
	// Used by console to stream updates to UI; called after initial GetAll()
	GetAllStream(ctx context.Context, in *GetAllRequest, opts ...grpc.CallOption) (External_GetAllStreamClient, error)
	// Returns pipelines (_wasm_bytes field is stripped)
	GetPipelines(ctx context.Context, in *GetPipelinesRequest, opts ...grpc.CallOption) (*GetPipelinesResponse, error)
	// Returns a single pipeline (_wasm_bytes field is stripped)
	GetPipeline(ctx context.Context, in *GetPipelineRequest, opts ...grpc.CallOption) (*GetPipelineResponse, error)
	// Create a new pipeline; id must be left empty on create
	CreatePipeline(ctx context.Context, in *CreatePipelineRequest, opts ...grpc.CallOption) (*CreatePipelineResponse, error)
	// Update an existing pipeline; id must be set
	UpdatePipeline(ctx context.Context, in *UpdatePipelineRequest, opts ...grpc.CallOption) (*StandardResponse, error)
	// Delete a pipeline
	DeletePipeline(ctx context.Context, in *DeletePipelineRequest, opts ...grpc.CallOption) (*StandardResponse, error)
	SetPipelines(ctx context.Context, in *SetPipelinesRequest, opts ...grpc.CallOption) (*StandardResponse, error)
	// Pause a pipeline; noop if pipeline is already paused
	PausePipeline(ctx context.Context, in *PausePipelineRequest, opts ...grpc.CallOption) (*StandardResponse, error)
	// Resume a pipeline; noop if pipeline is not paused
	ResumePipeline(ctx context.Context, in *ResumePipelineRequest, opts ...grpc.CallOption) (*StandardResponse, error)
	// Create a new notification config
	CreateNotification(ctx context.Context, in *CreateNotificationRequest, opts ...grpc.CallOption) (*CreateNotificationResponse, error)
	// Update an existing notification config
	UpdateNotification(ctx context.Context, in *UpdateNotificationRequest, opts ...grpc.CallOption) (*StandardResponse, error)
	// Delete a notification config
	DeleteNotification(ctx context.Context, in *DeleteNotificationRequest, opts ...grpc.CallOption) (*StandardResponse, error)
	// Returns all notification configs
	GetNotifications(ctx context.Context, in *GetNotificationsRequest, opts ...grpc.CallOption) (*GetNotificationsResponse, error)
	// Returns a single notification config
	GetNotification(ctx context.Context, in *GetNotificationRequest, opts ...grpc.CallOption) (*GetNotificationResponse, error)
	// Deprecated: Do not use.
	// Attach a notification config to a pipeline
	AttachNotification(ctx context.Context, in *AttachNotificationRequest, opts ...grpc.CallOption) (*StandardResponse, error)
	// Deprecated: Do not use.
	// Detach a notification config from a pipeline
	DetachNotification(ctx context.Context, in *DetachNotificationRequest, opts ...grpc.CallOption) (*StandardResponse, error)
	// Create an audience. Used for automation tooling (terraform, k8s cr's)
	CreateAudience(ctx context.Context, in *CreateAudienceRequest, opts ...grpc.CallOption) (*StandardResponse, error)
	// Delete an audience
	DeleteAudience(ctx context.Context, in *DeleteAudienceRequest, opts ...grpc.CallOption) (*StandardResponse, error)
	// Delete a service and all associated audiences
	DeleteService(ctx context.Context, in *DeleteServiceRequest, opts ...grpc.CallOption) (*StandardResponse, error)
	// Returns all metric counters
	GetMetrics(ctx context.Context, in *GetMetricsRequest, opts ...grpc.CallOption) (External_GetMetricsClient, error)
	Tail(ctx context.Context, in *TailRequest, opts ...grpc.CallOption) (External_TailClient, error)
	PauseTail(ctx context.Context, in *PauseTailRequest, opts ...grpc.CallOption) (*StandardResponse, error)
	ResumeTail(ctx context.Context, in *ResumeTailRequest, opts ...grpc.CallOption) (*StandardResponse, error)
	GetAudienceRates(ctx context.Context, in *GetAudienceRatesRequest, opts ...grpc.CallOption) (External_GetAudienceRatesClient, error)
	GetSchema(ctx context.Context, in *GetSchemaRequest, opts ...grpc.CallOption) (*GetSchemaResponse, error)
	AppRegistrationStatus(ctx context.Context, in *AppRegistrationStatusRequest, opts ...grpc.CallOption) (*AppRegistrationStatusResponse, error)
	AppRegister(ctx context.Context, in *AppRegistrationRequest, opts ...grpc.CallOption) (*StandardResponse, error)
	AppVerifyRegistration(ctx context.Context, in *AppVerifyRegistrationRequest, opts ...grpc.CallOption) (*StandardResponse, error)
	AppRegisterReject(ctx context.Context, in *AppRegisterRejectRequest, opts ...grpc.CallOption) (*StandardResponse, error)
	// BEGIN Wasm methods
	GetWasm(ctx context.Context, in *GetWasmRequest, opts ...grpc.CallOption) (*GetWasmResponse, error)
	GetAllWasm(ctx context.Context, in *GetAllWasmRequest, opts ...grpc.CallOption) (*GetAllWasmResponse, error)
	CreateWasm(ctx context.Context, in *CreateWasmRequest, opts ...grpc.CallOption) (*CreateWasmResponse, error)
	UpdateWasm(ctx context.Context, in *UpdateWasmRequest, opts ...grpc.CallOption) (*StandardResponse, error)
	DeleteWasm(ctx context.Context, in *DeleteWasmRequest, opts ...grpc.CallOption) (*StandardResponse, error)
	// Test method
	Test(ctx context.Context, in *TestRequest, opts ...grpc.CallOption) (*TestResponse, error)
}

type ExternalServer interface {
	// Returns all data needed for UI; called on initial console load
	GetAll(context.Context, *GetAllRequest) (*GetAllResponse, error)
	// Returns the current _full_ configuration of the server
	GetConfig(context.Context, *GetConfigRequest) (*GetConfigResponse, error)
	// Used by console to stream updates to UI; called after initial GetAll()
	GetAllStream(*GetAllRequest, External_GetAllStreamServer) error
	// Returns pipelines (_wasm_bytes field is stripped)
	GetPipelines(context.Context, *GetPipelinesRequest) (*GetPipelinesResponse, error)
	// Returns a single pipeline (_wasm_bytes field is stripped)
	GetPipeline(context.Context, *GetPipelineRequest) (*GetPipelineResponse, error)
	// Create a new pipeline; id must be left empty on create
	CreatePipeline(context.Context, *CreatePipelineRequest) (*CreatePipelineResponse, error)
	// Update an existing pipeline; id must be set
	UpdatePipeline(context.Context, *UpdatePipelineRequest) (*StandardResponse, error)
	// Delete a pipeline
	DeletePipeline(context.Context, *DeletePipelineRequest) (*StandardResponse, error)
	SetPipelines(context.Context, *SetPipelinesRequest) (*StandardResponse, error)
	// Pause a pipeline; noop if pipeline is already paused
	PausePipeline(context.Context, *PausePipelineRequest) (*StandardResponse, error)
	// Resume a pipeline; noop if pipeline is not paused
	ResumePipeline(context.Context, *ResumePipelineRequest) (*StandardResponse, error)
	// Create a new notification config
	CreateNotification(context.Context, *CreateNotificationRequest) (*CreateNotificationResponse, error)
	// Update an existing notification config
	UpdateNotification(context.Context, *UpdateNotificationRequest) (*StandardResponse, error)
	// Delete a notification config
	DeleteNotification(context.Context, *DeleteNotificationRequest) (*StandardResponse, error)
	// Returns all notification configs
	GetNotifications(context.Context, *GetNotificationsRequest) (*GetNotificationsResponse, error)
	// Returns a single notification config
	GetNotification(context.Context, *GetNotificationRequest) (*GetNotificationResponse, error)
	// Deprecated: Do not use.
	// Attach a notification config to a pipeline
	AttachNotification(context.Context, *AttachNotificationRequest) (*StandardResponse, error)
	// Deprecated: Do not use.
	// Detach a notification config from a pipeline
	DetachNotification(context.Context, *DetachNotificationRequest) (*StandardResponse, error)
	// Create an audience. Used for automation tooling (terraform, k8s cr's)
	CreateAudience(context.Context, *CreateAudienceRequest) (*StandardResponse, error)
	// Delete an audience
	DeleteAudience(context.Context, *DeleteAudienceRequest) (*StandardResponse, error)
	// Delete a service and all associated audiences
	DeleteService(context.Context, *DeleteServiceRequest) (*StandardResponse, error)
	// Returns all metric counters
	GetMetrics(*GetMetricsRequest, External_GetMetricsServer) error
	Tail(*TailRequest, External_TailServer) error
	PauseTail(context.Context, *PauseTailRequest) (*StandardResponse, error)
	ResumeTail(context.Context, *ResumeTailRequest) (*StandardResponse, error)
	GetAudienceRates(*GetAudienceRatesRequest, External_GetAudienceRatesServer) error
	GetSchema(context.Context, *GetSchemaRequest) (*GetSchemaResponse, error)
	AppRegistrationStatus(context.Context, *AppRegistrationStatusRequest) (*AppRegistrationStatusResponse, error)
	AppRegister(context.Context, *AppRegistrationRequest) (*StandardResponse, error)
	AppVerifyRegistration(context.Context, *AppVerifyRegistrationRequest) (*StandardResponse, error)
	AppRegisterReject(context.Context, *AppRegisterRejectRequest) (*StandardResponse, error)
	// BEGIN Wasm methods
	GetWasm(context.Context, *GetWasmRequest) (*GetWasmResponse, error)
	GetAllWasm(context.Context, *GetAllWasmRequest) (*GetAllWasmResponse, error)
	CreateWasm(context.Context, *CreateWasmRequest) (*CreateWasmResponse, error)
	UpdateWasm(context.Context, *UpdateWasmRequest) (*StandardResponse, error)
	DeleteWasm(context.Context, *DeleteWasmRequest) (*StandardResponse, error)
	// Test method
	Test(context.Context, *TestRequest) (*TestResponse, error)
	// contains filtered or unexported methods
}

type External_GetAllStreamClient interface {
	Recv() (*GetAllResponse, error)
	grpc.ClientStream
}

type External_GetAllStreamServer interface {
	Send(*GetAllResponse) error
	grpc.ServerStream
}

type External_GetAudienceRatesClient interface {
	Recv() (*GetAudienceRatesResponse, error)
	grpc.ClientStream
}

type External_GetAudienceRatesServer interface {
	Send(*GetAudienceRatesResponse) error
	grpc.ServerStream
}

type External_GetMetricsClient interface {
	Recv() (*GetMetricsResponse, error)
	grpc.ClientStream
}

type External_GetMetricsServer interface {
	Send(*GetMetricsResponse) error
	grpc.ServerStream
}

type External_TailClient interface {
	Recv() (*TailResponse, error)
	grpc.ClientStream
}

type External_TailServer interface {
	Send(*TailResponse) error
	grpc.ServerStream
}

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

type GetAllResponse struct {

	// Clients currently connected to the server
	Live []*LiveInfo `protobuf:"bytes,1,rep,name=live,proto3" json:"live,omitempty"`
	// All of the audiences that are known to the server
	Audiences []*Audience `protobuf:"bytes,2,rep,name=audiences,proto3" json:"audiences,omitempty"`
	// All of the pipelines known to the server + pipeline <-> audience mappings
	// key == pipeline_id; if "Audience" is not filled out - pipeline is not attached
	// to any audience.
	Pipelines map[string]*PipelineInfo `` /* 159-byte string literal not displayed */
	// Audience to pipeline mapping config; key == $audience_as_string
	Configs map[string]*PipelineConfigs `` /* 155-byte string literal not displayed */
	// When was this response generated. This is useful for determining what is
	// the latest update when using GetAllStream().
	GeneratedAtUnixTsNsUtc int64 `` /* 138-byte string literal not displayed */
	// Set by server to indicate that the response is a keepalive message
	XKeepalive *bool `protobuf:"varint,1000,opt,name=_keepalive,json=Keepalive,proto3,oneof" json:"_keepalive,omitempty"` // protolint:disable:this FIELD_NAMES_LOWER_SNAKE_CASE
	// contains filtered or unexported fields
}

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

type GetAllWasmResponse struct {
	Wasm []*shared.WasmModule `protobuf:"bytes,1,rep,name=wasm,proto3" json:"wasm,omitempty"`
	// contains filtered or unexported fields
}

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

type GetAudienceRatesResponse struct {
	Rates map[string]*AudienceRate `` // Key is an audience string
	/* 151-byte string literal not displayed */
	// Set by server to indicate that the response is a keepalive message
	XKeepalive *bool `protobuf:"varint,1000,opt,name=_keepalive,json=Keepalive,proto3,oneof" json:"_keepalive,omitempty"` // protolint:disable:this FIELD_NAMES_LOWER_SNAKE_CASE
	// contains filtered or unexported fields
}

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

type GetConfigResponse struct {
	Config *Config `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

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

type GetMetricsResponse struct {
	Metrics map[string]*Metric `` /* 155-byte string literal not displayed */
	// Set by server to indicate that the response is a keepalive message
	XKeepalive *bool `protobuf:"varint,1000,opt,name=_keepalive,json=Keepalive,proto3,oneof" json:"_keepalive,omitempty"` // protolint:disable:this FIELD_NAMES_LOWER_SNAKE_CASE
	// contains filtered or unexported fields
}

type GetNotificationRequest struct {
	NotificationId string `protobuf:"bytes,1,opt,name=notification_id,json=notificationId,proto3" json:"notification_id,omitempty"`
	// contains filtered or unexported fields
}

type GetNotificationResponse struct {
	Notification *NotificationConfig `protobuf:"bytes,1,opt,name=notification,proto3" json:"notification,omitempty"`
	// contains filtered or unexported fields
}