eventrouter

package
v0.0.0-...-204702d Latest Latest
Warning

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

 Go to latest Published: Nov 14, 2024 License: MIT Imports: 17 Imported by: 3

Documentation

Index

Constants

View Source 
const (
	BusService_Get_FullMethodName                  = "/yandex.cloud.serverless.eventrouter.v1.BusService/Get"
	BusService_List_FullMethodName                 = "/yandex.cloud.serverless.eventrouter.v1.BusService/List"
	BusService_Create_FullMethodName               = "/yandex.cloud.serverless.eventrouter.v1.BusService/Create"
	BusService_Update_FullMethodName               = "/yandex.cloud.serverless.eventrouter.v1.BusService/Update"
	BusService_Delete_FullMethodName               = "/yandex.cloud.serverless.eventrouter.v1.BusService/Delete"
	BusService_ListOperations_FullMethodName       = "/yandex.cloud.serverless.eventrouter.v1.BusService/ListOperations"
	BusService_ListAccessBindings_FullMethodName   = "/yandex.cloud.serverless.eventrouter.v1.BusService/ListAccessBindings"
	BusService_SetAccessBindings_FullMethodName    = "/yandex.cloud.serverless.eventrouter.v1.BusService/SetAccessBindings"
	BusService_UpdateAccessBindings_FullMethodName = "/yandex.cloud.serverless.eventrouter.v1.BusService/UpdateAccessBindings"
)
View Source 
const (
	ConnectorService_Get_FullMethodName                  = "/yandex.cloud.serverless.eventrouter.v1.ConnectorService/Get"
	ConnectorService_List_FullMethodName                 = "/yandex.cloud.serverless.eventrouter.v1.ConnectorService/List"
	ConnectorService_Create_FullMethodName               = "/yandex.cloud.serverless.eventrouter.v1.ConnectorService/Create"
	ConnectorService_Update_FullMethodName               = "/yandex.cloud.serverless.eventrouter.v1.ConnectorService/Update"
	ConnectorService_Delete_FullMethodName               = "/yandex.cloud.serverless.eventrouter.v1.ConnectorService/Delete"
	ConnectorService_Start_FullMethodName                = "/yandex.cloud.serverless.eventrouter.v1.ConnectorService/Start"
	ConnectorService_Stop_FullMethodName                 = "/yandex.cloud.serverless.eventrouter.v1.ConnectorService/Stop"
	ConnectorService_ListAccessBindings_FullMethodName   = "/yandex.cloud.serverless.eventrouter.v1.ConnectorService/ListAccessBindings"
	ConnectorService_SetAccessBindings_FullMethodName    = "/yandex.cloud.serverless.eventrouter.v1.ConnectorService/SetAccessBindings"
	ConnectorService_UpdateAccessBindings_FullMethodName = "/yandex.cloud.serverless.eventrouter.v1.ConnectorService/UpdateAccessBindings"
	ConnectorService_ListOperations_FullMethodName       = "/yandex.cloud.serverless.eventrouter.v1.ConnectorService/ListOperations"
)
View Source 
const (
	RuleService_Get_FullMethodName                  = "/yandex.cloud.serverless.eventrouter.v1.RuleService/Get"
	RuleService_List_FullMethodName                 = "/yandex.cloud.serverless.eventrouter.v1.RuleService/List"
	RuleService_Create_FullMethodName               = "/yandex.cloud.serverless.eventrouter.v1.RuleService/Create"
	RuleService_Update_FullMethodName               = "/yandex.cloud.serverless.eventrouter.v1.RuleService/Update"
	RuleService_Delete_FullMethodName               = "/yandex.cloud.serverless.eventrouter.v1.RuleService/Delete"
	RuleService_Enable_FullMethodName               = "/yandex.cloud.serverless.eventrouter.v1.RuleService/Enable"
	RuleService_Disable_FullMethodName              = "/yandex.cloud.serverless.eventrouter.v1.RuleService/Disable"
	RuleService_ListAccessBindings_FullMethodName   = "/yandex.cloud.serverless.eventrouter.v1.RuleService/ListAccessBindings"
	RuleService_SetAccessBindings_FullMethodName    = "/yandex.cloud.serverless.eventrouter.v1.RuleService/SetAccessBindings"
	RuleService_UpdateAccessBindings_FullMethodName = "/yandex.cloud.serverless.eventrouter.v1.RuleService/UpdateAccessBindings"
	RuleService_ListOperations_FullMethodName       = "/yandex.cloud.serverless.eventrouter.v1.RuleService/ListOperations"
)
View Source 
const (
	EventService_Put_FullMethodName = "/yandex.cloud.serverless.eventrouter.v1.EventService/Put"
)

Variables

View Source 
var (
	Bus_Status_name = map[int32]string{
		0: "STATUS_UNSPECIFIED",
		1: "CREATING",
		2: "ACTIVE",
		3: "DELETING",
	}
	Bus_Status_value = map[string]int32{
		"STATUS_UNSPECIFIED": 0,
		"CREATING":           1,
		"ACTIVE":             2,
		"DELETING":           3,
	}
)

Enum value maps for Bus_Status.

View Source 
var (
	Connector_Status_name = map[int32]string{
		0: "STATUS_UNSPECIFIED",
		1: "RUNNING",
		2: "STOPPED",
		3: "RESOURCE_NOT_FOUND",
		4: "PERMISSION_DENIED",
		5: "SUBJECT_NOT_FOUND",
		7: "DELETING",
		8: "CREATING",
	}
	Connector_Status_value = map[string]int32{
		"STATUS_UNSPECIFIED": 0,
		"RUNNING":            1,
		"STOPPED":            2,
		"RESOURCE_NOT_FOUND": 3,
		"PERMISSION_DENIED":  4,
		"SUBJECT_NOT_FOUND":  5,
		"DELETING":           7,
		"CREATING":           8,
	}
)

Enum value maps for Connector_Status.

View Source 
var (
	Rule_Status_name = map[int32]string{
		0: "STATUS_UNSPECIFIED",
		1: "CREATING",
		2: "ENABLED",
		3: "UPDATING",
		4: "DISABLED",
		5: "DELETING",
	}
	Rule_Status_value = map[string]int32{
		"STATUS_UNSPECIFIED": 0,
		"CREATING":           1,
		"ENABLED":            2,
		"UPDATING":           3,
		"DISABLED":           4,
		"DELETING":           5,
	}
)

Enum value maps for Rule_Status.

View Source 
var (
	Target_Status_name = map[int32]string{
		0: "STATUS_UNSPECIFIED",
		1: "ENABLED",
		2: "DISABLED",
		3: "RESOURCE_NOT_FOUND",
		4: "PERMISSION_DENIED",
		5: "SUBJECT_NOT_FOUND",
	}
	Target_Status_value = map[string]int32{
		"STATUS_UNSPECIFIED": 0,
		"ENABLED":            1,
		"DISABLED":           2,
		"RESOURCE_NOT_FOUND": 3,
		"PERMISSION_DENIED":  4,
		"SUBJECT_NOT_FOUND":  5,
	}
)

Enum value maps for Target_Status.

View Source 
var BusService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yandex.cloud.serverless.eventrouter.v1.BusService",
	HandlerType: (*BusServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _BusService_Get_Handler,
		},
		{
			MethodName: "List",
			Handler:    _BusService_List_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _BusService_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _BusService_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _BusService_Delete_Handler,
		},
		{
			MethodName: "ListOperations",
			Handler:    _BusService_ListOperations_Handler,
		},
		{
			MethodName: "ListAccessBindings",
			Handler:    _BusService_ListAccessBindings_Handler,
		},
		{
			MethodName: "SetAccessBindings",
			Handler:    _BusService_SetAccessBindings_Handler,
		},
		{
			MethodName: "UpdateAccessBindings",
			Handler:    _BusService_UpdateAccessBindings_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "yandex/cloud/serverless/eventrouter/v1/bus_service.proto",
}

BusService_ServiceDesc is the grpc.ServiceDesc for BusService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var ConnectorService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yandex.cloud.serverless.eventrouter.v1.ConnectorService",
	HandlerType: (*ConnectorServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _ConnectorService_Get_Handler,
		},
		{
			MethodName: "List",
			Handler:    _ConnectorService_List_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _ConnectorService_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _ConnectorService_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _ConnectorService_Delete_Handler,
		},
		{
			MethodName: "Start",
			Handler:    _ConnectorService_Start_Handler,
		},
		{
			MethodName: "Stop",
			Handler:    _ConnectorService_Stop_Handler,
		},
		{
			MethodName: "ListAccessBindings",
			Handler:    _ConnectorService_ListAccessBindings_Handler,
		},
		{
			MethodName: "SetAccessBindings",
			Handler:    _ConnectorService_SetAccessBindings_Handler,
		},
		{
			MethodName: "UpdateAccessBindings",
			Handler:    _ConnectorService_UpdateAccessBindings_Handler,
		},
		{
			MethodName: "ListOperations",
			Handler:    _ConnectorService_ListOperations_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "yandex/cloud/serverless/eventrouter/v1/connector_service.proto",
}

ConnectorService_ServiceDesc is the grpc.ServiceDesc for ConnectorService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var EventService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yandex.cloud.serverless.eventrouter.v1.EventService",
	HandlerType: (*EventServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Put",
			Handler:    _EventService_Put_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "yandex/cloud/serverless/eventrouter/v1/event_service.proto",
}

EventService_ServiceDesc is the grpc.ServiceDesc for EventService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_yandex_cloud_serverless_eventrouter_v1_bus_proto protoreflect.FileDescriptor
View Source 
var File_yandex_cloud_serverless_eventrouter_v1_bus_service_proto protoreflect.FileDescriptor
View Source 
var File_yandex_cloud_serverless_eventrouter_v1_connector_proto protoreflect.FileDescriptor
View Source 
var File_yandex_cloud_serverless_eventrouter_v1_connector_service_proto protoreflect.FileDescriptor
View Source 
var File_yandex_cloud_serverless_eventrouter_v1_event_service_proto protoreflect.FileDescriptor
View Source 
var File_yandex_cloud_serverless_eventrouter_v1_rule_proto protoreflect.FileDescriptor
View Source 
var File_yandex_cloud_serverless_eventrouter_v1_rule_service_proto protoreflect.FileDescriptor
View Source 
var RuleService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yandex.cloud.serverless.eventrouter.v1.RuleService",
	HandlerType: (*RuleServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _RuleService_Get_Handler,
		},
		{
			MethodName: "List",
			Handler:    _RuleService_List_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _RuleService_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _RuleService_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _RuleService_Delete_Handler,
		},
		{
			MethodName: "Enable",
			Handler:    _RuleService_Enable_Handler,
		},
		{
			MethodName: "Disable",
			Handler:    _RuleService_Disable_Handler,
		},
		{
			MethodName: "ListAccessBindings",
			Handler:    _RuleService_ListAccessBindings_Handler,
		},
		{
			MethodName: "SetAccessBindings",
			Handler:    _RuleService_SetAccessBindings_Handler,
		},
		{
			MethodName: "UpdateAccessBindings",
			Handler:    _RuleService_UpdateAccessBindings_Handler,
		},
		{
			MethodName: "ListOperations",
			Handler:    _RuleService_ListOperations_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "yandex/cloud/serverless/eventrouter/v1/rule_service.proto",
}

RuleService_ServiceDesc is the grpc.ServiceDesc for RuleService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterBusServiceServer 

func RegisterBusServiceServer(s grpc.ServiceRegistrar, srv BusServiceServer)

func RegisterConnectorServiceServer 

func RegisterConnectorServiceServer(s grpc.ServiceRegistrar, srv ConnectorServiceServer)

func RegisterEventServiceServer 

func RegisterEventServiceServer(s grpc.ServiceRegistrar, srv EventServiceServer)

func RegisterRuleServiceServer 

func RegisterRuleServiceServer(s grpc.ServiceRegistrar, srv RuleServiceServer)

Types

type BatchSettings 

type BatchSettings struct {

	// Maximum batch size: trigger will send a batch if number of events exceeds this value.
	MaxCount int64 `protobuf:"varint,1,opt,name=max_count,json=maxCount,proto3" json:"max_count,omitempty"`
	// Maximum batch size: trigger will send a batch if total size of events exceeds this value.
	MaxBytes int64 `protobuf:"varint,2,opt,name=max_bytes,json=maxBytes,proto3" json:"max_bytes,omitempty"`
	// Maximum batch size: trigger will send a batch if its lifetime exceeds this value.
	Cutoff *durationpb.Duration `protobuf:"bytes,3,opt,name=cutoff,proto3" json:"cutoff,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchSettings) Descriptor deprecated 

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

Deprecated: Use BatchSettings.ProtoReflect.Descriptor instead.

func (*BatchSettings) GetCutoff 

func (x *BatchSettings) GetCutoff() *durationpb.Duration

func (*BatchSettings) GetMaxBytes 

func (x *BatchSettings) GetMaxBytes() int64

func (*BatchSettings) GetMaxCount 

func (x *BatchSettings) GetMaxCount() int64

func (*BatchSettings) ProtoMessage 

func (*BatchSettings) ProtoMessage()

func (*BatchSettings) ProtoReflect 

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

func (*BatchSettings) Reset 

func (x *BatchSettings) Reset()

func (*BatchSettings) SetCutoff 

func (m *BatchSettings) SetCutoff(v *durationpb.Duration)

func (*BatchSettings) SetMaxBytes 

func (m *BatchSettings) SetMaxBytes(v int64)

func (*BatchSettings) SetMaxCount 

func (m *BatchSettings) SetMaxCount(v int64)

func (*BatchSettings) String 

func (x *BatchSettings) String() string

type Bus 

type Bus struct {

	// ID of the bus.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// ID of the folder that the bus belongs to.
	FolderId string `protobuf:"bytes,2,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	// ID of the cloud that the bus resides in.
	CloudId string `protobuf:"bytes,3,opt,name=cloud_id,json=cloudId,proto3" json:"cloud_id,omitempty"`
	// Creation timestamp.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Name of the bus.
	Name string `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the bus.
	Description string `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
	// Resource labels as `key:value` pairs.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Deletion protection.
	DeletionProtection bool `protobuf:"varint,8,opt,name=deletion_protection,json=deletionProtection,proto3" json:"deletion_protection,omitempty"`
	// Status of the bus.
	Status Bus_Status `protobuf:"varint,9,opt,name=status,proto3,enum=yandex.cloud.serverless.eventrouter.v1.Bus_Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*Bus) Descriptor deprecated 

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

Deprecated: Use Bus.ProtoReflect.Descriptor instead.

func (*Bus) GetCloudId 

func (x *Bus) GetCloudId() string

func (*Bus) GetCreatedAt 

func (x *Bus) GetCreatedAt() *timestamppb.Timestamp

func (*Bus) GetDeletionProtection 

func (x *Bus) GetDeletionProtection() bool

func (*Bus) GetDescription 

func (x *Bus) GetDescription() string

func (*Bus) GetFolderId 

func (x *Bus) GetFolderId() string

func (*Bus) GetId 

func (x *Bus) GetId() string

func (*Bus) GetLabels 

func (x *Bus) GetLabels() map[string]string

func (*Bus) GetName 

func (x *Bus) GetName() string

func (*Bus) GetStatus 

func (x *Bus) GetStatus() Bus_Status

func (*Bus) ProtoMessage 

func (*Bus) ProtoMessage()

func (*Bus) ProtoReflect 

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

func (*Bus) Reset 

func (x *Bus) Reset()

func (*Bus) SetCloudId 

func (m *Bus) SetCloudId(v string)

func (*Bus) SetCreatedAt 

func (m *Bus) SetCreatedAt(v *timestamppb.Timestamp)

func (*Bus) SetDeletionProtection 

func (m *Bus) SetDeletionProtection(v bool)

func (*Bus) SetDescription 

func (m *Bus) SetDescription(v string)

func (*Bus) SetFolderId 

func (m *Bus) SetFolderId(v string)

func (*Bus) SetId 

func (m *Bus) SetId(v string)

func (*Bus) SetLabels 

func (m *Bus) SetLabels(v map[string]string)

func (*Bus) SetName 

func (m *Bus) SetName(v string)

func (*Bus) SetStatus 

func (m *Bus) SetStatus(v Bus_Status)

func (*Bus) String 

func (x *Bus) String() string

type BusServiceClient 

type BusServiceClient interface {
	// Returns the specified bus.
	// To get the list of all available buses, make a [List] request.
	Get(ctx context.Context, in *GetBusRequest, opts ...grpc.CallOption) (*Bus, error)
	// Retrieves the list of buses in the specified folder.
	List(ctx context.Context, in *ListBusesRequest, opts ...grpc.CallOption) (*ListBusesResponse, error)
	// Creates a bus in the specified folder.
	Create(ctx context.Context, in *CreateBusRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Updates the specified bus.
	Update(ctx context.Context, in *UpdateBusRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Deletes the specified bus.
	Delete(ctx context.Context, in *DeleteBusRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Lists operations for the specified bus.
	ListOperations(ctx context.Context, in *ListBusOperationsRequest, opts ...grpc.CallOption) (*ListBusOperationsResponse, error)
	// Lists existing access bindings for the specified bus.
	ListAccessBindings(ctx context.Context, in *access.ListAccessBindingsRequest, opts ...grpc.CallOption) (*access.ListAccessBindingsResponse, error)
	// Sets access bindings for the bus.
	SetAccessBindings(ctx context.Context, in *access.SetAccessBindingsRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Updates access bindings for the specified bus.
	UpdateAccessBindings(ctx context.Context, in *access.UpdateAccessBindingsRequest, opts ...grpc.CallOption) (*operation.Operation, error)
}

BusServiceClient is the client API for BusService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

A set of methods for managing buses for serverless eventrouter.

func NewBusServiceClient 

func NewBusServiceClient(cc grpc.ClientConnInterface) BusServiceClient

type BusServiceServer 

type BusServiceServer interface {
	// Returns the specified bus.
	// To get the list of all available buses, make a [List] request.
	Get(context.Context, *GetBusRequest) (*Bus, error)
	// Retrieves the list of buses in the specified folder.
	List(context.Context, *ListBusesRequest) (*ListBusesResponse, error)
	// Creates a bus in the specified folder.
	Create(context.Context, *CreateBusRequest) (*operation.Operation, error)
	// Updates the specified bus.
	Update(context.Context, *UpdateBusRequest) (*operation.Operation, error)
	// Deletes the specified bus.
	Delete(context.Context, *DeleteBusRequest) (*operation.Operation, error)
	// Lists operations for the specified bus.
	ListOperations(context.Context, *ListBusOperationsRequest) (*ListBusOperationsResponse, error)
	// Lists existing access bindings for the specified bus.
	ListAccessBindings(context.Context, *access.ListAccessBindingsRequest) (*access.ListAccessBindingsResponse, error)
	// Sets access bindings for the bus.
	SetAccessBindings(context.Context, *access.SetAccessBindingsRequest) (*operation.Operation, error)
	// Updates access bindings for the specified bus.
	UpdateAccessBindings(context.Context, *access.UpdateAccessBindingsRequest) (*operation.Operation, error)
}

BusServiceServer is the server API for BusService service. All implementations should embed UnimplementedBusServiceServer for forward compatibility.

A set of methods for managing buses for serverless eventrouter.

type Bus_Status 

type Bus_Status int32
const (
	Bus_STATUS_UNSPECIFIED Bus_Status = 0
	Bus_CREATING           Bus_Status = 1
	Bus_ACTIVE             Bus_Status = 2
	Bus_DELETING           Bus_Status = 3
)

func (Bus_Status) Descriptor 

func (Bus_Status) Descriptor() protoreflect.EnumDescriptor

func (Bus_Status) Enum 

func (x Bus_Status) Enum() *Bus_Status

func (Bus_Status) EnumDescriptor deprecated 

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

Deprecated: Use Bus_Status.Descriptor instead.

func (Bus_Status) Number 

func (x Bus_Status) Number() protoreflect.EnumNumber

func (Bus_Status) String 

func (x Bus_Status) String() string

func (Bus_Status) Type 

func (Bus_Status) Type() protoreflect.EnumType

type Connector 

type Connector struct {

	// ID of the connector.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// ID of the bus that the connector belongs to.
	BusId string `protobuf:"bytes,2,opt,name=bus_id,json=busId,proto3" json:"bus_id,omitempty"`
	// ID of the folder that the connector resides in.
	FolderId string `protobuf:"bytes,3,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	// ID of the cloud that the connector resides in.
	CloudId string `protobuf:"bytes,4,opt,name=cloud_id,json=cloudId,proto3" json:"cloud_id,omitempty"`
	// Creation timestamp.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Name of the connector.
	Name string `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the connector.
	Description string `protobuf:"bytes,7,opt,name=description,proto3" json:"description,omitempty"`
	// Resource labels as `key:value` pairs.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Source of the connector.
	Source *Source `protobuf:"bytes,9,opt,name=source,proto3" json:"source,omitempty"`
	// Deletion protection.
	DeletionProtection bool `protobuf:"varint,10,opt,name=deletion_protection,json=deletionProtection,proto3" json:"deletion_protection,omitempty"`
	// Status of the connector.
	Status Connector_Status `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Connector) Descriptor deprecated 

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

Deprecated: Use Connector.ProtoReflect.Descriptor instead.

func (*Connector) GetBusId 

func (x *Connector) GetBusId() string

func (*Connector) GetCloudId 

func (x *Connector) GetCloudId() string

func (*Connector) GetCreatedAt 

func (x *Connector) GetCreatedAt() *timestamppb.Timestamp

func (*Connector) GetDeletionProtection 

func (x *Connector) GetDeletionProtection() bool

func (*Connector) GetDescription 

func (x *Connector) GetDescription() string

func (*Connector) GetFolderId 

func (x *Connector) GetFolderId() string

func (*Connector) GetId 

func (x *Connector) GetId() string

func (*Connector) GetLabels 

func (x *Connector) GetLabels() map[string]string

func (*Connector) GetName 

func (x *Connector) GetName() string

func (*Connector) GetSource 

func (x *Connector) GetSource() *Source

func (*Connector) GetStatus 

func (x *Connector) GetStatus() Connector_Status

func (*Connector) ProtoMessage 

func (*Connector) ProtoMessage()

func (*Connector) ProtoReflect 

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

func (*Connector) Reset 

func (x *Connector) Reset()

func (*Connector) SetBusId 

func (m *Connector) SetBusId(v string)

func (*Connector) SetCloudId 

func (m *Connector) SetCloudId(v string)

func (*Connector) SetCreatedAt 

func (m *Connector) SetCreatedAt(v *timestamppb.Timestamp)

func (*Connector) SetDeletionProtection 

func (m *Connector) SetDeletionProtection(v bool)

func (*Connector) SetDescription 

func (m *Connector) SetDescription(v string)

func (*Connector) SetFolderId 

func (m *Connector) SetFolderId(v string)

func (*Connector) SetId 

func (m *Connector) SetId(v string)

func (*Connector) SetLabels 

func (m *Connector) SetLabels(v map[string]string)

func (*Connector) SetName 

func (m *Connector) SetName(v string)

func (*Connector) SetSource 

func (m *Connector) SetSource(v *Source)

func (*Connector) SetStatus 

func (m *Connector) SetStatus(v Connector_Status)

func (*Connector) String 

func (x *Connector) String() string

type ConnectorServiceClient 

type ConnectorServiceClient interface {
	// Returns the specified bus.
	// To get the list of all available connectors, make a [List] request.
	Get(ctx context.Context, in *GetConnectorRequest, opts ...grpc.CallOption) (*Connector, error)
	// Retrieves the list of connectors in the specified folder.
	List(ctx context.Context, in *ListConnectorsRequest, opts ...grpc.CallOption) (*ListConnectorsResponse, error)
	// Creates a connector in the specified folder.
	Create(ctx context.Context, in *CreateConnectorRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Updates the specified connector.
	Update(ctx context.Context, in *UpdateConnectorRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Deletes the specified connector.
	Delete(ctx context.Context, in *DeleteConnectorRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Starts the specified connector.
	Start(ctx context.Context, in *StartConnectorRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Stops the specified connector.
	Stop(ctx context.Context, in *StopConnectorRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Lists existing access bindings for the specified bus.
	ListAccessBindings(ctx context.Context, in *access.ListAccessBindingsRequest, opts ...grpc.CallOption) (*access.ListAccessBindingsResponse, error)
	// Sets access bindings for the connector.
	SetAccessBindings(ctx context.Context, in *access.SetAccessBindingsRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Updates access bindings for the specified connector.
	UpdateAccessBindings(ctx context.Context, in *access.UpdateAccessBindingsRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Lists operations for the specified connector.
	ListOperations(ctx context.Context, in *ListConnectorOperationsRequest, opts ...grpc.CallOption) (*ListConnectorOperationsResponse, error)
}

ConnectorServiceClient is the client API for ConnectorService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

A set of methods for managing connectors for serverless eventrouter.

func NewConnectorServiceClient 

func NewConnectorServiceClient(cc grpc.ClientConnInterface) ConnectorServiceClient

type ConnectorServiceServer 

type ConnectorServiceServer interface {
	// Returns the specified bus.
	// To get the list of all available connectors, make a [List] request.
	Get(context.Context, *GetConnectorRequest) (*Connector, error)
	// Retrieves the list of connectors in the specified folder.
	List(context.Context, *ListConnectorsRequest) (*ListConnectorsResponse, error)
	// Creates a connector in the specified folder.
	Create(context.Context, *CreateConnectorRequest) (*operation.Operation, error)
	// Updates the specified connector.
	Update(context.Context, *UpdateConnectorRequest) (*operation.Operation, error)
	// Deletes the specified connector.
	Delete(context.Context, *DeleteConnectorRequest) (*operation.Operation, error)
	// Starts the specified connector.
	Start(context.Context, *StartConnectorRequest) (*operation.Operation, error)
	// Stops the specified connector.
	Stop(context.Context, *StopConnectorRequest) (*operation.Operation, error)
	// Lists existing access bindings for the specified bus.
	ListAccessBindings(context.Context, *access.ListAccessBindingsRequest) (*access.ListAccessBindingsResponse, error)
	// Sets access bindings for the connector.
	SetAccessBindings(context.Context, *access.SetAccessBindingsRequest) (*operation.Operation, error)
	// Updates access bindings for the specified connector.
	UpdateAccessBindings(context.Context, *access.UpdateAccessBindingsRequest) (*operation.Operation, error)
	// Lists operations for the specified connector.
	ListOperations(context.Context, *ListConnectorOperationsRequest) (*ListConnectorOperationsResponse, error)
}

ConnectorServiceServer is the server API for ConnectorService service. All implementations should embed UnimplementedConnectorServiceServer for forward compatibility.

A set of methods for managing connectors for serverless eventrouter.

type Connector_Status 

type Connector_Status int32

Status of the connector. 

const (
	Connector_STATUS_UNSPECIFIED Connector_Status = 0
	Connector_RUNNING            Connector_Status = 1
	// disabled by user
	Connector_STOPPED Connector_Status = 2
	// source does not exist
	Connector_RESOURCE_NOT_FOUND Connector_Status = 3
	// service account does not have read permission on source
	Connector_PERMISSION_DENIED Connector_Status = 4
	// service account not found
	Connector_SUBJECT_NOT_FOUND Connector_Status = 5
	// deletion in progress
	Connector_DELETING Connector_Status = 7
	// creation in progress
	Connector_CREATING Connector_Status = 8
)

func (Connector_Status) Descriptor 

func (Connector_Status) Descriptor() protoreflect.EnumDescriptor

func (Connector_Status) Enum 

func (x Connector_Status) Enum() *Connector_Status

func (Connector_Status) EnumDescriptor deprecated 

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

Deprecated: Use Connector_Status.Descriptor instead.

func (Connector_Status) Number 

func (x Connector_Status) Number() protoreflect.EnumNumber

func (Connector_Status) String 

func (x Connector_Status) String() string

func (Connector_Status) Type 

func (Connector_Status) Type() protoreflect.EnumType

type ContainerTarget 

type ContainerTarget struct {

	// Container ID.
	ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// Container revision ID.
	ContainerRevisionId string `protobuf:"bytes,2,opt,name=container_revision_id,json=containerRevisionId,proto3" json:"container_revision_id,omitempty"`
	// Endpoint HTTP path to invoke.
	Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	// Service account which should be used to call a container, optional.
	ServiceAccountId string `protobuf:"bytes,4,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"`
	// Batch settings.
	BatchSettings *BatchSettings `protobuf:"bytes,5,opt,name=batch_settings,json=batchSettings,proto3" json:"batch_settings,omitempty"`
	// contains filtered or unexported fields
}

func (*ContainerTarget) Descriptor deprecated 

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

Deprecated: Use ContainerTarget.ProtoReflect.Descriptor instead.

func (*ContainerTarget) GetBatchSettings 

func (x *ContainerTarget) GetBatchSettings() *BatchSettings

func (*ContainerTarget) GetContainerId 

func (x *ContainerTarget) GetContainerId() string

func (*ContainerTarget) GetContainerRevisionId 

func (x *ContainerTarget) GetContainerRevisionId() string

func (*ContainerTarget) GetPath 

func (x *ContainerTarget) GetPath() string

func (*ContainerTarget) GetServiceAccountId 

func (x *ContainerTarget) GetServiceAccountId() string

func (*ContainerTarget) ProtoMessage 

func (*ContainerTarget) ProtoMessage()

func (*ContainerTarget) ProtoReflect 

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

func (*ContainerTarget) Reset 

func (x *ContainerTarget) Reset()

func (*ContainerTarget) SetBatchSettings 

func (m *ContainerTarget) SetBatchSettings(v *BatchSettings)

func (*ContainerTarget) SetContainerId 

func (m *ContainerTarget) SetContainerId(v string)

func (*ContainerTarget) SetContainerRevisionId 

func (m *ContainerTarget) SetContainerRevisionId(v string)

func (*ContainerTarget) SetPath 

func (m *ContainerTarget) SetPath(v string)

func (*ContainerTarget) SetServiceAccountId 

func (m *ContainerTarget) SetServiceAccountId(v string)

func (*ContainerTarget) String 

func (x *ContainerTarget) String() string

type CreateBusMetadata 

type CreateBusMetadata struct {

	// ID of the bus that is being created.
	BusId string `protobuf:"bytes,1,opt,name=bus_id,json=busId,proto3" json:"bus_id,omitempty"`
	// ID of the folder that the bus is being created in.
	FolderId string `protobuf:"bytes,2,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateBusMetadata) Descriptor deprecated 

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

Deprecated: Use CreateBusMetadata.ProtoReflect.Descriptor instead.

func (*CreateBusMetadata) GetBusId 

func (x *CreateBusMetadata) GetBusId() string

func (*CreateBusMetadata) GetFolderId 

func (x *CreateBusMetadata) GetFolderId() string

func (*CreateBusMetadata) ProtoMessage 

func (*CreateBusMetadata) ProtoMessage()

func (*CreateBusMetadata) ProtoReflect 

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

func (*CreateBusMetadata) Reset 

func (x *CreateBusMetadata) Reset()

func (*CreateBusMetadata) SetBusId 

func (m *CreateBusMetadata) SetBusId(v string)

func (*CreateBusMetadata) SetFolderId 

func (m *CreateBusMetadata) SetFolderId(v string)

func (*CreateBusMetadata) String 

func (x *CreateBusMetadata) String() string

type CreateBusRequest 

type CreateBusRequest struct {

	// ID of the folder to create a bus in.
	FolderId string `protobuf:"bytes,1,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	// Name of the bus.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the bus.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Labels for the bus.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Flag that disallow deletion of the bus.
	DeletionProtection bool `protobuf:"varint,5,opt,name=deletion_protection,json=deletionProtection,proto3" json:"deletion_protection,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateBusRequest) Descriptor deprecated 

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

Deprecated: Use CreateBusRequest.ProtoReflect.Descriptor instead.

func (*CreateBusRequest) GetDeletionProtection 

func (x *CreateBusRequest) GetDeletionProtection() bool

func (*CreateBusRequest) GetDescription 

func (x *CreateBusRequest) GetDescription() string

func (*CreateBusRequest) GetFolderId 

func (x *CreateBusRequest) GetFolderId() string

func (*CreateBusRequest) GetLabels 

func (x *CreateBusRequest) GetLabels() map[string]string

func (*CreateBusRequest) GetName 

func (x *CreateBusRequest) GetName() string

func (*CreateBusRequest) ProtoMessage 

func (*CreateBusRequest) ProtoMessage()

func (*CreateBusRequest) ProtoReflect 

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

func (*CreateBusRequest) Reset 

func (x *CreateBusRequest) Reset()

func (*CreateBusRequest) SetDeletionProtection 

func (m *CreateBusRequest) SetDeletionProtection(v bool)

func (*CreateBusRequest) SetDescription 

func (m *CreateBusRequest) SetDescription(v string)

func (*CreateBusRequest) SetFolderId 

func (m *CreateBusRequest) SetFolderId(v string)

func (*CreateBusRequest) SetLabels 

func (m *CreateBusRequest) SetLabels(v map[string]string)

func (*CreateBusRequest) SetName 

func (m *CreateBusRequest) SetName(v string)

func (*CreateBusRequest) String 

func (x *CreateBusRequest) String() string

type CreateConnectorMetadata 

type CreateConnectorMetadata struct {

	// ID of the connector that is being created.
	ConnectorId string `protobuf:"bytes,1,opt,name=connector_id,json=connectorId,proto3" json:"connector_id,omitempty"`
	// ID of the bus that the connector is created in.
	BusId string `protobuf:"bytes,2,opt,name=bus_id,json=busId,proto3" json:"bus_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateConnectorMetadata) Descriptor deprecated 

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

Deprecated: Use CreateConnectorMetadata.ProtoReflect.Descriptor instead.

func (*CreateConnectorMetadata) GetBusId 

func (x *CreateConnectorMetadata) GetBusId() string

func (*CreateConnectorMetadata) GetConnectorId 

func (x *CreateConnectorMetadata) GetConnectorId() string

func (*CreateConnectorMetadata) ProtoMessage 

func (*CreateConnectorMetadata) ProtoMessage()

func (*CreateConnectorMetadata) ProtoReflect 

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

func (*CreateConnectorMetadata) Reset 

func (x *CreateConnectorMetadata) Reset()

func (*CreateConnectorMetadata) SetBusId 

func (m *CreateConnectorMetadata) SetBusId(v string)

func (*CreateConnectorMetadata) SetConnectorId 

func (m *CreateConnectorMetadata) SetConnectorId(v string)

func (*CreateConnectorMetadata) String 

func (x *CreateConnectorMetadata) String() string

type CreateConnectorRequest 

type CreateConnectorRequest struct {

	// ID of the bus to create a connector in.
	BusId string `protobuf:"bytes,1,opt,name=bus_id,json=busId,proto3" json:"bus_id,omitempty"`
	// Name of the connector.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the connector.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Labels for the connector.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Source of the connector.
	Source *Source `protobuf:"bytes,5,opt,name=source,proto3" json:"source,omitempty"`
	// Flag that disallow deletion of the connector.
	DeletionProtection bool `protobuf:"varint,6,opt,name=deletion_protection,json=deletionProtection,proto3" json:"deletion_protection,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateConnectorRequest) Descriptor deprecated 

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

Deprecated: Use CreateConnectorRequest.ProtoReflect.Descriptor instead.

func (*CreateConnectorRequest) GetBusId 

func (x *CreateConnectorRequest) GetBusId() string

func (*CreateConnectorRequest) GetDeletionProtection 

func (x *CreateConnectorRequest) GetDeletionProtection() bool

func (*CreateConnectorRequest) GetDescription 

func (x *CreateConnectorRequest) GetDescription() string

func (*CreateConnectorRequest) GetLabels 

func (x *CreateConnectorRequest) GetLabels() map[string]string

func (*CreateConnectorRequest) GetName 

func (x *CreateConnectorRequest) GetName() string

func (*CreateConnectorRequest) GetSource 

func (x *CreateConnectorRequest) GetSource() *Source

func (*CreateConnectorRequest) ProtoMessage 

func (*CreateConnectorRequest) ProtoMessage()

func (*CreateConnectorRequest) ProtoReflect 

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

func (*CreateConnectorRequest) Reset 

func (x *CreateConnectorRequest) Reset()

func (*CreateConnectorRequest) SetBusId 

func (m *CreateConnectorRequest) SetBusId(v string)

func (*CreateConnectorRequest) SetDeletionProtection 

func (m *CreateConnectorRequest) SetDeletionProtection(v bool)

func (*CreateConnectorRequest) SetDescription 

func (m *CreateConnectorRequest) SetDescription(v string)

func (*CreateConnectorRequest) SetLabels 

func (m *CreateConnectorRequest) SetLabels(v map[string]string)

func (*CreateConnectorRequest) SetName 

func (m *CreateConnectorRequest) SetName(v string)

func (*CreateConnectorRequest) SetSource 

func (m *CreateConnectorRequest) SetSource(v *Source)

func (*CreateConnectorRequest) String 

func (x *CreateConnectorRequest) String() string

type CreateRuleMetadata 

type CreateRuleMetadata struct {

	// ID of the rule that is being created.
	RuleId string `protobuf:"bytes,1,opt,name=rule_id,json=ruleId,proto3" json:"rule_id,omitempty"`
	// ID of the bus that the rule belongs to.
	BusId string `protobuf:"bytes,2,opt,name=bus_id,json=busId,proto3" json:"bus_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateRuleMetadata) Descriptor deprecated 

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

Deprecated: Use CreateRuleMetadata.ProtoReflect.Descriptor instead.

func (*CreateRuleMetadata) GetBusId 

func (x *CreateRuleMetadata) GetBusId() string

func (*CreateRuleMetadata) GetRuleId 

func (x *CreateRuleMetadata) GetRuleId() string

func (*CreateRuleMetadata) ProtoMessage 

func (*CreateRuleMetadata) ProtoMessage()

func (*CreateRuleMetadata) ProtoReflect 

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

func (*CreateRuleMetadata) Reset 

func (x *CreateRuleMetadata) Reset()

func (*CreateRuleMetadata) SetBusId 

func (m *CreateRuleMetadata) SetBusId(v string)

func (*CreateRuleMetadata) SetRuleId 

func (m *CreateRuleMetadata) SetRuleId(v string)

func (*CreateRuleMetadata) String 

func (x *CreateRuleMetadata) String() string

type CreateRuleRequest 

type CreateRuleRequest struct {

	// ID of the bus to create a rule for.
	BusId string `protobuf:"bytes,1,opt,name=bus_id,json=busId,proto3" json:"bus_id,omitempty"`
	// Name of the rule.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the rule.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Labels for the rule.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Filter for the rule.
	Filter *Filter `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
	// Targets for the rule.
	Targets []*Target `protobuf:"bytes,6,rep,name=targets,proto3" json:"targets,omitempty"`
	// Flag that disallow deletion of the rule.
	DeletionProtection bool `protobuf:"varint,7,opt,name=deletion_protection,json=deletionProtection,proto3" json:"deletion_protection,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateRuleRequest) Descriptor deprecated 

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

Deprecated: Use CreateRuleRequest.ProtoReflect.Descriptor instead.

func (*CreateRuleRequest) GetBusId 

func (x *CreateRuleRequest) GetBusId() string

func (*CreateRuleRequest) GetDeletionProtection 

func (x *CreateRuleRequest) GetDeletionProtection() bool

func (*CreateRuleRequest) GetDescription 

func (x *CreateRuleRequest) GetDescription() string

func (*CreateRuleRequest) GetFilter 

func (x *CreateRuleRequest) GetFilter() *Filter

func (*CreateRuleRequest) GetLabels 

func (x *CreateRuleRequest) GetLabels() map[string]string

func (*CreateRuleRequest) GetName 

func (x *CreateRuleRequest) GetName() string

func (*CreateRuleRequest) GetTargets 

func (x *CreateRuleRequest) GetTargets() []*Target

func (*CreateRuleRequest) ProtoMessage 

func (*CreateRuleRequest) ProtoMessage()

func (*CreateRuleRequest) ProtoReflect 

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

func (*CreateRuleRequest) Reset 

func (x *CreateRuleRequest) Reset()

func (*CreateRuleRequest) SetBusId 

func (m *CreateRuleRequest) SetBusId(v string)

func (*CreateRuleRequest) SetDeletionProtection 

func (m *CreateRuleRequest) SetDeletionProtection(v bool)

func (*CreateRuleRequest) SetDescription 

func (m *CreateRuleRequest) SetDescription(v string)

func (*CreateRuleRequest) SetFilter 

func (m *CreateRuleRequest) SetFilter(v *Filter)

func (*CreateRuleRequest) SetLabels 

func (m *CreateRuleRequest) SetLabels(v map[string]string)

func (*CreateRuleRequest) SetName 

func (m *CreateRuleRequest) SetName(v string)

func (*CreateRuleRequest) SetTargets 

func (m *CreateRuleRequest) SetTargets(v []*Target)

func (*CreateRuleRequest) String 

func (x *CreateRuleRequest) String() string

type DataStream 

type DataStream struct {

	// Stream database.
	// example: /ru-central1/aoegtvhtp8ob********/cc8004q4lbo6********
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// Stream name, absolute or relative.
	StreamName string `protobuf:"bytes,2,opt,name=stream_name,json=streamName,proto3" json:"stream_name,omitempty"`
	// Consumer name.
	Consumer string `protobuf:"bytes,3,opt,name=consumer,proto3" json:"consumer,omitempty"`
	// Service account which has read permission on the stream.
	ServiceAccountId string `protobuf:"bytes,4,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DataStream) Descriptor deprecated 

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

Deprecated: Use DataStream.ProtoReflect.Descriptor instead.

func (*DataStream) GetConsumer 

func (x *DataStream) GetConsumer() string

func (*DataStream) GetDatabase 

func (x *DataStream) GetDatabase() string

func (*DataStream) GetServiceAccountId 

func (x *DataStream) GetServiceAccountId() string

func (*DataStream) GetStreamName 

func (x *DataStream) GetStreamName() string

func (*DataStream) ProtoMessage 

func (*DataStream) ProtoMessage()

func (*DataStream) ProtoReflect 

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

func (*DataStream) Reset 

func (x *DataStream) Reset()

func (*DataStream) SetConsumer 

func (m *DataStream) SetConsumer(v string)

func (*DataStream) SetDatabase 

func (m *DataStream) SetDatabase(v string)

func (*DataStream) SetServiceAccountId 

func (m *DataStream) SetServiceAccountId(v string)

func (*DataStream) SetStreamName 

func (m *DataStream) SetStreamName(v string)

func (*DataStream) String 

func (x *DataStream) String() string

type DeleteBusMetadata 

type DeleteBusMetadata struct {

	// ID of the bus that is being deleted.
	BusId string `protobuf:"bytes,1,opt,name=bus_id,json=busId,proto3" json:"bus_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteBusMetadata) Descriptor deprecated 

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

Deprecated: Use DeleteBusMetadata.ProtoReflect.Descriptor instead.

func (*DeleteBusMetadata) GetBusId 

func (x *DeleteBusMetadata) GetBusId() string

func (*DeleteBusMetadata) ProtoMessage 

func (*DeleteBusMetadata) ProtoMessage()

func (*DeleteBusMetadata) ProtoReflect 

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

func (*DeleteBusMetadata) Reset 

func (x *DeleteBusMetadata) Reset()

func (*DeleteBusMetadata) SetBusId 

func (m *DeleteBusMetadata) SetBusId(v string)

func (*DeleteBusMetadata) String 

func (x *DeleteBusMetadata) String() string

type DeleteBusRequest 

type DeleteBusRequest struct {

	// ID of the bus to delete.
	BusId string `protobuf:"bytes,1,opt,name=bus_id,json=busId,proto3" json:"bus_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteBusRequest) Descriptor deprecated 

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

Deprecated: Use DeleteBusRequest.ProtoReflect.Descriptor instead.

func (*DeleteBusRequest) GetBusId 

func (x *DeleteBusRequest) GetBusId() string

func (*DeleteBusRequest) ProtoMessage 

func (*DeleteBusRequest) ProtoMessage()

func (*DeleteBusRequest) ProtoReflect 

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

func (*DeleteBusRequest) Reset 

func (x *DeleteBusRequest) Reset()

func (*DeleteBusRequest) SetBusId 

func (m *DeleteBusRequest) SetBusId(v string)

func (*DeleteBusRequest) String 

func (x *DeleteBusRequest) String() string

type DeleteConnectorMetadata 

type DeleteConnectorMetadata struct {

	// ID of the connector that is being deleted.
	ConnectorId string `protobuf:"bytes,1,opt,name=connector_id,json=connectorId,proto3" json:"connector_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteConnectorMetadata) Descriptor deprecated 

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

Deprecated: Use DeleteConnectorMetadata.ProtoReflect.Descriptor instead.

func (*DeleteConnectorMetadata) GetConnectorId 

func (x *DeleteConnectorMetadata) GetConnectorId() string

func (*DeleteConnectorMetadata) ProtoMessage 

func (*DeleteConnectorMetadata) ProtoMessage()

func (*DeleteConnectorMetadata) ProtoReflect 

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

func (*DeleteConnectorMetadata) Reset 

func (x *DeleteConnectorMetadata) Reset()

func (*DeleteConnectorMetadata) SetConnectorId 

func (m *DeleteConnectorMetadata) SetConnectorId(v string)

func (*DeleteConnectorMetadata) String 

func (x *DeleteConnectorMetadata) String() string

type DeleteConnectorRequest 

type DeleteConnectorRequest struct {

	// ID of the connector to delete.
	ConnectorId string `protobuf:"bytes,1,opt,name=connector_id,json=connectorId,proto3" json:"connector_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteConnectorRequest) Descriptor deprecated 

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

Deprecated: Use DeleteConnectorRequest.ProtoReflect.Descriptor instead.

func (*DeleteConnectorRequest) GetConnectorId 

func (x *DeleteConnectorRequest) GetConnectorId() string

func (*DeleteConnectorRequest) ProtoMessage 

func (*DeleteConnectorRequest) ProtoMessage()

func (*DeleteConnectorRequest) ProtoReflect 

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

func (*DeleteConnectorRequest) Reset 

func (x *DeleteConnectorRequest) Reset()

func (*DeleteConnectorRequest) SetConnectorId 

func (m *DeleteConnectorRequest) SetConnectorId(v string)

func (*DeleteConnectorRequest) String 

func (x *DeleteConnectorRequest) String() string

type DeleteRuleMetadata 

type DeleteRuleMetadata struct {

	// ID of the rule that is being deleted.
	RuleId string `protobuf:"bytes,1,opt,name=rule_id,json=ruleId,proto3" json:"rule_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRuleMetadata) Descriptor deprecated 

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

Deprecated: Use DeleteRuleMetadata.ProtoReflect.Descriptor instead.

func (*DeleteRuleMetadata) GetRuleId 

func (x *DeleteRuleMetadata) GetRuleId() string

func (*DeleteRuleMetadata) ProtoMessage 

func (*DeleteRuleMetadata) ProtoMessage()

func (*DeleteRuleMetadata) ProtoReflect 

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

func (*DeleteRuleMetadata) Reset 

func (x *DeleteRuleMetadata) Reset()

func (*DeleteRuleMetadata) SetRuleId 

func (m *DeleteRuleMetadata) SetRuleId(v string)

func (*DeleteRuleMetadata) String 

func (x *DeleteRuleMetadata) String() string

type DeleteRuleRequest 

type DeleteRuleRequest struct {

	// ID of the rule to delete.
	RuleId string `protobuf:"bytes,1,opt,name=rule_id,json=ruleId,proto3" json:"rule_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRuleRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRuleRequest.ProtoReflect.Descriptor instead.

func (*DeleteRuleRequest) GetRuleId 

func (x *DeleteRuleRequest) GetRuleId() string

func (*DeleteRuleRequest) ProtoMessage 

func (*DeleteRuleRequest) ProtoMessage()

func (*DeleteRuleRequest) ProtoReflect 

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

func (*DeleteRuleRequest) Reset 

func (x *DeleteRuleRequest) Reset()

func (*DeleteRuleRequest) SetRuleId 

func (m *DeleteRuleRequest) SetRuleId(v string)

func (*DeleteRuleRequest) String 

func (x *DeleteRuleRequest) String() string

type DisableRuleMetadata 

type DisableRuleMetadata struct {

	// ID of the rule that is being disabled.
	RuleId string `protobuf:"bytes,1,opt,name=rule_id,json=ruleId,proto3" json:"rule_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DisableRuleMetadata) Descriptor deprecated 

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

Deprecated: Use DisableRuleMetadata.ProtoReflect.Descriptor instead.

func (*DisableRuleMetadata) GetRuleId 

func (x *DisableRuleMetadata) GetRuleId() string

func (*DisableRuleMetadata) ProtoMessage 

func (*DisableRuleMetadata) ProtoMessage()

func (*DisableRuleMetadata) ProtoReflect 

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

func (*DisableRuleMetadata) Reset 

func (x *DisableRuleMetadata) Reset()

func (*DisableRuleMetadata) SetRuleId 

func (m *DisableRuleMetadata) SetRuleId(v string)

func (*DisableRuleMetadata) String 

func (x *DisableRuleMetadata) String() string

type DisableRuleRequest 

type DisableRuleRequest struct {

	// ID of the rule to disable.
	RuleId string `protobuf:"bytes,1,opt,name=rule_id,json=ruleId,proto3" json:"rule_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DisableRuleRequest) Descriptor deprecated 

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

Deprecated: Use DisableRuleRequest.ProtoReflect.Descriptor instead.

func (*DisableRuleRequest) GetRuleId 

func (x *DisableRuleRequest) GetRuleId() string

func (*DisableRuleRequest) ProtoMessage 

func (*DisableRuleRequest) ProtoMessage()

func (*DisableRuleRequest) ProtoReflect 

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

func (*DisableRuleRequest) Reset 

func (x *DisableRuleRequest) Reset()

func (*DisableRuleRequest) SetRuleId 

func (m *DisableRuleRequest) SetRuleId(v string)

func (*DisableRuleRequest) String 

func (x *DisableRuleRequest) String() string

type EnableRuleMetadata 

type EnableRuleMetadata struct {

	// ID of the rule that is being enabled.
	RuleId string `protobuf:"bytes,1,opt,name=rule_id,json=ruleId,proto3" json:"rule_id,omitempty"`
	// contains filtered or unexported fields
}

func (*EnableRuleMetadata) Descriptor deprecated 

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

Deprecated: Use EnableRuleMetadata.ProtoReflect.Descriptor instead.

func (*EnableRuleMetadata) GetRuleId 

func (x *EnableRuleMetadata) GetRuleId() string

func (*EnableRuleMetadata) ProtoMessage 

func (*EnableRuleMetadata) ProtoMessage()

func (*EnableRuleMetadata) ProtoReflect 

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

func (*EnableRuleMetadata) Reset 

func (x *EnableRuleMetadata) Reset()

func (*EnableRuleMetadata) SetRuleId 

func (m *EnableRuleMetadata) SetRuleId(v string)

func (*EnableRuleMetadata) String 

func (x *EnableRuleMetadata) String() string

type EnableRuleRequest 

type EnableRuleRequest struct {

	// ID of the rule to enable.
	RuleId string `protobuf:"bytes,1,opt,name=rule_id,json=ruleId,proto3" json:"rule_id,omitempty"`
	// contains filtered or unexported fields
}

func (*EnableRuleRequest) Descriptor deprecated 

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

Deprecated: Use EnableRuleRequest.ProtoReflect.Descriptor instead.

func (*EnableRuleRequest) GetRuleId 

func (x *EnableRuleRequest) GetRuleId() string

func (*EnableRuleRequest) ProtoMessage 

func (*EnableRuleRequest) ProtoMessage()

func (*EnableRuleRequest) ProtoReflect 

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

func (*EnableRuleRequest) Reset 

func (x *EnableRuleRequest) Reset()

func (*EnableRuleRequest) SetRuleId 

func (m *EnableRuleRequest) SetRuleId(v string)

func (*EnableRuleRequest) String 

func (x *EnableRuleRequest) String() string

type EventServiceClient 

type EventServiceClient interface {
	// Puts event to bus.
	Put(ctx context.Context, in *PutEventRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

EventServiceClient is the client API for EventService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

Service for put events to bus for serverless eventrouter.

func NewEventServiceClient 

func NewEventServiceClient(cc grpc.ClientConnInterface) EventServiceClient

type EventServiceServer 

type EventServiceServer interface {
	// Puts event to bus.
	Put(context.Context, *PutEventRequest) (*emptypb.Empty, error)
}

EventServiceServer is the server API for EventService service. All implementations should embed UnimplementedEventServiceServer for forward compatibility.

Service for put events to bus for serverless eventrouter.

type Filter 

type Filter struct {

	// Types that are assignable to Condition:
	//
	//	*Filter_JqFilter
	Condition isFilter_Condition `protobuf_oneof:"condition"`
	// contains filtered or unexported fields
}

func (*Filter) Descriptor deprecated 

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

Deprecated: Use Filter.ProtoReflect.Descriptor instead.

func (*Filter) GetCondition 

func (m *Filter) GetCondition() isFilter_Condition

func (*Filter) GetJqFilter 

func (x *Filter) GetJqFilter() string

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) ProtoReflect 

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

func (*Filter) Reset 

func (x *Filter) Reset()

func (*Filter) SetCondition 

func (m *Filter) SetCondition(v Filter_Condition)

func (*Filter) SetJqFilter 

func (m *Filter) SetJqFilter(v string)

func (*Filter) String 

func (x *Filter) String() string

type Filter_Condition 

type Filter_Condition = isFilter_Condition

type Filter_JqFilter 

type Filter_JqFilter struct {
	// JQ filter for matching events.
	JqFilter string `protobuf:"bytes,1,opt,name=jq_filter,json=jqFilter,proto3,oneof"`
}

type FunctionTarget 

type FunctionTarget struct {

	// Function ID.
	FunctionId string `protobuf:"bytes,1,opt,name=function_id,json=functionId,proto3" json:"function_id,omitempty"`
	// Function tag, optional.
	FunctionTag string `protobuf:"bytes,2,opt,name=function_tag,json=functionTag,proto3" json:"function_tag,omitempty"`
	// Service account which has call permission on the function, optional.
	ServiceAccountId string `protobuf:"bytes,3,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"`
	// Batch settings.
	BatchSettings *BatchSettings `protobuf:"bytes,4,opt,name=batch_settings,json=batchSettings,proto3" json:"batch_settings,omitempty"`
	// contains filtered or unexported fields
}

func (*FunctionTarget) Descriptor deprecated 

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

Deprecated: Use FunctionTarget.ProtoReflect.Descriptor instead.

func (*FunctionTarget) GetBatchSettings 

func (x *FunctionTarget) GetBatchSettings() *BatchSettings

func (*FunctionTarget) GetFunctionId 

func (x *FunctionTarget) GetFunctionId() string

func (*FunctionTarget) GetFunctionTag 

func (x *FunctionTarget) GetFunctionTag() string

func (*FunctionTarget) GetServiceAccountId 

func (x *FunctionTarget) GetServiceAccountId() string

func (*FunctionTarget) ProtoMessage 

func (*FunctionTarget) ProtoMessage()

func (*FunctionTarget) ProtoReflect 

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

func (*FunctionTarget) Reset 

func (x *FunctionTarget) Reset()

func (*FunctionTarget) SetBatchSettings 

func (m *FunctionTarget) SetBatchSettings(v *BatchSettings)

func (*FunctionTarget) SetFunctionId 

func (m *FunctionTarget) SetFunctionId(v string)

func (*FunctionTarget) SetFunctionTag 

func (m *FunctionTarget) SetFunctionTag(v string)

func (*FunctionTarget) SetServiceAccountId 

func (m *FunctionTarget) SetServiceAccountId(v string)

func (*FunctionTarget) String 

func (x *FunctionTarget) String() string

type GatewayWebsocketBroadcastTarget 

type GatewayWebsocketBroadcastTarget struct {

	// Gateway ID.
	GatewayId string `protobuf:"bytes,1,opt,name=gateway_id,json=gatewayId,proto3" json:"gateway_id,omitempty"`
	// Path.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Service account which has permission for writing to websockets.
	ServiceAccountId string `protobuf:"bytes,3,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"`
	// Batch settings.
	BatchSettings *BatchSettings `protobuf:"bytes,4,opt,name=batch_settings,json=batchSettings,proto3" json:"batch_settings,omitempty"`
	// contains filtered or unexported fields
}

func (*GatewayWebsocketBroadcastTarget) Descriptor deprecated 

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

Deprecated: Use GatewayWebsocketBroadcastTarget.ProtoReflect.Descriptor instead.

func (*GatewayWebsocketBroadcastTarget) GetBatchSettings 

func (x *GatewayWebsocketBroadcastTarget) GetBatchSettings() *BatchSettings

func (*GatewayWebsocketBroadcastTarget) GetGatewayId 

func (x *GatewayWebsocketBroadcastTarget) GetGatewayId() string

func (*GatewayWebsocketBroadcastTarget) GetPath 

func (x *GatewayWebsocketBroadcastTarget) GetPath() string

func (*GatewayWebsocketBroadcastTarget) GetServiceAccountId 

func (x *GatewayWebsocketBroadcastTarget) GetServiceAccountId() string

func (*GatewayWebsocketBroadcastTarget) ProtoMessage 

func (*GatewayWebsocketBroadcastTarget) ProtoMessage()

func (*GatewayWebsocketBroadcastTarget) ProtoReflect 

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

func (*GatewayWebsocketBroadcastTarget) Reset 

func (x *GatewayWebsocketBroadcastTarget) Reset()

func (*GatewayWebsocketBroadcastTarget) SetBatchSettings 

func (m *GatewayWebsocketBroadcastTarget) SetBatchSettings(v *BatchSettings)

func (*GatewayWebsocketBroadcastTarget) SetGatewayId 

func (m *GatewayWebsocketBroadcastTarget) SetGatewayId(v string)

func (*GatewayWebsocketBroadcastTarget) SetPath 

func (m *GatewayWebsocketBroadcastTarget) SetPath(v string)

func (*GatewayWebsocketBroadcastTarget) SetServiceAccountId 

func (m *GatewayWebsocketBroadcastTarget) SetServiceAccountId(v string)

func (*GatewayWebsocketBroadcastTarget) String 

func (x *GatewayWebsocketBroadcastTarget) String() string

type GetBusRequest 

type GetBusRequest struct {

	// ID of the bus to get.
	BusId string `protobuf:"bytes,1,opt,name=bus_id,json=busId,proto3" json:"bus_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBusRequest) Descriptor deprecated 

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

Deprecated: Use GetBusRequest.ProtoReflect.Descriptor instead.

func (*GetBusRequest) GetBusId 

func (x *GetBusRequest) GetBusId() string

func (*GetBusRequest) ProtoMessage 

func (*GetBusRequest) ProtoMessage()

func (*GetBusRequest) ProtoReflect 

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

func (*GetBusRequest) Reset 

func (x *GetBusRequest) Reset()

func (*GetBusRequest) SetBusId 

func (m *GetBusRequest) SetBusId(v string)

func (*GetBusRequest) String 

func (x *GetBusRequest) String() string

type GetConnectorRequest 

type GetConnectorRequest struct {

	// ID of the connector to return.
	ConnectorId string `protobuf:"bytes,1,opt,name=connector_id,json=connectorId,proto3" json:"connector_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConnectorRequest) Descriptor deprecated 

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

Deprecated: Use GetConnectorRequest.ProtoReflect.Descriptor instead.

func (*GetConnectorRequest) GetConnectorId 

func (x *GetConnectorRequest) GetConnectorId() string

func (*GetConnectorRequest) ProtoMessage 

func (*GetConnectorRequest) ProtoMessage()

func (*GetConnectorRequest) ProtoReflect 

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

func (*GetConnectorRequest) Reset 

func (x *GetConnectorRequest) Reset()

func (*GetConnectorRequest) SetConnectorId 

func (m *GetConnectorRequest) SetConnectorId(v string)

func (*GetConnectorRequest) String 

func (x *GetConnectorRequest) String() string

type GetRuleRequest 

type GetRuleRequest struct {

	// ID of the rule to return.
	RuleId string `protobuf:"bytes,1,opt,name=rule_id,json=ruleId,proto3" json:"rule_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRuleRequest) Descriptor deprecated 

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

Deprecated: Use GetRuleRequest.ProtoReflect.Descriptor instead.

func (*GetRuleRequest) GetRuleId 

func (x *GetRuleRequest) GetRuleId() string

func (*GetRuleRequest) ProtoMessage 

func (*GetRuleRequest) ProtoMessage()

func (*GetRuleRequest) ProtoReflect 

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

func (*GetRuleRequest) Reset 

func (x *GetRuleRequest) Reset()

func (*GetRuleRequest) SetRuleId 

func (m *GetRuleRequest) SetRuleId(v string)

func (*GetRuleRequest) String 

func (x *GetRuleRequest) String() string

type ListBusOperationsRequest 

type ListBusOperationsRequest struct {

	// ID of the bus to list operations for.
	BusId string `protobuf:"bytes,1,opt,name=bus_id,json=busId,proto3" json:"bus_id,omitempty"`
	// Maximum number of operations to return.
	PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token. To get the next page of results, set `page_token` to the
	// [ListBusesResponse.next_page_token] returned by a previous list request.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Supported attributes for filter:
	//
	//	description
	//	created_at
	//	modified_at
	//	created_by
	//	done
	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBusOperationsRequest) Descriptor deprecated 

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

Deprecated: Use ListBusOperationsRequest.ProtoReflect.Descriptor instead.

func (*ListBusOperationsRequest) GetBusId 

func (x *ListBusOperationsRequest) GetBusId() string

func (*ListBusOperationsRequest) GetFilter 

func (x *ListBusOperationsRequest) GetFilter() string

func (*ListBusOperationsRequest) GetPageSize 

func (x *ListBusOperationsRequest) GetPageSize() int64

func (*ListBusOperationsRequest) GetPageToken 

func (x *ListBusOperationsRequest) GetPageToken() string

func (*ListBusOperationsRequest) ProtoMessage 

func (*ListBusOperationsRequest) ProtoMessage()

func (*ListBusOperationsRequest) ProtoReflect 

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

func (*ListBusOperationsRequest) Reset 

func (x *ListBusOperationsRequest) Reset()

func (*ListBusOperationsRequest) SetBusId 

func (m *ListBusOperationsRequest) SetBusId(v string)

func (*ListBusOperationsRequest) SetFilter 

func (m *ListBusOperationsRequest) SetFilter(v string)

func (*ListBusOperationsRequest) SetPageSize 

func (m *ListBusOperationsRequest) SetPageSize(v int64)

func (*ListBusOperationsRequest) SetPageToken 

func (m *ListBusOperationsRequest) SetPageToken(v string)

func (*ListBusOperationsRequest) String 

func (x *ListBusOperationsRequest) String() string

type ListBusOperationsResponse 

type ListBusOperationsResponse struct {

	// List of operations for the specified bus.
	Operations []*operation.Operation `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"`
	// Token for getting the next page of the list of operations.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBusOperationsResponse) Descriptor deprecated 

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

Deprecated: Use ListBusOperationsResponse.ProtoReflect.Descriptor instead.

func (*ListBusOperationsResponse) GetNextPageToken 

func (x *ListBusOperationsResponse) GetNextPageToken() string

func (*ListBusOperationsResponse) GetOperations 

func (x *ListBusOperationsResponse) GetOperations() []*operation.Operation

func (*ListBusOperationsResponse) ProtoMessage 

func (*ListBusOperationsResponse) ProtoMessage()

func (*ListBusOperationsResponse) ProtoReflect 

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

func (*ListBusOperationsResponse) Reset 

func (x *ListBusOperationsResponse) Reset()

func (*ListBusOperationsResponse) SetNextPageToken 

func (m *ListBusOperationsResponse) SetNextPageToken(v string)

func (*ListBusOperationsResponse) SetOperations 

func (m *ListBusOperationsResponse) SetOperations(v []*operation.Operation)

func (*ListBusOperationsResponse) String 

func (x *ListBusOperationsResponse) String() string

type ListBusesRequest 

type ListBusesRequest struct {

	// ID of the folder to list buses in.
	FolderId string `protobuf:"bytes,1,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	// Maximum number of buses to return.
	PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token. To get the next page of results, set `page_token` to the
	// [ListBusesResponse.next_page_token] returned by a previous list request.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Supported fields for filter:
	//
	//	name
	//	created_at
	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBusesRequest) Descriptor deprecated 

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

Deprecated: Use ListBusesRequest.ProtoReflect.Descriptor instead.

func (*ListBusesRequest) GetFilter 

func (x *ListBusesRequest) GetFilter() string

func (*ListBusesRequest) GetFolderId 

func (x *ListBusesRequest) GetFolderId() string

func (*ListBusesRequest) GetPageSize 

func (x *ListBusesRequest) GetPageSize() int64

func (*ListBusesRequest) GetPageToken 

func (x *ListBusesRequest) GetPageToken() string

func (*ListBusesRequest) ProtoMessage 

func (*ListBusesRequest) ProtoMessage()

func (*ListBusesRequest) ProtoReflect 

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

func (*ListBusesRequest) Reset 

func (x *ListBusesRequest) Reset()

func (*ListBusesRequest) SetFilter 

func (m *ListBusesRequest) SetFilter(v string)

func (*ListBusesRequest) SetFolderId 

func (m *ListBusesRequest) SetFolderId(v string)

func (*ListBusesRequest) SetPageSize 

func (m *ListBusesRequest) SetPageSize(v int64)

func (*ListBusesRequest) SetPageToken 

func (m *ListBusesRequest) SetPageToken(v string)

func (*ListBusesRequest) String 

func (x *ListBusesRequest) String() string

type ListBusesResponse 

type ListBusesResponse struct {

	// List of buses.
	Buses []*Bus `protobuf:"bytes,1,rep,name=buses,proto3" json:"buses,omitempty"`
	// Token for getting the next page of the list of buses.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBusesResponse) Descriptor deprecated 

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

Deprecated: Use ListBusesResponse.ProtoReflect.Descriptor instead.

func (*ListBusesResponse) GetBuses 

func (x *ListBusesResponse) GetBuses() []*Bus

func (*ListBusesResponse) GetNextPageToken 

func (x *ListBusesResponse) GetNextPageToken() string

func (*ListBusesResponse) ProtoMessage 

func (*ListBusesResponse) ProtoMessage()

func (*ListBusesResponse) ProtoReflect 

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

func (*ListBusesResponse) Reset 

func (x *ListBusesResponse) Reset()

func (*ListBusesResponse) SetBuses 

func (m *ListBusesResponse) SetBuses(v []*Bus)

func (*ListBusesResponse) SetNextPageToken 

func (m *ListBusesResponse) SetNextPageToken(v string)

func (*ListBusesResponse) String 

func (x *ListBusesResponse) String() string

type ListConnectorOperationsRequest 

type ListConnectorOperationsRequest struct {

	// ID of the connector to list operations for.
	ConnectorId string `protobuf:"bytes,1,opt,name=connector_id,json=connectorId,proto3" json:"connector_id,omitempty"`
	// The maximum number of results per response.
	PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token. To get the next page of results, set `page_token` to the
	// `next_page_token` returned by a previous list request.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Supported attributes for filter:
	//
	//	description
	//	created_at
	//	modified_at
	//	created_by
	//	done
	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListConnectorOperationsRequest) Descriptor deprecated 

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

Deprecated: Use ListConnectorOperationsRequest.ProtoReflect.Descriptor instead.

func (*ListConnectorOperationsRequest) GetConnectorId 

func (x *ListConnectorOperationsRequest) GetConnectorId() string

func (*ListConnectorOperationsRequest) GetFilter 

func (x *ListConnectorOperationsRequest) GetFilter() string

func (*ListConnectorOperationsRequest) GetPageSize 

func (x *ListConnectorOperationsRequest) GetPageSize() int64

func (*ListConnectorOperationsRequest) GetPageToken 

func (x *ListConnectorOperationsRequest) GetPageToken() string

func (*ListConnectorOperationsRequest) ProtoMessage 

func (*ListConnectorOperationsRequest) ProtoMessage()

func (*ListConnectorOperationsRequest) ProtoReflect 

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

func (*ListConnectorOperationsRequest) Reset 

func (x *ListConnectorOperationsRequest) Reset()

func (*ListConnectorOperationsRequest) SetConnectorId 

func (m *ListConnectorOperationsRequest) SetConnectorId(v string)

func (*ListConnectorOperationsRequest) SetFilter 

func (m *ListConnectorOperationsRequest) SetFilter(v string)

func (*ListConnectorOperationsRequest) SetPageSize 

func (m *ListConnectorOperationsRequest) SetPageSize(v int64)

func (*ListConnectorOperationsRequest) SetPageToken 

func (m *ListConnectorOperationsRequest) SetPageToken(v string)

func (*ListConnectorOperationsRequest) String 

func (x *ListConnectorOperationsRequest) String() string

type ListConnectorOperationsResponse 

type ListConnectorOperationsResponse struct {

	// List of operations for the specified connector.
	Operations []*operation.Operation `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"`
	// Token for getting the next page of the list of results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListConnectorOperationsResponse) Descriptor deprecated 

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

Deprecated: Use ListConnectorOperationsResponse.ProtoReflect.Descriptor instead.

func (*ListConnectorOperationsResponse) GetNextPageToken 

func (x *ListConnectorOperationsResponse) GetNextPageToken() string

func (*ListConnectorOperationsResponse) GetOperations 

func (x *ListConnectorOperationsResponse) GetOperations() []*operation.Operation

func (*ListConnectorOperationsResponse) ProtoMessage 

func (*ListConnectorOperationsResponse) ProtoMessage()

func (*ListConnectorOperationsResponse) ProtoReflect 

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

func (*ListConnectorOperationsResponse) Reset 

func (x *ListConnectorOperationsResponse) Reset()

func (*ListConnectorOperationsResponse) SetNextPageToken 

func (m *ListConnectorOperationsResponse) SetNextPageToken(v string)

func (*ListConnectorOperationsResponse) SetOperations 

func (m *ListConnectorOperationsResponse) SetOperations(v []*operation.Operation)

func (*ListConnectorOperationsResponse) String 

func (x *ListConnectorOperationsResponse) String() string

type ListConnectorsRequest 

type ListConnectorsRequest struct {

	// ID of the folder or bus to list connectors in.
	//
	// Types that are assignable to ContainerId:
	//
	//	*ListConnectorsRequest_BusId
	//	*ListConnectorsRequest_FolderId
	ContainerId isListConnectorsRequest_ContainerId `protobuf_oneof:"container_id"`
	// The maximum number of results per response.
	PageSize int64 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token. To get the next page of results, set `page_token` to the
	// `next_page_token` returned by a previous list request.
	PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Supported fields for filter:
	//
	//	name
	//	created_at
	Filter string `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListConnectorsRequest) Descriptor deprecated 

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

Deprecated: Use ListConnectorsRequest.ProtoReflect.Descriptor instead.

func (*ListConnectorsRequest) GetBusId 

func (x *ListConnectorsRequest) GetBusId() string

func (*ListConnectorsRequest) GetContainerId 

func (m *ListConnectorsRequest) GetContainerId() isListConnectorsRequest_ContainerId

func (*ListConnectorsRequest) GetFilter 

func (x *ListConnectorsRequest) GetFilter() string

func (*ListConnectorsRequest) GetFolderId 

func (x *ListConnectorsRequest) GetFolderId() string

func (*ListConnectorsRequest) GetPageSize 

func (x *ListConnectorsRequest) GetPageSize() int64

func (*ListConnectorsRequest) GetPageToken 

func (x *ListConnectorsRequest) GetPageToken() string

func (*ListConnectorsRequest) ProtoMessage 

func (*ListConnectorsRequest) ProtoMessage()

func (*ListConnectorsRequest) ProtoReflect 

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

func (*ListConnectorsRequest) Reset 

func (x *ListConnectorsRequest) Reset()

func (*ListConnectorsRequest) SetBusId 

func (m *ListConnectorsRequest) SetBusId(v string)

func (*ListConnectorsRequest) SetContainerId 

func (m *ListConnectorsRequest) SetContainerId(v ListConnectorsRequest_ContainerId)

func (*ListConnectorsRequest) SetFilter 

func (m *ListConnectorsRequest) SetFilter(v string)

func (*ListConnectorsRequest) SetFolderId 

func (m *ListConnectorsRequest) SetFolderId(v string)

func (*ListConnectorsRequest) SetPageSize 

func (m *ListConnectorsRequest) SetPageSize(v int64)

func (*ListConnectorsRequest) SetPageToken 

func (m *ListConnectorsRequest) SetPageToken(v string)

func (*ListConnectorsRequest) String 

func (x *ListConnectorsRequest) String() string

type ListConnectorsRequest_BusId 

type ListConnectorsRequest_BusId struct {
	// ID of the bus to list connectors in.
	BusId string `protobuf:"bytes,1,opt,name=bus_id,json=busId,proto3,oneof"`
}

type ListConnectorsRequest_ContainerId 

type ListConnectorsRequest_ContainerId = isListConnectorsRequest_ContainerId

type ListConnectorsRequest_FolderId 

type ListConnectorsRequest_FolderId struct {
	// ID of the folder to list connectors in.
	FolderId string `protobuf:"bytes,2,opt,name=folder_id,json=folderId,proto3,oneof"`
}

type ListConnectorsResponse 

type ListConnectorsResponse struct {

	// List of connectors.
	Connectors []*Connector `protobuf:"bytes,1,rep,name=connectors,proto3" json:"connectors,omitempty"`
	// Token for getting the next page of the list of results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListConnectorsResponse) Descriptor deprecated 

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

Deprecated: Use ListConnectorsResponse.ProtoReflect.Descriptor instead.

func (*ListConnectorsResponse) GetConnectors 

func (x *ListConnectorsResponse) GetConnectors() []*Connector

func (*ListConnectorsResponse) GetNextPageToken 

func (x *ListConnectorsResponse) GetNextPageToken() string

func (*ListConnectorsResponse) ProtoMessage 

func (*ListConnectorsResponse) ProtoMessage()

func (*ListConnectorsResponse) ProtoReflect 

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

func (*ListConnectorsResponse) Reset 

func (x *ListConnectorsResponse) Reset()

func (*ListConnectorsResponse) SetConnectors 

func (m *ListConnectorsResponse) SetConnectors(v []*Connector)

func (*ListConnectorsResponse) SetNextPageToken 

func (m *ListConnectorsResponse) SetNextPageToken(v string)

func (*ListConnectorsResponse) String 

func (x *ListConnectorsResponse) String() string

type ListRuleOperationsRequest 

type ListRuleOperationsRequest struct {

	// ID of the rule to list operations for.
	RuleId string `protobuf:"bytes,1,opt,name=rule_id,json=ruleId,proto3" json:"rule_id,omitempty"`
	// The maximum number of results per response.
	PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token. To get the next page of results, set `page_token` to the
	// `next_page_token` returned by a previous list request.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Supported attributes for filter:
	//
	//	description
	//	created_at
	//	modified_at
	//	created_by
	//	done
	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRuleOperationsRequest) Descriptor deprecated 

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

Deprecated: Use ListRuleOperationsRequest.ProtoReflect.Descriptor instead.

func (*ListRuleOperationsRequest) GetFilter 

func (x *ListRuleOperationsRequest) GetFilter() string

func (*ListRuleOperationsRequest) GetPageSize 

func (x *ListRuleOperationsRequest) GetPageSize() int64

func (*ListRuleOperationsRequest) GetPageToken 

func (x *ListRuleOperationsRequest) GetPageToken() string

func (*ListRuleOperationsRequest) GetRuleId 

func (x *ListRuleOperationsRequest) GetRuleId() string

func (*ListRuleOperationsRequest) ProtoMessage 

func (*ListRuleOperationsRequest) ProtoMessage()

func (*ListRuleOperationsRequest) ProtoReflect 

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

func (*ListRuleOperationsRequest) Reset 

func (x *ListRuleOperationsRequest) Reset()

func (*ListRuleOperationsRequest) SetFilter 

func (m *ListRuleOperationsRequest) SetFilter(v string)

func (*ListRuleOperationsRequest) SetPageSize 

func (m *ListRuleOperationsRequest) SetPageSize(v int64)

func (*ListRuleOperationsRequest) SetPageToken 

func (m *ListRuleOperationsRequest) SetPageToken(v string)

func (*ListRuleOperationsRequest) SetRuleId 

func (m *ListRuleOperationsRequest) SetRuleId(v string)

func (*ListRuleOperationsRequest) String 

func (x *ListRuleOperationsRequest) String() string

type ListRuleOperationsResponse 

type ListRuleOperationsResponse struct {

	// List of operations for the specified rule.
	Operations []*operation.Operation `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"`
	// Token for getting the next page of the list of operations.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRuleOperationsResponse) Descriptor deprecated 

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

Deprecated: Use ListRuleOperationsResponse.ProtoReflect.Descriptor instead.

func (*ListRuleOperationsResponse) GetNextPageToken 

func (x *ListRuleOperationsResponse) GetNextPageToken() string

func (*ListRuleOperationsResponse) GetOperations 

func (x *ListRuleOperationsResponse) GetOperations() []*operation.Operation

func (*ListRuleOperationsResponse) ProtoMessage 

func (*ListRuleOperationsResponse) ProtoMessage()

func (*ListRuleOperationsResponse) ProtoReflect 

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

func (*ListRuleOperationsResponse) Reset 

func (x *ListRuleOperationsResponse) Reset()

func (*ListRuleOperationsResponse) SetNextPageToken 

func (m *ListRuleOperationsResponse) SetNextPageToken(v string)

func (*ListRuleOperationsResponse) SetOperations 

func (m *ListRuleOperationsResponse) SetOperations(v []*operation.Operation)

func (*ListRuleOperationsResponse) String 

func (x *ListRuleOperationsResponse) String() string

type ListRulesRequest 

type ListRulesRequest struct {

	// ID of the folder on bus to list rules in.
	//
	// Types that are assignable to ContainerId:
	//
	//	*ListRulesRequest_BusId
	//	*ListRulesRequest_FolderId
	ContainerId isListRulesRequest_ContainerId `protobuf_oneof:"container_id"`
	// The maximum number of results per response.
	PageSize int64 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token. To get the next page of results, set `page_token` to the
	// `next_page_token` returned by a previous list request.
	PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Supported fields for filter:
	//
	//	name
	//	created_at
	Filter string `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRulesRequest) Descriptor deprecated 

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

Deprecated: Use ListRulesRequest.ProtoReflect.Descriptor instead.

func (*ListRulesRequest) GetBusId 

func (x *ListRulesRequest) GetBusId() string

func (*ListRulesRequest) GetContainerId 

func (m *ListRulesRequest) GetContainerId() isListRulesRequest_ContainerId

func (*ListRulesRequest) GetFilter 

func (x *ListRulesRequest) GetFilter() string

func (*ListRulesRequest) GetFolderId 

func (x *ListRulesRequest) GetFolderId() string

func (*ListRulesRequest) GetPageSize 

func (x *ListRulesRequest) GetPageSize() int64

func (*ListRulesRequest) GetPageToken 

func (x *ListRulesRequest) GetPageToken() string

func (*ListRulesRequest) ProtoMessage 

func (*ListRulesRequest) ProtoMessage()

func (*ListRulesRequest) ProtoReflect 

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

func (*ListRulesRequest) Reset 

func (x *ListRulesRequest) Reset()

func (*ListRulesRequest) SetBusId 

func (m *ListRulesRequest) SetBusId(v string)

func (*ListRulesRequest) SetContainerId 

func (m *ListRulesRequest) SetContainerId(v ListRulesRequest_ContainerId)

func (*ListRulesRequest) SetFilter 

func (m *ListRulesRequest) SetFilter(v string)

func (*ListRulesRequest) SetFolderId 

func (m *ListRulesRequest) SetFolderId(v string)

func (*ListRulesRequest) SetPageSize 

func (m *ListRulesRequest) SetPageSize(v int64)

func (*ListRulesRequest) SetPageToken 

func (m *ListRulesRequest) SetPageToken(v string)

func (*ListRulesRequest) String 

func (x *ListRulesRequest) String() string

type ListRulesRequest_BusId 

type ListRulesRequest_BusId struct {
	// ID of the bus to list rules in.
	BusId string `protobuf:"bytes,1,opt,name=bus_id,json=busId,proto3,oneof"`
}

type ListRulesRequest_ContainerId 

type ListRulesRequest_ContainerId = isListRulesRequest_ContainerId

type ListRulesRequest_FolderId 

type ListRulesRequest_FolderId struct {
	// ID of the folder to list rules in.
	FolderId string `protobuf:"bytes,2,opt,name=folder_id,json=folderId,proto3,oneof"`
}

type ListRulesResponse 

type ListRulesResponse struct {

	// List of rules.
	Rules []*Rule `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"`
	// Token for getting the next page of the list of rules.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRulesResponse) Descriptor deprecated 

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

Deprecated: Use ListRulesResponse.ProtoReflect.Descriptor instead.

func (*ListRulesResponse) GetNextPageToken 

func (x *ListRulesResponse) GetNextPageToken() string

func (*ListRulesResponse) GetRules 

func (x *ListRulesResponse) GetRules() []*Rule

func (*ListRulesResponse) ProtoMessage 

func (*ListRulesResponse) ProtoMessage()

func (*ListRulesResponse) ProtoReflect 

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

func (*ListRulesResponse) Reset 

func (x *ListRulesResponse) Reset()

func (*ListRulesResponse) SetNextPageToken 

func (m *ListRulesResponse) SetNextPageToken(v string)

func (*ListRulesResponse) SetRules 

func (m *ListRulesResponse) SetRules(v []*Rule)

func (*ListRulesResponse) String 

func (x *ListRulesResponse) String() string

type LoggingTarget 

type LoggingTarget struct {

	// Log group ID or folder ID.
	//
	// Types that are assignable to Destination:
	//
	//	*LoggingTarget_LogGroupId
	//	*LoggingTarget_FolderId
	Destination isLoggingTarget_Destination `protobuf_oneof:"destination"`
	// Service account which has permission for writing logs.
	ServiceAccountId string `protobuf:"bytes,3,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"`
	// contains filtered or unexported fields
}

func (*LoggingTarget) Descriptor deprecated 

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

Deprecated: Use LoggingTarget.ProtoReflect.Descriptor instead.

func (*LoggingTarget) GetDestination 

func (m *LoggingTarget) GetDestination() isLoggingTarget_Destination

func (*LoggingTarget) GetFolderId 

func (x *LoggingTarget) GetFolderId() string

func (*LoggingTarget) GetLogGroupId 

func (x *LoggingTarget) GetLogGroupId() string

func (*LoggingTarget) GetServiceAccountId 

func (x *LoggingTarget) GetServiceAccountId() string

func (*LoggingTarget) ProtoMessage 

func (*LoggingTarget) ProtoMessage()

func (*LoggingTarget) ProtoReflect 

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

func (*LoggingTarget) Reset 

func (x *LoggingTarget) Reset()

func (*LoggingTarget) SetDestination 

func (m *LoggingTarget) SetDestination(v LoggingTarget_Destination)

func (*LoggingTarget) SetFolderId 

func (m *LoggingTarget) SetFolderId(v string)

func (*LoggingTarget) SetLogGroupId 

func (m *LoggingTarget) SetLogGroupId(v string)

func (*LoggingTarget) SetServiceAccountId 

func (m *LoggingTarget) SetServiceAccountId(v string)

func (*LoggingTarget) String 

func (x *LoggingTarget) String() string

type LoggingTarget_Destination 

type LoggingTarget_Destination = isLoggingTarget_Destination

type LoggingTarget_FolderId 

type LoggingTarget_FolderId struct {
	FolderId string `protobuf:"bytes,2,opt,name=folder_id,json=folderId,proto3,oneof"`
}

type LoggingTarget_LogGroupId 

type LoggingTarget_LogGroupId struct {
	LogGroupId string `protobuf:"bytes,1,opt,name=log_group_id,json=logGroupId,proto3,oneof"`
}

type MessageQueue 

type MessageQueue struct {

	// Queue ARN.
	// Example: yrn:yc:ymq:ru-central1:aoe***:test
	QueueArn string `protobuf:"bytes,1,opt,name=queue_arn,json=queueArn,proto3" json:"queue_arn,omitempty"`
	// Service account which has read access to the queue.
	ServiceAccountId string `protobuf:"bytes,2,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"`
	// Queue visibility timeout override.
	VisibilityTimeout *durationpb.Duration `protobuf:"bytes,3,opt,name=visibility_timeout,json=visibilityTimeout,proto3" json:"visibility_timeout,omitempty"`
	// Batch size for polling.
	BatchSize int64 `protobuf:"varint,4,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	// Queue polling timeout.
	PollingTimeout *durationpb.Duration `protobuf:"bytes,5,opt,name=polling_timeout,json=pollingTimeout,proto3" json:"polling_timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageQueue) Descriptor deprecated 

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

Deprecated: Use MessageQueue.ProtoReflect.Descriptor instead.

func (*MessageQueue) GetBatchSize 

func (x *MessageQueue) GetBatchSize() int64

func (*MessageQueue) GetPollingTimeout 

func (x *MessageQueue) GetPollingTimeout() *durationpb.Duration

func (*MessageQueue) GetQueueArn 

func (x *MessageQueue) GetQueueArn() string

func (*MessageQueue) GetServiceAccountId 

func (x *MessageQueue) GetServiceAccountId() string

func (*MessageQueue) GetVisibilityTimeout 

func (x *MessageQueue) GetVisibilityTimeout() *durationpb.Duration

func (*MessageQueue) ProtoMessage 

func (*MessageQueue) ProtoMessage()

func (*MessageQueue) ProtoReflect 

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

func (*MessageQueue) Reset 

func (x *MessageQueue) Reset()

func (*MessageQueue) SetBatchSize 

func (m *MessageQueue) SetBatchSize(v int64)

func (*MessageQueue) SetPollingTimeout 

func (m *MessageQueue) SetPollingTimeout(v *durationpb.Duration)

func (*MessageQueue) SetQueueArn 

func (m *MessageQueue) SetQueueArn(v string)

func (*MessageQueue) SetServiceAccountId 

func (m *MessageQueue) SetServiceAccountId(v string)

func (*MessageQueue) SetVisibilityTimeout 

func (m *MessageQueue) SetVisibilityTimeout(v *durationpb.Duration)

func (*MessageQueue) String 

func (x *MessageQueue) String() string

type PutEventRequest 

type PutEventRequest struct {

	// ID of the bus to put event.
	BusId string `protobuf:"bytes,1,opt,name=bus_id,json=busId,proto3" json:"bus_id,omitempty"`
	// Event body.
	Body string `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*PutEventRequest) Descriptor deprecated 

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

Deprecated: Use PutEventRequest.ProtoReflect.Descriptor instead.

func (*PutEventRequest) GetBody 

func (x *PutEventRequest) GetBody() string

func (*PutEventRequest) GetBusId 

func (x *PutEventRequest) GetBusId() string

func (*PutEventRequest) ProtoMessage 

func (*PutEventRequest) ProtoMessage()

func (*PutEventRequest) ProtoReflect 

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

func (*PutEventRequest) Reset 

func (x *PutEventRequest) Reset()

func (*PutEventRequest) SetBody 

func (m *PutEventRequest) SetBody(v string)

func (*PutEventRequest) SetBusId 

func (m *PutEventRequest) SetBusId(v string)

func (*PutEventRequest) String 

func (x *PutEventRequest) String() string

type PutQueueMessage 

type PutQueueMessage struct {

	// ID of the queue.
	QueueArn string `protobuf:"bytes,1,opt,name=queue_arn,json=queueArn,proto3" json:"queue_arn,omitempty"`
	// Service account which has write permission on the queue.
	ServiceAccountId string `protobuf:"bytes,2,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"`
	// contains filtered or unexported fields
}

func (*PutQueueMessage) Descriptor deprecated 

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

Deprecated: Use PutQueueMessage.ProtoReflect.Descriptor instead.

func (*PutQueueMessage) GetQueueArn 

func (x *PutQueueMessage) GetQueueArn() string

func (*PutQueueMessage) GetServiceAccountId 

func (x *PutQueueMessage) GetServiceAccountId() string

func (*PutQueueMessage) ProtoMessage 

func (*PutQueueMessage) ProtoMessage()

func (*PutQueueMessage) ProtoReflect 

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

func (*PutQueueMessage) Reset 

func (x *PutQueueMessage) Reset()

func (*PutQueueMessage) SetQueueArn 

func (m *PutQueueMessage) SetQueueArn(v string)

func (*PutQueueMessage) SetServiceAccountId 

func (m *PutQueueMessage) SetServiceAccountId(v string)

func (*PutQueueMessage) String 

func (x *PutQueueMessage) String() string

type RetrySettings 

type RetrySettings struct {

	// Maximum number of retries (extra calls) before an action fails.
	RetryAttempts int64 `protobuf:"varint,1,opt,name=retry_attempts,json=retryAttempts,proto3" json:"retry_attempts,omitempty"`
	// Event goes to dlq when its age exceeds this value. Default is 24h.
	MaximumAge *durationpb.Duration `protobuf:"bytes,2,opt,name=maximum_age,json=maximumAge,proto3" json:"maximum_age,omitempty"`
	// contains filtered or unexported fields
}

func (*RetrySettings) Descriptor deprecated 

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

Deprecated: Use RetrySettings.ProtoReflect.Descriptor instead.

func (*RetrySettings) GetMaximumAge 

func (x *RetrySettings) GetMaximumAge() *durationpb.Duration

func (*RetrySettings) GetRetryAttempts 

func (x *RetrySettings) GetRetryAttempts() int64

func (*RetrySettings) ProtoMessage 

func (*RetrySettings) ProtoMessage()

func (*RetrySettings) ProtoReflect 

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

func (*RetrySettings) Reset 

func (x *RetrySettings) Reset()

func (*RetrySettings) SetMaximumAge 

func (m *RetrySettings) SetMaximumAge(v *durationpb.Duration)

func (*RetrySettings) SetRetryAttempts 

func (m *RetrySettings) SetRetryAttempts(v int64)

func (*RetrySettings) String 

func (x *RetrySettings) String() string

type Rule 

type Rule struct {

	// ID of the rule.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// ID of the bus that the rule belongs to.
	BusId string `protobuf:"bytes,2,opt,name=bus_id,json=busId,proto3" json:"bus_id,omitempty"`
	// ID of the folder that the rule resides in.
	FolderId string `protobuf:"bytes,3,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	// ID of the cloud that the rule resides in.
	CloudId string `protobuf:"bytes,4,opt,name=cloud_id,json=cloudId,proto3" json:"cloud_id,omitempty"`
	// Creation timestamp.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Name of the rule.
	Name string `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the rule.
	Description string `protobuf:"bytes,7,opt,name=description,proto3" json:"description,omitempty"`
	// Resource labels as `key:value` pairs.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Filter for the rule.
	Filter *Filter `protobuf:"bytes,11,opt,name=filter,proto3" json:"filter,omitempty"`
	// Targets of the rule.
	Targets []*Target `protobuf:"bytes,12,rep,name=targets,proto3" json:"targets,omitempty"`
	// Flag that disallow deletion of the rule.
	DeletionProtection bool `protobuf:"varint,13,opt,name=deletion_protection,json=deletionProtection,proto3" json:"deletion_protection,omitempty"`
	// Rule status
	Status Rule_Status `protobuf:"varint,14,opt,name=status,proto3,enum=yandex.cloud.serverless.eventrouter.v1.Rule_Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*Rule) Descriptor deprecated 

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

Deprecated: Use Rule.ProtoReflect.Descriptor instead.

func (*Rule) GetBusId 

func (x *Rule) GetBusId() string

func (*Rule) GetCloudId 

func (x *Rule) GetCloudId() string

func (*Rule) GetCreatedAt 

func (x *Rule) GetCreatedAt() *timestamppb.Timestamp

func (*Rule) GetDeletionProtection 

func (x *Rule) GetDeletionProtection() bool

func (*Rule) GetDescription 

func (x *Rule) GetDescription() string

func (*Rule) GetFilter 

func (x *Rule) GetFilter() *Filter

func (*Rule) GetFolderId 

func (x *Rule) GetFolderId() string

func (*Rule) GetId 

func (x *Rule) GetId() string

func (*Rule) GetLabels 

func (x *Rule) GetLabels() map[string]string

func (*Rule) GetName 

func (x *Rule) GetName() string

func (*Rule) GetStatus 

func (x *Rule) GetStatus() Rule_Status

func (*Rule) GetTargets 

func (x *Rule) GetTargets() []*Target

func (*Rule) ProtoMessage 

func (*Rule) ProtoMessage()

func (*Rule) ProtoReflect 

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

func (*Rule) Reset 

func (x *Rule) Reset()

func (*Rule) SetBusId 

func (m *Rule) SetBusId(v string)

func (*Rule) SetCloudId 

func (m *Rule) SetCloudId(v string)

func (*Rule) SetCreatedAt 

func (m *Rule) SetCreatedAt(v *timestamppb.Timestamp)

func (*Rule) SetDeletionProtection 

func (m *Rule) SetDeletionProtection(v bool)

func (*Rule) SetDescription 

func (m *Rule) SetDescription(v string)

func (*Rule) SetFilter 

func (m *Rule) SetFilter(v *Filter)

func (*Rule) SetFolderId 

func (m *Rule) SetFolderId(v string)

func (*Rule) SetId 

func (m *Rule) SetId(v string)

func (*Rule) SetLabels 

func (m *Rule) SetLabels(v map[string]string)

func (*Rule) SetName 

func (m *Rule) SetName(v string)

func (*Rule) SetStatus 

func (m *Rule) SetStatus(v Rule_Status)

func (*Rule) SetTargets 

func (m *Rule) SetTargets(v []*Target)

func (*Rule) String 

func (x *Rule) String() string

type RuleServiceClient 

type RuleServiceClient interface {
	// Returns the specified rules.
	// To get the list of all available buses, make a [List] request.
	Get(ctx context.Context, in *GetRuleRequest, opts ...grpc.CallOption) (*Rule, error)
	// Retrieves the list of rules in the specified folder.
	List(ctx context.Context, in *ListRulesRequest, opts ...grpc.CallOption) (*ListRulesResponse, error)
	// Creates a rule in the specified folder.
	Create(ctx context.Context, in *CreateRuleRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Updates the specified rule.
	Update(ctx context.Context, in *UpdateRuleRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Deletes the specified rule.
	Delete(ctx context.Context, in *DeleteRuleRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Enables the specified rule.
	Enable(ctx context.Context, in *EnableRuleRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Disables the specified rule.
	Disable(ctx context.Context, in *DisableRuleRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Lists existing access bindings for the specified rule.
	ListAccessBindings(ctx context.Context, in *access.ListAccessBindingsRequest, opts ...grpc.CallOption) (*access.ListAccessBindingsResponse, error)
	// Sets access bindings for the rule.
	SetAccessBindings(ctx context.Context, in *access.SetAccessBindingsRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Updates access bindings for the specified rule.
	UpdateAccessBindings(ctx context.Context, in *access.UpdateAccessBindingsRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Lists operations for the specified rule.
	ListOperations(ctx context.Context, in *ListRuleOperationsRequest, opts ...grpc.CallOption) (*ListRuleOperationsResponse, error)
}

RuleServiceClient is the client API for RuleService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

A set of methods for managing rules for serverless eventrouter.

func NewRuleServiceClient 

func NewRuleServiceClient(cc grpc.ClientConnInterface) RuleServiceClient

type RuleServiceServer 

type RuleServiceServer interface {
	// Returns the specified rules.
	// To get the list of all available buses, make a [List] request.
	Get(context.Context, *GetRuleRequest) (*Rule, error)
	// Retrieves the list of rules in the specified folder.
	List(context.Context, *ListRulesRequest) (*ListRulesResponse, error)
	// Creates a rule in the specified folder.
	Create(context.Context, *CreateRuleRequest) (*operation.Operation, error)
	// Updates the specified rule.
	Update(context.Context, *UpdateRuleRequest) (*operation.Operation, error)
	// Deletes the specified rule.
	Delete(context.Context, *DeleteRuleRequest) (*operation.Operation, error)
	// Enables the specified rule.
	Enable(context.Context, *EnableRuleRequest) (*operation.Operation, error)
	// Disables the specified rule.
	Disable(context.Context, *DisableRuleRequest) (*operation.Operation, error)
	// Lists existing access bindings for the specified rule.
	ListAccessBindings(context.Context, *access.ListAccessBindingsRequest) (*access.ListAccessBindingsResponse, error)
	// Sets access bindings for the rule.
	SetAccessBindings(context.Context, *access.SetAccessBindingsRequest) (*operation.Operation, error)
	// Updates access bindings for the specified rule.
	UpdateAccessBindings(context.Context, *access.UpdateAccessBindingsRequest) (*operation.Operation, error)
	// Lists operations for the specified rule.
	ListOperations(context.Context, *ListRuleOperationsRequest) (*ListRuleOperationsResponse, error)
}

RuleServiceServer is the server API for RuleService service. All implementations should embed UnimplementedRuleServiceServer for forward compatibility.

A set of methods for managing rules for serverless eventrouter.

type Rule_Status 

type Rule_Status int32
const (
	Rule_STATUS_UNSPECIFIED Rule_Status = 0
	// Rule creation in progress, rule is not enabled yet
	Rule_CREATING Rule_Status = 1
	// Rule is operating
	Rule_ENABLED Rule_Status = 2
	// Rule update in progress, rule is disabled during update
	Rule_UPDATING Rule_Status = 3
	// Rule is explicitly disabled by the user
	Rule_DISABLED Rule_Status = 4
	// Rule deletion in progress
	Rule_DELETING Rule_Status = 5
)

func (Rule_Status) Descriptor 

func (Rule_Status) Descriptor() protoreflect.EnumDescriptor

func (Rule_Status) Enum 

func (x Rule_Status) Enum() *Rule_Status

func (Rule_Status) EnumDescriptor deprecated 

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

Deprecated: Use Rule_Status.Descriptor instead.

func (Rule_Status) Number 

func (x Rule_Status) Number() protoreflect.EnumNumber

func (Rule_Status) String 

func (x Rule_Status) String() string

func (Rule_Status) Type 

func (Rule_Status) Type() protoreflect.EnumType

type Source 

type Source struct {

	// Types that are assignable to Source:
	//
	//	*Source_DataStream
	//	*Source_MessageQueue
	Source isSource_Source `protobuf_oneof:"source"`
	// contains filtered or unexported fields
}

func (*Source) Descriptor deprecated 

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

Deprecated: Use Source.ProtoReflect.Descriptor instead.

func (*Source) GetDataStream 

func (x *Source) GetDataStream() *DataStream

func (*Source) GetMessageQueue 

func (x *Source) GetMessageQueue() *MessageQueue

func (*Source) GetSource 

func (m *Source) GetSource() isSource_Source

func (*Source) ProtoMessage 

func (*Source) ProtoMessage()

func (*Source) ProtoReflect 

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

func (*Source) Reset 

func (x *Source) Reset()

func (*Source) SetDataStream 

func (m *Source) SetDataStream(v *DataStream)

func (*Source) SetMessageQueue 

func (m *Source) SetMessageQueue(v *MessageQueue)

func (*Source) SetSource 

func (m *Source) SetSource(v Source_Source)

func (*Source) String 

func (x *Source) String() string

type Source_DataStream 

type Source_DataStream struct {
	DataStream *DataStream `protobuf:"bytes,1,opt,name=data_stream,json=dataStream,proto3,oneof"`
}

type Source_MessageQueue 

type Source_MessageQueue struct {
	MessageQueue *MessageQueue `protobuf:"bytes,2,opt,name=message_queue,json=messageQueue,proto3,oneof"`
}

type Source_Source 

type Source_Source = isSource_Source

type StartConnectorMetadata 

type StartConnectorMetadata struct {

	// ID of the connector that is being started.
	ConnectorId string `protobuf:"bytes,1,opt,name=connector_id,json=connectorId,proto3" json:"connector_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StartConnectorMetadata) Descriptor deprecated 

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

Deprecated: Use StartConnectorMetadata.ProtoReflect.Descriptor instead.

func (*StartConnectorMetadata) GetConnectorId 

func (x *StartConnectorMetadata) GetConnectorId() string

func (*StartConnectorMetadata) ProtoMessage 

func (*StartConnectorMetadata) ProtoMessage()

func (*StartConnectorMetadata) ProtoReflect 

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

func (*StartConnectorMetadata) Reset 

func (x *StartConnectorMetadata) Reset()

func (*StartConnectorMetadata) SetConnectorId 

func (m *StartConnectorMetadata) SetConnectorId(v string)

func (*StartConnectorMetadata) String 

func (x *StartConnectorMetadata) String() string

type StartConnectorRequest 

type StartConnectorRequest struct {

	// ID of the connector to start.
	ConnectorId string `protobuf:"bytes,1,opt,name=connector_id,json=connectorId,proto3" json:"connector_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StartConnectorRequest) Descriptor deprecated 

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

Deprecated: Use StartConnectorRequest.ProtoReflect.Descriptor instead.

func (*StartConnectorRequest) GetConnectorId 

func (x *StartConnectorRequest) GetConnectorId() string

func (*StartConnectorRequest) ProtoMessage 

func (*StartConnectorRequest) ProtoMessage()

func (*StartConnectorRequest) ProtoReflect 

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

func (*StartConnectorRequest) Reset 

func (x *StartConnectorRequest) Reset()

func (*StartConnectorRequest) SetConnectorId 

func (m *StartConnectorRequest) SetConnectorId(v string)

func (*StartConnectorRequest) String 

func (x *StartConnectorRequest) String() string

type StopConnectorMetadata 

type StopConnectorMetadata struct {

	// ID of the connector that is being stopped.
	ConnectorId string `protobuf:"bytes,1,opt,name=connector_id,json=connectorId,proto3" json:"connector_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StopConnectorMetadata) Descriptor deprecated 

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

Deprecated: Use StopConnectorMetadata.ProtoReflect.Descriptor instead.

func (*StopConnectorMetadata) GetConnectorId 

func (x *StopConnectorMetadata) GetConnectorId() string

func (*StopConnectorMetadata) ProtoMessage 

func (*StopConnectorMetadata) ProtoMessage()

func (*StopConnectorMetadata) ProtoReflect 

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

func (*StopConnectorMetadata) Reset 

func (x *StopConnectorMetadata) Reset()

func (*StopConnectorMetadata) SetConnectorId 

func (m *StopConnectorMetadata) SetConnectorId(v string)

func (*StopConnectorMetadata) String 

func (x *StopConnectorMetadata) String() string

type StopConnectorRequest 

type StopConnectorRequest struct {

	// ID of the connector to stop.
	ConnectorId string `protobuf:"bytes,1,opt,name=connector_id,json=connectorId,proto3" json:"connector_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StopConnectorRequest) Descriptor deprecated 

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

Deprecated: Use StopConnectorRequest.ProtoReflect.Descriptor instead.

func (*StopConnectorRequest) GetConnectorId 

func (x *StopConnectorRequest) GetConnectorId() string

func (*StopConnectorRequest) ProtoMessage 

func (*StopConnectorRequest) ProtoMessage()

func (*StopConnectorRequest) ProtoReflect 

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

func (*StopConnectorRequest) Reset 

func (x *StopConnectorRequest) Reset()

func (*StopConnectorRequest) SetConnectorId 

func (m *StopConnectorRequest) SetConnectorId(v string)

func (*StopConnectorRequest) String 

func (x *StopConnectorRequest) String() string

type Target 

type Target struct {

	// Types that are assignable to Target:
	//
	//	*Target_Yds
	//	*Target_Ymq
	//	*Target_Function
	//	*Target_Container
	//	*Target_GatewayWsBroadcast
	//	*Target_Logging
	//	*Target_Workflow
	Target isTarget_Target `protobuf_oneof:"target"`
	// Transformer of the target.
	Transformer *Transformer `protobuf:"bytes,50,opt,name=transformer,proto3" json:"transformer,omitempty"`
	// Retry settings of the target.
	RetrySettings *RetrySettings `protobuf:"bytes,51,opt,name=retry_settings,json=retrySettings,proto3" json:"retry_settings,omitempty"`
	// Dead letter settings of the target.
	//
	// Types that are assignable to DeadLetter:
	//
	//	*Target_DeadLetterQueue
	DeadLetter isTarget_DeadLetter `protobuf_oneof:"dead_letter"`
	// Status of the target.
	Status Target_Status `protobuf:"varint,54,opt,name=status,proto3,enum=yandex.cloud.serverless.eventrouter.v1.Target_Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*Target) Descriptor deprecated 

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

Deprecated: Use Target.ProtoReflect.Descriptor instead.

func (*Target) GetContainer 

func (x *Target) GetContainer() *ContainerTarget

func (*Target) GetDeadLetter 

func (m *Target) GetDeadLetter() isTarget_DeadLetter

func (*Target) GetDeadLetterQueue 

func (x *Target) GetDeadLetterQueue() *PutQueueMessage

func (*Target) GetFunction 

func (x *Target) GetFunction() *FunctionTarget

func (*Target) GetGatewayWsBroadcast 

func (x *Target) GetGatewayWsBroadcast() *GatewayWebsocketBroadcastTarget

func (*Target) GetLogging 

func (x *Target) GetLogging() *LoggingTarget

func (*Target) GetRetrySettings 

func (x *Target) GetRetrySettings() *RetrySettings

func (*Target) GetStatus 

func (x *Target) GetStatus() Target_Status

func (*Target) GetTarget 

func (m *Target) GetTarget() isTarget_Target

func (*Target) GetTransformer 

func (x *Target) GetTransformer() *Transformer

func (*Target) GetWorkflow 

func (x *Target) GetWorkflow() *WorkflowTarget

func (*Target) GetYds 

func (x *Target) GetYds() *YdsTarget

func (*Target) GetYmq 

func (x *Target) GetYmq() *YmqTarget

func (*Target) ProtoMessage 

func (*Target) ProtoMessage()

func (*Target) ProtoReflect 

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

func (*Target) Reset 

func (x *Target) Reset()

func (*Target) SetContainer 

func (m *Target) SetContainer(v *ContainerTarget)

func (*Target) SetDeadLetter 

func (m *Target) SetDeadLetter(v Target_DeadLetter)

func (*Target) SetDeadLetterQueue 

func (m *Target) SetDeadLetterQueue(v *PutQueueMessage)

func (*Target) SetFunction 

func (m *Target) SetFunction(v *FunctionTarget)

func (*Target) SetGatewayWsBroadcast 

func (m *Target) SetGatewayWsBroadcast(v *GatewayWebsocketBroadcastTarget)

func (*Target) SetLogging 

func (m *Target) SetLogging(v *LoggingTarget)

func (*Target) SetRetrySettings 

func (m *Target) SetRetrySettings(v *RetrySettings)

func (*Target) SetStatus 

func (m *Target) SetStatus(v Target_Status)

func (*Target) SetTarget 

func (m *Target) SetTarget(v Target_Target)

func (*Target) SetTransformer 

func (m *Target) SetTransformer(v *Transformer)

func (*Target) SetWorkflow 

func (m *Target) SetWorkflow(v *WorkflowTarget)

func (*Target) SetYds 

func (m *Target) SetYds(v *YdsTarget)

func (*Target) SetYmq 

func (m *Target) SetYmq(v *YmqTarget)

func (*Target) String 

func (x *Target) String() string

type Target_Container 

type Target_Container struct {
	Container *ContainerTarget `protobuf:"bytes,4,opt,name=container,proto3,oneof"`
}

type Target_DeadLetter 

type Target_DeadLetter = isTarget_DeadLetter

type Target_DeadLetterQueue 

type Target_DeadLetterQueue struct {
	// Dead letter queue.
	DeadLetterQueue *PutQueueMessage `protobuf:"bytes,52,opt,name=dead_letter_queue,json=deadLetterQueue,proto3,oneof"`
}

type Target_Function 

type Target_Function struct {
	Function *FunctionTarget `protobuf:"bytes,3,opt,name=function,proto3,oneof"`
}

type Target_GatewayWsBroadcast 

type Target_GatewayWsBroadcast struct {
	GatewayWsBroadcast *GatewayWebsocketBroadcastTarget `protobuf:"bytes,5,opt,name=gateway_ws_broadcast,json=gatewayWsBroadcast,proto3,oneof"`
}

type Target_Logging 

type Target_Logging struct {
	Logging *LoggingTarget `protobuf:"bytes,6,opt,name=logging,proto3,oneof"`
}

type Target_Status 

type Target_Status int32

Status of the target. 

const (
	Target_STATUS_UNSPECIFIED Target_Status = 0
	// Target is enabled.
	Target_ENABLED Target_Status = 1
	// Target is disabled.
	Target_DISABLED Target_Status = 2
	// Target does not exist.
	Target_RESOURCE_NOT_FOUND Target_Status = 3
	// Service account does not have read permission on source.
	Target_PERMISSION_DENIED Target_Status = 4
	// Service account not found.
	Target_SUBJECT_NOT_FOUND Target_Status = 5
)

func (Target_Status) Descriptor 

func (Target_Status) Descriptor() protoreflect.EnumDescriptor

func (Target_Status) Enum 

func (x Target_Status) Enum() *Target_Status

func (Target_Status) EnumDescriptor deprecated 

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

Deprecated: Use Target_Status.Descriptor instead.

func (Target_Status) Number 

func (x Target_Status) Number() protoreflect.EnumNumber

func (Target_Status) String 

func (x Target_Status) String() string

func (Target_Status) Type 

func (Target_Status) Type() protoreflect.EnumType

type Target_Target 

type Target_Target = isTarget_Target

type Target_Workflow 

type Target_Workflow struct {
	Workflow *WorkflowTarget `protobuf:"bytes,7,opt,name=workflow,proto3,oneof"`
}

type Target_Yds 

type Target_Yds struct {
	Yds *YdsTarget `protobuf:"bytes,1,opt,name=yds,proto3,oneof"`
}

type Target_Ymq 

type Target_Ymq struct {
	Ymq *YmqTarget `protobuf:"bytes,2,opt,name=ymq,proto3,oneof"`
}

type Transformer 

type Transformer struct {

	// Types that are assignable to Transformer:
	//
	//	*Transformer_JqTransformer
	Transformer isTransformer_Transformer `protobuf_oneof:"transformer"`
	// contains filtered or unexported fields
}

func (*Transformer) Descriptor deprecated 

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

Deprecated: Use Transformer.ProtoReflect.Descriptor instead.

func (*Transformer) GetJqTransformer 

func (x *Transformer) GetJqTransformer() string

func (*Transformer) GetTransformer 

func (m *Transformer) GetTransformer() isTransformer_Transformer

func (*Transformer) ProtoMessage 

func (*Transformer) ProtoMessage()

func (*Transformer) ProtoReflect 

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

func (*Transformer) Reset 

func (x *Transformer) Reset()

func (*Transformer) SetJqTransformer 

func (m *Transformer) SetJqTransformer(v string)

func (*Transformer) SetTransformer 

func (m *Transformer) SetTransformer(v Transformer_Transformer)

func (*Transformer) String 

func (x *Transformer) String() string

type Transformer_JqTransformer 

type Transformer_JqTransformer struct {
	// JQ string inrerpolation expression for changing event format.
	JqTransformer string `protobuf:"bytes,1,opt,name=jq_transformer,json=jqTransformer,proto3,oneof"`
}

type Transformer_Transformer 

type Transformer_Transformer = isTransformer_Transformer

type UnimplementedBusServiceServer 

type UnimplementedBusServiceServer struct{}

UnimplementedBusServiceServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedBusServiceServer) Create 

func (UnimplementedBusServiceServer) Create(context.Context, *CreateBusRequest) (*operation.Operation, error)

func (UnimplementedBusServiceServer) Delete 

func (UnimplementedBusServiceServer) Delete(context.Context, *DeleteBusRequest) (*operation.Operation, error)

func (UnimplementedBusServiceServer) Get 

func (UnimplementedBusServiceServer) Get(context.Context, *GetBusRequest) (*Bus, error)

func (UnimplementedBusServiceServer) List 

func (UnimplementedBusServiceServer) List(context.Context, *ListBusesRequest) (*ListBusesResponse, error)

func (UnimplementedBusServiceServer) ListAccessBindings 

func (UnimplementedBusServiceServer) ListAccessBindings(context.Context, *access.ListAccessBindingsRequest) (*access.ListAccessBindingsResponse, error)

func (UnimplementedBusServiceServer) ListOperations 

func (UnimplementedBusServiceServer) ListOperations(context.Context, *ListBusOperationsRequest) (*ListBusOperationsResponse, error)

func (UnimplementedBusServiceServer) SetAccessBindings 

func (UnimplementedBusServiceServer) SetAccessBindings(context.Context, *access.SetAccessBindingsRequest) (*operation.Operation, error)

func (UnimplementedBusServiceServer) Update 

func (UnimplementedBusServiceServer) Update(context.Context, *UpdateBusRequest) (*operation.Operation, error)

func (UnimplementedBusServiceServer) UpdateAccessBindings 

func (UnimplementedBusServiceServer) UpdateAccessBindings(context.Context, *access.UpdateAccessBindingsRequest) (*operation.Operation, error)

type UnimplementedConnectorServiceServer 

type UnimplementedConnectorServiceServer struct{}

UnimplementedConnectorServiceServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedConnectorServiceServer) Create 

func (UnimplementedConnectorServiceServer) Create(context.Context, *CreateConnectorRequest) (*operation.Operation, error)

func (UnimplementedConnectorServiceServer) Delete 

func (UnimplementedConnectorServiceServer) Delete(context.Context, *DeleteConnectorRequest) (*operation.Operation, error)

func (UnimplementedConnectorServiceServer) Get 

func (UnimplementedConnectorServiceServer) Get(context.Context, *GetConnectorRequest) (*Connector, error)

func (UnimplementedConnectorServiceServer) List 

func (UnimplementedConnectorServiceServer) List(context.Context, *ListConnectorsRequest) (*ListConnectorsResponse, error)

func (UnimplementedConnectorServiceServer) ListAccessBindings 

func (UnimplementedConnectorServiceServer) ListAccessBindings(context.Context, *access.ListAccessBindingsRequest) (*access.ListAccessBindingsResponse, error)

func (UnimplementedConnectorServiceServer) ListOperations 

func (UnimplementedConnectorServiceServer) ListOperations(context.Context, *ListConnectorOperationsRequest) (*ListConnectorOperationsResponse, error)

func (UnimplementedConnectorServiceServer) SetAccessBindings 

func (UnimplementedConnectorServiceServer) SetAccessBindings(context.Context, *access.SetAccessBindingsRequest) (*operation.Operation, error)

func (UnimplementedConnectorServiceServer) Start 

func (UnimplementedConnectorServiceServer) Start(context.Context, *StartConnectorRequest) (*operation.Operation, error)

func (UnimplementedConnectorServiceServer) Stop 

func (UnimplementedConnectorServiceServer) Stop(context.Context, *StopConnectorRequest) (*operation.Operation, error)

func (UnimplementedConnectorServiceServer) Update 

func (UnimplementedConnectorServiceServer) Update(context.Context, *UpdateConnectorRequest) (*operation.Operation, error)

func (UnimplementedConnectorServiceServer) UpdateAccessBindings 

func (UnimplementedConnectorServiceServer) UpdateAccessBindings(context.Context, *access.UpdateAccessBindingsRequest) (*operation.Operation, error)

type UnimplementedEventServiceServer 

type UnimplementedEventServiceServer struct{}

UnimplementedEventServiceServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedEventServiceServer) Put 

func (UnimplementedEventServiceServer) Put(context.Context, *PutEventRequest) (*emptypb.Empty, error)

type UnimplementedRuleServiceServer 

type UnimplementedRuleServiceServer struct{}

UnimplementedRuleServiceServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedRuleServiceServer) Create 

func (UnimplementedRuleServiceServer) Create(context.Context, *CreateRuleRequest) (*operation.Operation, error)

func (UnimplementedRuleServiceServer) Delete 

func (UnimplementedRuleServiceServer) Delete(context.Context, *DeleteRuleRequest) (*operation.Operation, error)

func (UnimplementedRuleServiceServer) Disable 

func (UnimplementedRuleServiceServer) Disable(context.Context, *DisableRuleRequest) (*operation.Operation, error)

func (UnimplementedRuleServiceServer) Enable 

func (UnimplementedRuleServiceServer) Enable(context.Context, *EnableRuleRequest) (*operation.Operation, error)

func (UnimplementedRuleServiceServer) Get 

func (UnimplementedRuleServiceServer) Get(context.Context, *GetRuleRequest) (*Rule, error)

func (UnimplementedRuleServiceServer) List 

func (UnimplementedRuleServiceServer) List(context.Context, *ListRulesRequest) (*ListRulesResponse, error)

func (UnimplementedRuleServiceServer) ListAccessBindings 

func (UnimplementedRuleServiceServer) ListAccessBindings(context.Context, *access.ListAccessBindingsRequest) (*access.ListAccessBindingsResponse, error)

func (UnimplementedRuleServiceServer) ListOperations 

func (UnimplementedRuleServiceServer) ListOperations(context.Context, *ListRuleOperationsRequest) (*ListRuleOperationsResponse, error)

func (UnimplementedRuleServiceServer) SetAccessBindings 

func (UnimplementedRuleServiceServer) SetAccessBindings(context.Context, *access.SetAccessBindingsRequest) (*operation.Operation, error)

func (UnimplementedRuleServiceServer) Update 

func (UnimplementedRuleServiceServer) Update(context.Context, *UpdateRuleRequest) (*operation.Operation, error)

func (UnimplementedRuleServiceServer) UpdateAccessBindings 

func (UnimplementedRuleServiceServer) UpdateAccessBindings(context.Context, *access.UpdateAccessBindingsRequest) (*operation.Operation, error)

type UnsafeBusServiceServer 

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

UnsafeBusServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BusServiceServer will result in compilation errors.

type UnsafeConnectorServiceServer 

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

UnsafeConnectorServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ConnectorServiceServer will result in compilation errors.

type UnsafeEventServiceServer 

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

UnsafeEventServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EventServiceServer will result in compilation errors.

type UnsafeRuleServiceServer 

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

UnsafeRuleServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RuleServiceServer will result in compilation errors.

type UpdateBusMetadata 

type UpdateBusMetadata struct {

	// ID of the bus that is being updated.
	BusId string `protobuf:"bytes,1,opt,name=bus_id,json=busId,proto3" json:"bus_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateBusMetadata) Descriptor deprecated 

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

Deprecated: Use UpdateBusMetadata.ProtoReflect.Descriptor instead.

func (*UpdateBusMetadata) GetBusId 

func (x *UpdateBusMetadata) GetBusId() string

func (*UpdateBusMetadata) ProtoMessage 

func (*UpdateBusMetadata) ProtoMessage()

func (*UpdateBusMetadata) ProtoReflect 

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

func (*UpdateBusMetadata) Reset 

func (x *UpdateBusMetadata) Reset()

func (*UpdateBusMetadata) SetBusId 

func (m *UpdateBusMetadata) SetBusId(v string)

func (*UpdateBusMetadata) String 

func (x *UpdateBusMetadata) String() string

type UpdateBusRequest 

type UpdateBusRequest struct {

	// ID of the bus to update.
	BusId string `protobuf:"bytes,1,opt,name=bus_id,json=busId,proto3" json:"bus_id,omitempty"`
	// Field mask that specifies which fields of the bus are going to be updated.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// New name of the bus.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// New description of the bus.
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// New labels of the bus.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// New flag that disallow deletion of the bus.
	DeletionProtection bool `protobuf:"varint,6,opt,name=deletion_protection,json=deletionProtection,proto3" json:"deletion_protection,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateBusRequest) Descriptor deprecated 

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

Deprecated: Use UpdateBusRequest.ProtoReflect.Descriptor instead.

func (*UpdateBusRequest) GetBusId 

func (x *UpdateBusRequest) GetBusId() string

func (*UpdateBusRequest) GetDeletionProtection 

func (x *UpdateBusRequest) GetDeletionProtection() bool

func (*UpdateBusRequest) GetDescription 

func (x *UpdateBusRequest) GetDescription() string

func (*UpdateBusRequest) GetLabels 

func (x *UpdateBusRequest) GetLabels() map[string]string

func (*UpdateBusRequest) GetName 

func (x *UpdateBusRequest) GetName() string

func (*UpdateBusRequest) GetUpdateMask 

func (x *UpdateBusRequest) GetUpdateMask() *fieldmaskpb.FieldMask

func (*UpdateBusRequest) ProtoMessage 

func (*UpdateBusRequest) ProtoMessage()

func (*UpdateBusRequest) ProtoReflect 

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

func (*UpdateBusRequest) Reset 

func (x *UpdateBusRequest) Reset()

func (*UpdateBusRequest) SetBusId 

func (m *UpdateBusRequest) SetBusId(v string)

func (*UpdateBusRequest) SetDeletionProtection 

func (m *UpdateBusRequest) SetDeletionProtection(v bool)

func (*UpdateBusRequest) SetDescription 

func (m *UpdateBusRequest) SetDescription(v string)

func (*UpdateBusRequest) SetLabels 

func (m *UpdateBusRequest) SetLabels(v map[string]string)

func (*UpdateBusRequest) SetName 

func (m *UpdateBusRequest) SetName(v string)

func (*UpdateBusRequest) SetUpdateMask 

func (m *UpdateBusRequest) SetUpdateMask(v *fieldmaskpb.FieldMask)

func (*UpdateBusRequest) String 

func (x *UpdateBusRequest) String() string

type UpdateConnectorMetadata 

type UpdateConnectorMetadata struct {

	// ID of the connector that is being updated.
	ConnectorId string `protobuf:"bytes,1,opt,name=connector_id,json=connectorId,proto3" json:"connector_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateConnectorMetadata) Descriptor deprecated 

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

Deprecated: Use UpdateConnectorMetadata.ProtoReflect.Descriptor instead.

func (*UpdateConnectorMetadata) GetConnectorId 

func (x *UpdateConnectorMetadata) GetConnectorId() string

func (*UpdateConnectorMetadata) ProtoMessage 

func (*UpdateConnectorMetadata) ProtoMessage()

func (*UpdateConnectorMetadata) ProtoReflect 

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

func (*UpdateConnectorMetadata) Reset 

func (x *UpdateConnectorMetadata) Reset()

func (*UpdateConnectorMetadata) SetConnectorId 

func (m *UpdateConnectorMetadata) SetConnectorId(v string)

func (*UpdateConnectorMetadata) String 

func (x *UpdateConnectorMetadata) String() string

type UpdateConnectorRequest 

type UpdateConnectorRequest struct {

	// ID of the connector to update.
	ConnectorId string `protobuf:"bytes,1,opt,name=connector_id,json=connectorId,proto3" json:"connector_id,omitempty"`
	// Field mask that specifies which fields of the connector are going to be updated.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// New name of the connector.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// New description of the connector.
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// New labels of the connector.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// New flag that disallow deletion of the connector.
	DeletionProtection bool `protobuf:"varint,6,opt,name=deletion_protection,json=deletionProtection,proto3" json:"deletion_protection,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateConnectorRequest) Descriptor deprecated 

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

Deprecated: Use UpdateConnectorRequest.ProtoReflect.Descriptor instead.

func (*UpdateConnectorRequest) GetConnectorId 

func (x *UpdateConnectorRequest) GetConnectorId() string

func (*UpdateConnectorRequest) GetDeletionProtection 

func (x *UpdateConnectorRequest) GetDeletionProtection() bool

func (*UpdateConnectorRequest) GetDescription 

func (x *UpdateConnectorRequest) GetDescription() string

func (*UpdateConnectorRequest) GetLabels 

func (x *UpdateConnectorRequest) GetLabels() map[string]string

func (*UpdateConnectorRequest) GetName 

func (x *UpdateConnectorRequest) GetName() string

func (*UpdateConnectorRequest) GetUpdateMask 

func (x *UpdateConnectorRequest) GetUpdateMask() *fieldmaskpb.FieldMask

func (*UpdateConnectorRequest) ProtoMessage 

func (*UpdateConnectorRequest) ProtoMessage()

func (*UpdateConnectorRequest) ProtoReflect 

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

func (*UpdateConnectorRequest) Reset 

func (x *UpdateConnectorRequest) Reset()

func (*UpdateConnectorRequest) SetConnectorId 

func (m *UpdateConnectorRequest) SetConnectorId(v string)

func (*UpdateConnectorRequest) SetDeletionProtection 

func (m *UpdateConnectorRequest) SetDeletionProtection(v bool)

func (*UpdateConnectorRequest) SetDescription 

func (m *UpdateConnectorRequest) SetDescription(v string)

func (*UpdateConnectorRequest) SetLabels 

func (m *UpdateConnectorRequest) SetLabels(v map[string]string)

func (*UpdateConnectorRequest) SetName 

func (m *UpdateConnectorRequest) SetName(v string)

func (*UpdateConnectorRequest) SetUpdateMask 

func (m *UpdateConnectorRequest) SetUpdateMask(v *fieldmaskpb.FieldMask)

func (*UpdateConnectorRequest) String 

func (x *UpdateConnectorRequest) String() string

type UpdateRuleMetadata 

type UpdateRuleMetadata struct {

	// ID of the rule that is being updated.
	RuleId string `protobuf:"bytes,1,opt,name=rule_id,json=ruleId,proto3" json:"rule_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateRuleMetadata) Descriptor deprecated 

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

Deprecated: Use UpdateRuleMetadata.ProtoReflect.Descriptor instead.

func (*UpdateRuleMetadata) GetRuleId 

func (x *UpdateRuleMetadata) GetRuleId() string

func (*UpdateRuleMetadata) ProtoMessage 

func (*UpdateRuleMetadata) ProtoMessage()

func (*UpdateRuleMetadata) ProtoReflect 

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

func (*UpdateRuleMetadata) Reset 

func (x *UpdateRuleMetadata) Reset()

func (*UpdateRuleMetadata) SetRuleId 

func (m *UpdateRuleMetadata) SetRuleId(v string)

func (*UpdateRuleMetadata) String 

func (x *UpdateRuleMetadata) String() string

type UpdateRuleRequest 

type UpdateRuleRequest struct {

	// ID of the rule to update.
	RuleId string `protobuf:"bytes,1,opt,name=rule_id,json=ruleId,proto3" json:"rule_id,omitempty"`
	// Field mask that specifies which fields of the rule are going to be updated.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// New name of the rule.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// New description of the rule.
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// New labels for the rule.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// New filter for the rule.
	Filter *Filter `protobuf:"bytes,6,opt,name=filter,proto3" json:"filter,omitempty"`
	// New targets for the rule.
	Targets []*Target `protobuf:"bytes,7,rep,name=targets,proto3" json:"targets,omitempty"`
	// New flag that disallow deletion of the rule.
	DeletionProtection bool `protobuf:"varint,8,opt,name=deletion_protection,json=deletionProtection,proto3" json:"deletion_protection,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateRuleRequest) Descriptor deprecated 

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

Deprecated: Use UpdateRuleRequest.ProtoReflect.Descriptor instead.

func (*UpdateRuleRequest) GetDeletionProtection 

func (x *UpdateRuleRequest) GetDeletionProtection() bool

func (*UpdateRuleRequest) GetDescription 

func (x *UpdateRuleRequest) GetDescription() string

func (*UpdateRuleRequest) GetFilter 

func (x *UpdateRuleRequest) GetFilter() *Filter

func (*UpdateRuleRequest) GetLabels 

func (x *UpdateRuleRequest) GetLabels() map[string]string

func (*UpdateRuleRequest) GetName 

func (x *UpdateRuleRequest) GetName() string

func (*UpdateRuleRequest) GetRuleId 

func (x *UpdateRuleRequest) GetRuleId() string

func (*UpdateRuleRequest) GetTargets 

func (x *UpdateRuleRequest) GetTargets() []*Target

func (*UpdateRuleRequest) GetUpdateMask 

func (x *UpdateRuleRequest) GetUpdateMask() *fieldmaskpb.FieldMask

func (*UpdateRuleRequest) ProtoMessage 

func (*UpdateRuleRequest) ProtoMessage()

func (*UpdateRuleRequest) ProtoReflect 

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

func (*UpdateRuleRequest) Reset 

func (x *UpdateRuleRequest) Reset()

func (*UpdateRuleRequest) SetDeletionProtection 

func (m *UpdateRuleRequest) SetDeletionProtection(v bool)

func (*UpdateRuleRequest) SetDescription 

func (m *UpdateRuleRequest) SetDescription(v string)

func (*UpdateRuleRequest) SetFilter 

func (m *UpdateRuleRequest) SetFilter(v *Filter)

func (*UpdateRuleRequest) SetLabels 

func (m *UpdateRuleRequest) SetLabels(v map[string]string)

func (*UpdateRuleRequest) SetName 

func (m *UpdateRuleRequest) SetName(v string)

func (*UpdateRuleRequest) SetRuleId 

func (m *UpdateRuleRequest) SetRuleId(v string)

func (*UpdateRuleRequest) SetTargets 

func (m *UpdateRuleRequest) SetTargets(v []*Target)

func (*UpdateRuleRequest) SetUpdateMask 

func (m *UpdateRuleRequest) SetUpdateMask(v *fieldmaskpb.FieldMask)

func (*UpdateRuleRequest) String 

func (x *UpdateRuleRequest) String() string

type WorkflowTarget 

type WorkflowTarget struct {

	// Workflow ID.
	WorkflowId string `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	// SA which should be used to start workflow.
	ServiceAccountId string `protobuf:"bytes,4,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"`
	// Batch settings.
	BatchSettings *BatchSettings `protobuf:"bytes,5,opt,name=batch_settings,json=batchSettings,proto3" json:"batch_settings,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowTarget) Descriptor deprecated 

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

Deprecated: Use WorkflowTarget.ProtoReflect.Descriptor instead.

func (*WorkflowTarget) GetBatchSettings 

func (x *WorkflowTarget) GetBatchSettings() *BatchSettings

func (*WorkflowTarget) GetServiceAccountId 

func (x *WorkflowTarget) GetServiceAccountId() string

func (*WorkflowTarget) GetWorkflowId 

func (x *WorkflowTarget) GetWorkflowId() string

func (*WorkflowTarget) ProtoMessage 

func (*WorkflowTarget) ProtoMessage()

func (*WorkflowTarget) ProtoReflect 

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

func (*WorkflowTarget) Reset 

func (x *WorkflowTarget) Reset()

func (*WorkflowTarget) SetBatchSettings 

func (m *WorkflowTarget) SetBatchSettings(v *BatchSettings)

func (*WorkflowTarget) SetServiceAccountId 

func (m *WorkflowTarget) SetServiceAccountId(v string)

func (*WorkflowTarget) SetWorkflowId 

func (m *WorkflowTarget) SetWorkflowId(v string)

func (*WorkflowTarget) String 

func (x *WorkflowTarget) String() string

type YdsTarget 

type YdsTarget struct {

	// Stream database.
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// Full stream name, like /ru-central1/aoegtvhtp8ob********/cc8004q4lbo6********/test.
	StreamName string `protobuf:"bytes,2,opt,name=stream_name,json=streamName,proto3" json:"stream_name,omitempty"`
	// Service account, which has write permission on the stream.
	ServiceAccountId string `protobuf:"bytes,3,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"`
	// contains filtered or unexported fields
}

func (*YdsTarget) Descriptor deprecated 

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

Deprecated: Use YdsTarget.ProtoReflect.Descriptor instead.

func (*YdsTarget) GetDatabase 

func (x *YdsTarget) GetDatabase() string

func (*YdsTarget) GetServiceAccountId 

func (x *YdsTarget) GetServiceAccountId() string

func (*YdsTarget) GetStreamName 

func (x *YdsTarget) GetStreamName() string

func (*YdsTarget) ProtoMessage 

func (*YdsTarget) ProtoMessage()

func (*YdsTarget) ProtoReflect 

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

func (*YdsTarget) Reset 

func (x *YdsTarget) Reset()

func (*YdsTarget) SetDatabase 

func (m *YdsTarget) SetDatabase(v string)

func (*YdsTarget) SetServiceAccountId 

func (m *YdsTarget) SetServiceAccountId(v string)

func (*YdsTarget) SetStreamName 

func (m *YdsTarget) SetStreamName(v string)

func (*YdsTarget) String 

func (x *YdsTarget) String() string

type YmqTarget 

type YmqTarget struct {

	// Queue ARN.
	// Example: yrn:yc:ymq:ru-central1:aoe***:test
	QueueArn string `protobuf:"bytes,1,opt,name=queue_arn,json=queueArn,proto3" json:"queue_arn,omitempty"`
	// Service account which has write access to the queue.
	ServiceAccountId string `protobuf:"bytes,2,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"`
	// contains filtered or unexported fields
}

func (*YmqTarget) Descriptor deprecated 

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

Deprecated: Use YmqTarget.ProtoReflect.Descriptor instead.

func (*YmqTarget) GetQueueArn 

func (x *YmqTarget) GetQueueArn() string

func (*YmqTarget) GetServiceAccountId 

func (x *YmqTarget) GetServiceAccountId() string

func (*YmqTarget) ProtoMessage 

func (*YmqTarget) ProtoMessage()

func (*YmqTarget) ProtoReflect 

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

func (*YmqTarget) Reset 

func (x *YmqTarget) Reset()

func (*YmqTarget) SetQueueArn 

func (m *YmqTarget) SetQueueArn(v string)

func (*YmqTarget) SetServiceAccountId 

func (m *YmqTarget) SetServiceAccountId(v string)

func (*YmqTarget) String 

func (x *YmqTarget) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.