Documentation ¶
Overview ¶
Package connectorv1alpha is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Variables
- func RegisterConnectorServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterConnectorServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ConnectorServiceClient) error
- func RegisterConnectorServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterConnectorServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ConnectorServiceServer) error
- func RegisterConnectorServiceServer(s grpc.ServiceRegistrar, srv ConnectorServiceServer)
- type AdvancedAuth
- func (*AdvancedAuth) Descriptor() ([]byte, []int)deprecated
- func (x *AdvancedAuth) GetAuthFlowType() AdvancedAuth_AuthFlowType
- func (x *AdvancedAuth) GetOauthConfigSpecification() *OauthConfigSpecification
- func (x *AdvancedAuth) GetPredicateKey() []string
- func (x *AdvancedAuth) GetPredicateValue() string
- func (*AdvancedAuth) ProtoMessage()
- func (x *AdvancedAuth) ProtoReflect() protoreflect.Message
- func (x *AdvancedAuth) Reset()
- func (x *AdvancedAuth) String() string
- type AdvancedAuth_AuthFlowType
- func (AdvancedAuth_AuthFlowType) Descriptor() protoreflect.EnumDescriptor
- func (x AdvancedAuth_AuthFlowType) Enum() *AdvancedAuth_AuthFlowType
- func (AdvancedAuth_AuthFlowType) EnumDescriptor() ([]byte, []int)deprecated
- func (x AdvancedAuth_AuthFlowType) Number() protoreflect.EnumNumber
- func (x AdvancedAuth_AuthFlowType) String() string
- func (AdvancedAuth_AuthFlowType) Type() protoreflect.EnumType
- type ConnectDestinationConnectorRequest
- func (*ConnectDestinationConnectorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectDestinationConnectorRequest) GetName() string
- func (*ConnectDestinationConnectorRequest) ProtoMessage()
- func (x *ConnectDestinationConnectorRequest) ProtoReflect() protoreflect.Message
- func (x *ConnectDestinationConnectorRequest) Reset()
- func (x *ConnectDestinationConnectorRequest) String() string
- type ConnectDestinationConnectorResponse
- func (*ConnectDestinationConnectorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectDestinationConnectorResponse) GetDestinationConnector() *DestinationConnector
- func (*ConnectDestinationConnectorResponse) ProtoMessage()
- func (x *ConnectDestinationConnectorResponse) ProtoReflect() protoreflect.Message
- func (x *ConnectDestinationConnectorResponse) Reset()
- func (x *ConnectDestinationConnectorResponse) String() string
- type ConnectSourceConnectorRequest
- func (*ConnectSourceConnectorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectSourceConnectorRequest) GetName() string
- func (*ConnectSourceConnectorRequest) ProtoMessage()
- func (x *ConnectSourceConnectorRequest) ProtoReflect() protoreflect.Message
- func (x *ConnectSourceConnectorRequest) Reset()
- func (x *ConnectSourceConnectorRequest) String() string
- type ConnectSourceConnectorResponse
- func (*ConnectSourceConnectorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectSourceConnectorResponse) GetSourceConnector() *SourceConnector
- func (*ConnectSourceConnectorResponse) ProtoMessage()
- func (x *ConnectSourceConnectorResponse) ProtoReflect() protoreflect.Message
- func (x *ConnectSourceConnectorResponse) Reset()
- func (x *ConnectSourceConnectorResponse) String() string
- type Connector
- func (*Connector) Descriptor() ([]byte, []int)deprecated
- func (x *Connector) GetConfiguration() *structpb.Struct
- func (x *Connector) GetCreateTime() *timestamppb.Timestamp
- func (x *Connector) GetDescription() string
- func (x *Connector) GetOrg() string
- func (m *Connector) GetOwner() isConnector_Owner
- func (x *Connector) GetState() Connector_State
- func (x *Connector) GetTombstone() bool
- func (x *Connector) GetUpdateTime() *timestamppb.Timestamp
- func (x *Connector) GetUser() string
- func (*Connector) ProtoMessage()
- func (x *Connector) ProtoReflect() protoreflect.Message
- func (x *Connector) Reset()
- func (x *Connector) String() string
- type ConnectorDefinition
- func (*ConnectorDefinition) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectorDefinition) GetCreateTime() *timestamppb.Timestamp
- func (x *ConnectorDefinition) GetCustom() bool
- func (x *ConnectorDefinition) GetDockerImageTag() string
- func (x *ConnectorDefinition) GetDockerRepository() string
- func (x *ConnectorDefinition) GetDocumentationUrl() string
- func (x *ConnectorDefinition) GetIcon() string
- func (x *ConnectorDefinition) GetPublic() bool
- func (x *ConnectorDefinition) GetReleaseDate() *date.Date
- func (x *ConnectorDefinition) GetReleaseStage() ReleaseStage
- func (x *ConnectorDefinition) GetResourceRequirements() *structpb.Struct
- func (x *ConnectorDefinition) GetSpec() *Spec
- func (x *ConnectorDefinition) GetTitle() string
- func (x *ConnectorDefinition) GetTombstone() bool
- func (x *ConnectorDefinition) GetUpdateTime() *timestamppb.Timestamp
- func (*ConnectorDefinition) ProtoMessage()
- func (x *ConnectorDefinition) ProtoReflect() protoreflect.Message
- func (x *ConnectorDefinition) Reset()
- func (x *ConnectorDefinition) String() string
- type ConnectorServiceClient
- type ConnectorServiceServer
- type ConnectorType
- func (ConnectorType) Descriptor() protoreflect.EnumDescriptor
- func (x ConnectorType) Enum() *ConnectorType
- func (ConnectorType) EnumDescriptor() ([]byte, []int)deprecated
- func (x ConnectorType) Number() protoreflect.EnumNumber
- func (x ConnectorType) String() string
- func (ConnectorType) Type() protoreflect.EnumType
- type Connector_Org
- type Connector_State
- func (Connector_State) Descriptor() protoreflect.EnumDescriptor
- func (x Connector_State) Enum() *Connector_State
- func (Connector_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x Connector_State) Number() protoreflect.EnumNumber
- func (x Connector_State) String() string
- func (Connector_State) Type() protoreflect.EnumType
- type Connector_User
- type CreateDestinationConnectorRequest
- func (*CreateDestinationConnectorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateDestinationConnectorRequest) GetDestinationConnector() *DestinationConnector
- func (*CreateDestinationConnectorRequest) ProtoMessage()
- func (x *CreateDestinationConnectorRequest) ProtoReflect() protoreflect.Message
- func (x *CreateDestinationConnectorRequest) Reset()
- func (x *CreateDestinationConnectorRequest) String() string
- type CreateDestinationConnectorResponse
- func (*CreateDestinationConnectorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateDestinationConnectorResponse) GetDestinationConnector() *DestinationConnector
- func (*CreateDestinationConnectorResponse) ProtoMessage()
- func (x *CreateDestinationConnectorResponse) ProtoReflect() protoreflect.Message
- func (x *CreateDestinationConnectorResponse) Reset()
- func (x *CreateDestinationConnectorResponse) String() string
- type CreateSourceConnectorRequest
- func (*CreateSourceConnectorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateSourceConnectorRequest) GetSourceConnector() *SourceConnector
- func (*CreateSourceConnectorRequest) ProtoMessage()
- func (x *CreateSourceConnectorRequest) ProtoReflect() protoreflect.Message
- func (x *CreateSourceConnectorRequest) Reset()
- func (x *CreateSourceConnectorRequest) String() string
- type CreateSourceConnectorResponse
- func (*CreateSourceConnectorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateSourceConnectorResponse) GetSourceConnector() *SourceConnector
- func (*CreateSourceConnectorResponse) ProtoMessage()
- func (x *CreateSourceConnectorResponse) ProtoReflect() protoreflect.Message
- func (x *CreateSourceConnectorResponse) Reset()
- func (x *CreateSourceConnectorResponse) String() string
- type DeleteDestinationConnectorRequest
- func (*DeleteDestinationConnectorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteDestinationConnectorRequest) GetName() string
- func (*DeleteDestinationConnectorRequest) ProtoMessage()
- func (x *DeleteDestinationConnectorRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteDestinationConnectorRequest) Reset()
- func (x *DeleteDestinationConnectorRequest) String() string
- type DeleteDestinationConnectorResponse
- func (*DeleteDestinationConnectorResponse) Descriptor() ([]byte, []int)deprecated
- func (*DeleteDestinationConnectorResponse) ProtoMessage()
- func (x *DeleteDestinationConnectorResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteDestinationConnectorResponse) Reset()
- func (x *DeleteDestinationConnectorResponse) String() string
- type DeleteSourceConnectorRequest
- func (*DeleteSourceConnectorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteSourceConnectorRequest) GetName() string
- func (*DeleteSourceConnectorRequest) ProtoMessage()
- func (x *DeleteSourceConnectorRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteSourceConnectorRequest) Reset()
- func (x *DeleteSourceConnectorRequest) String() string
- type DeleteSourceConnectorResponse
- func (*DeleteSourceConnectorResponse) Descriptor() ([]byte, []int)deprecated
- func (*DeleteSourceConnectorResponse) ProtoMessage()
- func (x *DeleteSourceConnectorResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteSourceConnectorResponse) Reset()
- func (x *DeleteSourceConnectorResponse) String() string
- type DestinationConnector
- func (*DestinationConnector) Descriptor() ([]byte, []int)deprecated
- func (x *DestinationConnector) GetConnector() *Connector
- func (x *DestinationConnector) GetDestinationConnectorDefinition() string
- func (x *DestinationConnector) GetId() string
- func (x *DestinationConnector) GetName() string
- func (x *DestinationConnector) GetUid() string
- func (*DestinationConnector) ProtoMessage()
- func (x *DestinationConnector) ProtoReflect() protoreflect.Message
- func (x *DestinationConnector) Reset()
- func (x *DestinationConnector) String() string
- type DestinationConnectorDefinition
- func (*DestinationConnectorDefinition) Descriptor() ([]byte, []int)deprecated
- func (x *DestinationConnectorDefinition) GetConnectorDefinition() *ConnectorDefinition
- func (x *DestinationConnectorDefinition) GetId() string
- func (x *DestinationConnectorDefinition) GetName() string
- func (x *DestinationConnectorDefinition) GetUid() string
- func (*DestinationConnectorDefinition) ProtoMessage()
- func (x *DestinationConnectorDefinition) ProtoReflect() protoreflect.Message
- func (x *DestinationConnectorDefinition) Reset()
- func (x *DestinationConnectorDefinition) String() string
- type DisconnectDestinationConnectorRequest
- func (*DisconnectDestinationConnectorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DisconnectDestinationConnectorRequest) GetName() string
- func (*DisconnectDestinationConnectorRequest) ProtoMessage()
- func (x *DisconnectDestinationConnectorRequest) ProtoReflect() protoreflect.Message
- func (x *DisconnectDestinationConnectorRequest) Reset()
- func (x *DisconnectDestinationConnectorRequest) String() string
- type DisconnectDestinationConnectorResponse
- func (*DisconnectDestinationConnectorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DisconnectDestinationConnectorResponse) GetDestinationConnector() *DestinationConnector
- func (*DisconnectDestinationConnectorResponse) ProtoMessage()
- func (x *DisconnectDestinationConnectorResponse) ProtoReflect() protoreflect.Message
- func (x *DisconnectDestinationConnectorResponse) Reset()
- func (x *DisconnectDestinationConnectorResponse) String() string
- type DisconnectSourceConnectorRequest
- func (*DisconnectSourceConnectorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DisconnectSourceConnectorRequest) GetName() string
- func (*DisconnectSourceConnectorRequest) ProtoMessage()
- func (x *DisconnectSourceConnectorRequest) ProtoReflect() protoreflect.Message
- func (x *DisconnectSourceConnectorRequest) Reset()
- func (x *DisconnectSourceConnectorRequest) String() string
- type DisconnectSourceConnectorResponse
- func (*DisconnectSourceConnectorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DisconnectSourceConnectorResponse) GetSourceConnector() *SourceConnector
- func (*DisconnectSourceConnectorResponse) ProtoMessage()
- func (x *DisconnectSourceConnectorResponse) ProtoReflect() protoreflect.Message
- func (x *DisconnectSourceConnectorResponse) Reset()
- func (x *DisconnectSourceConnectorResponse) String() string
- type DockerImageSpec
- func (*DockerImageSpec) Descriptor() ([]byte, []int)deprecated
- func (x *DockerImageSpec) GetDockerImage() string
- func (x *DockerImageSpec) GetSpec() *Spec
- func (*DockerImageSpec) ProtoMessage()
- func (x *DockerImageSpec) ProtoReflect() protoreflect.Message
- func (x *DockerImageSpec) Reset()
- func (x *DockerImageSpec) String() string
- type GetDestinationConnectorDefinitionRequest
- func (*GetDestinationConnectorDefinitionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetDestinationConnectorDefinitionRequest) GetName() string
- func (x *GetDestinationConnectorDefinitionRequest) GetView() View
- func (*GetDestinationConnectorDefinitionRequest) ProtoMessage()
- func (x *GetDestinationConnectorDefinitionRequest) ProtoReflect() protoreflect.Message
- func (x *GetDestinationConnectorDefinitionRequest) Reset()
- func (x *GetDestinationConnectorDefinitionRequest) String() string
- type GetDestinationConnectorDefinitionResponse
- func (*GetDestinationConnectorDefinitionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetDestinationConnectorDefinitionResponse) GetDestinationConnectorDefinition() *DestinationConnectorDefinition
- func (*GetDestinationConnectorDefinitionResponse) ProtoMessage()
- func (x *GetDestinationConnectorDefinitionResponse) ProtoReflect() protoreflect.Message
- func (x *GetDestinationConnectorDefinitionResponse) Reset()
- func (x *GetDestinationConnectorDefinitionResponse) String() string
- type GetDestinationConnectorRequest
- func (*GetDestinationConnectorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetDestinationConnectorRequest) GetName() string
- func (x *GetDestinationConnectorRequest) GetView() View
- func (*GetDestinationConnectorRequest) ProtoMessage()
- func (x *GetDestinationConnectorRequest) ProtoReflect() protoreflect.Message
- func (x *GetDestinationConnectorRequest) Reset()
- func (x *GetDestinationConnectorRequest) String() string
- type GetDestinationConnectorResponse
- func (*GetDestinationConnectorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetDestinationConnectorResponse) GetDestinationConnector() *DestinationConnector
- func (*GetDestinationConnectorResponse) ProtoMessage()
- func (x *GetDestinationConnectorResponse) ProtoReflect() protoreflect.Message
- func (x *GetDestinationConnectorResponse) Reset()
- func (x *GetDestinationConnectorResponse) String() string
- type GetSourceConnectorDefinitionRequest
- func (*GetSourceConnectorDefinitionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetSourceConnectorDefinitionRequest) GetName() string
- func (x *GetSourceConnectorDefinitionRequest) GetView() View
- func (*GetSourceConnectorDefinitionRequest) ProtoMessage()
- func (x *GetSourceConnectorDefinitionRequest) ProtoReflect() protoreflect.Message
- func (x *GetSourceConnectorDefinitionRequest) Reset()
- func (x *GetSourceConnectorDefinitionRequest) String() string
- type GetSourceConnectorDefinitionResponse
- func (*GetSourceConnectorDefinitionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetSourceConnectorDefinitionResponse) GetSourceConnectorDefinition() *SourceConnectorDefinition
- func (*GetSourceConnectorDefinitionResponse) ProtoMessage()
- func (x *GetSourceConnectorDefinitionResponse) ProtoReflect() protoreflect.Message
- func (x *GetSourceConnectorDefinitionResponse) Reset()
- func (x *GetSourceConnectorDefinitionResponse) String() string
- type GetSourceConnectorRequest
- func (*GetSourceConnectorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetSourceConnectorRequest) GetName() string
- func (x *GetSourceConnectorRequest) GetView() View
- func (*GetSourceConnectorRequest) ProtoMessage()
- func (x *GetSourceConnectorRequest) ProtoReflect() protoreflect.Message
- func (x *GetSourceConnectorRequest) Reset()
- func (x *GetSourceConnectorRequest) String() string
- type GetSourceConnectorResponse
- func (*GetSourceConnectorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetSourceConnectorResponse) GetSourceConnector() *SourceConnector
- func (*GetSourceConnectorResponse) ProtoMessage()
- func (x *GetSourceConnectorResponse) ProtoReflect() protoreflect.Message
- func (x *GetSourceConnectorResponse) Reset()
- func (x *GetSourceConnectorResponse) String() string
- type ListDestinationConnectorDefinitionRequest
- func (*ListDestinationConnectorDefinitionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListDestinationConnectorDefinitionRequest) GetPageSize() int64
- func (x *ListDestinationConnectorDefinitionRequest) GetPageToken() string
- func (x *ListDestinationConnectorDefinitionRequest) GetView() View
- func (*ListDestinationConnectorDefinitionRequest) ProtoMessage()
- func (x *ListDestinationConnectorDefinitionRequest) ProtoReflect() protoreflect.Message
- func (x *ListDestinationConnectorDefinitionRequest) Reset()
- func (x *ListDestinationConnectorDefinitionRequest) String() string
- type ListDestinationConnectorDefinitionResponse
- func (*ListDestinationConnectorDefinitionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListDestinationConnectorDefinitionResponse) GetDestinationConnectorDefinitions() []*DestinationConnectorDefinition
- func (x *ListDestinationConnectorDefinitionResponse) GetNextPageToken() string
- func (x *ListDestinationConnectorDefinitionResponse) GetTotalSize() int64
- func (*ListDestinationConnectorDefinitionResponse) ProtoMessage()
- func (x *ListDestinationConnectorDefinitionResponse) ProtoReflect() protoreflect.Message
- func (x *ListDestinationConnectorDefinitionResponse) Reset()
- func (x *ListDestinationConnectorDefinitionResponse) String() string
- type ListDestinationConnectorRequest
- func (*ListDestinationConnectorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListDestinationConnectorRequest) GetPageSize() int64
- func (x *ListDestinationConnectorRequest) GetPageToken() string
- func (x *ListDestinationConnectorRequest) GetView() View
- func (*ListDestinationConnectorRequest) ProtoMessage()
- func (x *ListDestinationConnectorRequest) ProtoReflect() protoreflect.Message
- func (x *ListDestinationConnectorRequest) Reset()
- func (x *ListDestinationConnectorRequest) String() string
- type ListDestinationConnectorResponse
- func (*ListDestinationConnectorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListDestinationConnectorResponse) GetDestinationConnectors() []*DestinationConnector
- func (x *ListDestinationConnectorResponse) GetNextPageToken() string
- func (x *ListDestinationConnectorResponse) GetTotalSize() int64
- func (*ListDestinationConnectorResponse) ProtoMessage()
- func (x *ListDestinationConnectorResponse) ProtoReflect() protoreflect.Message
- func (x *ListDestinationConnectorResponse) Reset()
- func (x *ListDestinationConnectorResponse) String() string
- type ListSourceConnectorDefinitionRequest
- func (*ListSourceConnectorDefinitionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListSourceConnectorDefinitionRequest) GetPageSize() int64
- func (x *ListSourceConnectorDefinitionRequest) GetPageToken() string
- func (x *ListSourceConnectorDefinitionRequest) GetView() View
- func (*ListSourceConnectorDefinitionRequest) ProtoMessage()
- func (x *ListSourceConnectorDefinitionRequest) ProtoReflect() protoreflect.Message
- func (x *ListSourceConnectorDefinitionRequest) Reset()
- func (x *ListSourceConnectorDefinitionRequest) String() string
- type ListSourceConnectorDefinitionResponse
- func (*ListSourceConnectorDefinitionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListSourceConnectorDefinitionResponse) GetNextPageToken() string
- func (x *ListSourceConnectorDefinitionResponse) GetSourceConnectorDefinitions() []*SourceConnectorDefinition
- func (x *ListSourceConnectorDefinitionResponse) GetTotalSize() int64
- func (*ListSourceConnectorDefinitionResponse) ProtoMessage()
- func (x *ListSourceConnectorDefinitionResponse) ProtoReflect() protoreflect.Message
- func (x *ListSourceConnectorDefinitionResponse) Reset()
- func (x *ListSourceConnectorDefinitionResponse) String() string
- type ListSourceConnectorRequest
- func (*ListSourceConnectorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListSourceConnectorRequest) GetPageSize() int64
- func (x *ListSourceConnectorRequest) GetPageToken() string
- func (x *ListSourceConnectorRequest) GetView() View
- func (*ListSourceConnectorRequest) ProtoMessage()
- func (x *ListSourceConnectorRequest) ProtoReflect() protoreflect.Message
- func (x *ListSourceConnectorRequest) Reset()
- func (x *ListSourceConnectorRequest) String() string
- type ListSourceConnectorResponse
- func (*ListSourceConnectorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListSourceConnectorResponse) GetNextPageToken() string
- func (x *ListSourceConnectorResponse) GetSourceConnectors() []*SourceConnector
- func (x *ListSourceConnectorResponse) GetTotalSize() int64
- func (*ListSourceConnectorResponse) ProtoMessage()
- func (x *ListSourceConnectorResponse) ProtoReflect() protoreflect.Message
- func (x *ListSourceConnectorResponse) Reset()
- func (x *ListSourceConnectorResponse) String() string
- type LivenessRequest
- func (*LivenessRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LivenessRequest) GetHealthCheckRequest() *v1alpha.HealthCheckRequest
- func (*LivenessRequest) ProtoMessage()
- func (x *LivenessRequest) ProtoReflect() protoreflect.Message
- func (x *LivenessRequest) Reset()
- func (x *LivenessRequest) String() string
- type LivenessResponse
- func (*LivenessResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LivenessResponse) GetHealthCheckResponse() *v1alpha.HealthCheckResponse
- func (*LivenessResponse) ProtoMessage()
- func (x *LivenessResponse) ProtoReflect() protoreflect.Message
- func (x *LivenessResponse) Reset()
- func (x *LivenessResponse) String() string
- type LookUpDestinationConnectorRequest
- func (*LookUpDestinationConnectorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LookUpDestinationConnectorRequest) GetPermalink() string
- func (x *LookUpDestinationConnectorRequest) GetView() View
- func (*LookUpDestinationConnectorRequest) ProtoMessage()
- func (x *LookUpDestinationConnectorRequest) ProtoReflect() protoreflect.Message
- func (x *LookUpDestinationConnectorRequest) Reset()
- func (x *LookUpDestinationConnectorRequest) String() string
- type LookUpDestinationConnectorResponse
- func (*LookUpDestinationConnectorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LookUpDestinationConnectorResponse) GetDestinationConnector() *DestinationConnector
- func (*LookUpDestinationConnectorResponse) ProtoMessage()
- func (x *LookUpDestinationConnectorResponse) ProtoReflect() protoreflect.Message
- func (x *LookUpDestinationConnectorResponse) Reset()
- func (x *LookUpDestinationConnectorResponse) String() string
- type LookUpSourceConnectorRequest
- func (*LookUpSourceConnectorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LookUpSourceConnectorRequest) GetPermalink() string
- func (x *LookUpSourceConnectorRequest) GetView() View
- func (*LookUpSourceConnectorRequest) ProtoMessage()
- func (x *LookUpSourceConnectorRequest) ProtoReflect() protoreflect.Message
- func (x *LookUpSourceConnectorRequest) Reset()
- func (x *LookUpSourceConnectorRequest) String() string
- type LookUpSourceConnectorResponse
- func (*LookUpSourceConnectorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LookUpSourceConnectorResponse) GetSourceConnector() *SourceConnector
- func (*LookUpSourceConnectorResponse) ProtoMessage()
- func (x *LookUpSourceConnectorResponse) ProtoReflect() protoreflect.Message
- func (x *LookUpSourceConnectorResponse) Reset()
- func (x *LookUpSourceConnectorResponse) String() string
- type OauthConfigSpecification
- func (*OauthConfigSpecification) Descriptor() ([]byte, []int)deprecated
- func (x *OauthConfigSpecification) GetCompleteOauthOutputSpecification() *structpb.Struct
- func (x *OauthConfigSpecification) GetCompleteOauthServerInputSpecification() *structpb.Struct
- func (x *OauthConfigSpecification) GetCompleteOauthServerOutputSpecification() *structpb.Struct
- func (x *OauthConfigSpecification) GetOauthUserInputFromConnectorConfigSpecification() *structpb.Struct
- func (*OauthConfigSpecification) ProtoMessage()
- func (x *OauthConfigSpecification) ProtoReflect() protoreflect.Message
- func (x *OauthConfigSpecification) Reset()
- func (x *OauthConfigSpecification) String() string
- type ReadSourceConnectorRequest
- func (*ReadSourceConnectorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReadSourceConnectorRequest) GetName() string
- func (*ReadSourceConnectorRequest) ProtoMessage()
- func (x *ReadSourceConnectorRequest) ProtoReflect() protoreflect.Message
- func (x *ReadSourceConnectorRequest) Reset()
- func (x *ReadSourceConnectorRequest) String() string
- type ReadSourceConnectorResponse
- func (*ReadSourceConnectorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReadSourceConnectorResponse) GetData() []byte
- func (*ReadSourceConnectorResponse) ProtoMessage()
- func (x *ReadSourceConnectorResponse) ProtoReflect() protoreflect.Message
- func (x *ReadSourceConnectorResponse) Reset()
- func (x *ReadSourceConnectorResponse) String() string
- type ReadinessRequest
- func (*ReadinessRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReadinessRequest) GetHealthCheckRequest() *v1alpha.HealthCheckRequest
- func (*ReadinessRequest) ProtoMessage()
- func (x *ReadinessRequest) ProtoReflect() protoreflect.Message
- func (x *ReadinessRequest) Reset()
- func (x *ReadinessRequest) String() string
- type ReadinessResponse
- func (*ReadinessResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReadinessResponse) GetHealthCheckResponse() *v1alpha.HealthCheckResponse
- func (*ReadinessResponse) ProtoMessage()
- func (x *ReadinessResponse) ProtoReflect() protoreflect.Message
- func (x *ReadinessResponse) Reset()
- func (x *ReadinessResponse) String() string
- type ReleaseStage
- func (ReleaseStage) Descriptor() protoreflect.EnumDescriptor
- func (x ReleaseStage) Enum() *ReleaseStage
- func (ReleaseStage) EnumDescriptor() ([]byte, []int)deprecated
- func (x ReleaseStage) Number() protoreflect.EnumNumber
- func (x ReleaseStage) String() string
- func (ReleaseStage) Type() protoreflect.EnumType
- type RenameDestinationConnectorRequest
- func (*RenameDestinationConnectorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RenameDestinationConnectorRequest) GetName() string
- func (x *RenameDestinationConnectorRequest) GetNewDestinationConnectorId() string
- func (*RenameDestinationConnectorRequest) ProtoMessage()
- func (x *RenameDestinationConnectorRequest) ProtoReflect() protoreflect.Message
- func (x *RenameDestinationConnectorRequest) Reset()
- func (x *RenameDestinationConnectorRequest) String() string
- type RenameDestinationConnectorResponse
- func (*RenameDestinationConnectorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RenameDestinationConnectorResponse) GetDestinationConnector() *DestinationConnector
- func (*RenameDestinationConnectorResponse) ProtoMessage()
- func (x *RenameDestinationConnectorResponse) ProtoReflect() protoreflect.Message
- func (x *RenameDestinationConnectorResponse) Reset()
- func (x *RenameDestinationConnectorResponse) String() string
- type RenameSourceConnectorRequest
- func (*RenameSourceConnectorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RenameSourceConnectorRequest) GetName() string
- func (x *RenameSourceConnectorRequest) GetNewSourceConnectorId() string
- func (*RenameSourceConnectorRequest) ProtoMessage()
- func (x *RenameSourceConnectorRequest) ProtoReflect() protoreflect.Message
- func (x *RenameSourceConnectorRequest) Reset()
- func (x *RenameSourceConnectorRequest) String() string
- type RenameSourceConnectorResponse
- func (*RenameSourceConnectorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RenameSourceConnectorResponse) GetSourceConnector() *SourceConnector
- func (*RenameSourceConnectorResponse) ProtoMessage()
- func (x *RenameSourceConnectorResponse) ProtoReflect() protoreflect.Message
- func (x *RenameSourceConnectorResponse) Reset()
- func (x *RenameSourceConnectorResponse) String() string
- type SourceConnector
- func (*SourceConnector) Descriptor() ([]byte, []int)deprecated
- func (x *SourceConnector) GetConnector() *Connector
- func (x *SourceConnector) GetId() string
- func (x *SourceConnector) GetName() string
- func (x *SourceConnector) GetSourceConnectorDefinition() string
- func (x *SourceConnector) GetUid() string
- func (*SourceConnector) ProtoMessage()
- func (x *SourceConnector) ProtoReflect() protoreflect.Message
- func (x *SourceConnector) Reset()
- func (x *SourceConnector) String() string
- type SourceConnectorDefinition
- func (*SourceConnectorDefinition) Descriptor() ([]byte, []int)deprecated
- func (x *SourceConnectorDefinition) GetConnectorDefinition() *ConnectorDefinition
- func (x *SourceConnectorDefinition) GetId() string
- func (x *SourceConnectorDefinition) GetName() string
- func (x *SourceConnectorDefinition) GetUid() string
- func (*SourceConnectorDefinition) ProtoMessage()
- func (x *SourceConnectorDefinition) ProtoReflect() protoreflect.Message
- func (x *SourceConnectorDefinition) Reset()
- func (x *SourceConnectorDefinition) String() string
- type Spec
- func (*Spec) Descriptor() ([]byte, []int)deprecated
- func (x *Spec) GetAdvancedAuth() *AdvancedAuth
- func (x *Spec) GetConnectionSpecification() *structpb.Struct
- func (x *Spec) GetDocumentationUrl() string
- func (x *Spec) GetSupportedDestinationSyncModes() []SupportedDestinationSyncModes
- func (x *Spec) GetSupportsDbt() bool
- func (x *Spec) GetSupportsIncremental() bool
- func (x *Spec) GetSupportsNormalization() bool
- func (*Spec) ProtoMessage()
- func (x *Spec) ProtoReflect() protoreflect.Message
- func (x *Spec) Reset()
- func (x *Spec) String() string
- type SupportedDestinationSyncModes
- func (SupportedDestinationSyncModes) Descriptor() protoreflect.EnumDescriptor
- func (x SupportedDestinationSyncModes) Enum() *SupportedDestinationSyncModes
- func (SupportedDestinationSyncModes) EnumDescriptor() ([]byte, []int)deprecated
- func (x SupportedDestinationSyncModes) Number() protoreflect.EnumNumber
- func (x SupportedDestinationSyncModes) String() string
- func (SupportedDestinationSyncModes) Type() protoreflect.EnumType
- type SupportedSyncModes
- func (SupportedSyncModes) Descriptor() protoreflect.EnumDescriptor
- func (x SupportedSyncModes) Enum() *SupportedSyncModes
- func (SupportedSyncModes) EnumDescriptor() ([]byte, []int)deprecated
- func (x SupportedSyncModes) Number() protoreflect.EnumNumber
- func (x SupportedSyncModes) String() string
- func (SupportedSyncModes) Type() protoreflect.EnumType
- type UnimplementedConnectorServiceServer
- func (UnimplementedConnectorServiceServer) ConnectDestinationConnector(context.Context, *ConnectDestinationConnectorRequest) (*ConnectDestinationConnectorResponse, error)
- func (UnimplementedConnectorServiceServer) ConnectSourceConnector(context.Context, *ConnectSourceConnectorRequest) (*ConnectSourceConnectorResponse, error)
- func (UnimplementedConnectorServiceServer) CreateDestinationConnector(context.Context, *CreateDestinationConnectorRequest) (*CreateDestinationConnectorResponse, error)
- func (UnimplementedConnectorServiceServer) CreateSourceConnector(context.Context, *CreateSourceConnectorRequest) (*CreateSourceConnectorResponse, error)
- func (UnimplementedConnectorServiceServer) DeleteDestinationConnector(context.Context, *DeleteDestinationConnectorRequest) (*DeleteDestinationConnectorResponse, error)
- func (UnimplementedConnectorServiceServer) DeleteSourceConnector(context.Context, *DeleteSourceConnectorRequest) (*DeleteSourceConnectorResponse, error)
- func (UnimplementedConnectorServiceServer) DisconnectDestinationConnector(context.Context, *DisconnectDestinationConnectorRequest) (*DisconnectDestinationConnectorResponse, error)
- func (UnimplementedConnectorServiceServer) DisconnectSourceConnector(context.Context, *DisconnectSourceConnectorRequest) (*DisconnectSourceConnectorResponse, error)
- func (UnimplementedConnectorServiceServer) GetDestinationConnector(context.Context, *GetDestinationConnectorRequest) (*GetDestinationConnectorResponse, error)
- func (UnimplementedConnectorServiceServer) GetDestinationConnectorDefinition(context.Context, *GetDestinationConnectorDefinitionRequest) (*GetDestinationConnectorDefinitionResponse, error)
- func (UnimplementedConnectorServiceServer) GetSourceConnector(context.Context, *GetSourceConnectorRequest) (*GetSourceConnectorResponse, error)
- func (UnimplementedConnectorServiceServer) GetSourceConnectorDefinition(context.Context, *GetSourceConnectorDefinitionRequest) (*GetSourceConnectorDefinitionResponse, error)
- func (UnimplementedConnectorServiceServer) ListDestinationConnector(context.Context, *ListDestinationConnectorRequest) (*ListDestinationConnectorResponse, error)
- func (UnimplementedConnectorServiceServer) ListDestinationConnectorDefinition(context.Context, *ListDestinationConnectorDefinitionRequest) (*ListDestinationConnectorDefinitionResponse, error)
- func (UnimplementedConnectorServiceServer) ListSourceConnector(context.Context, *ListSourceConnectorRequest) (*ListSourceConnectorResponse, error)
- func (UnimplementedConnectorServiceServer) ListSourceConnectorDefinition(context.Context, *ListSourceConnectorDefinitionRequest) (*ListSourceConnectorDefinitionResponse, error)
- func (UnimplementedConnectorServiceServer) Liveness(context.Context, *LivenessRequest) (*LivenessResponse, error)
- func (UnimplementedConnectorServiceServer) LookUpDestinationConnector(context.Context, *LookUpDestinationConnectorRequest) (*LookUpDestinationConnectorResponse, error)
- func (UnimplementedConnectorServiceServer) LookUpSourceConnector(context.Context, *LookUpSourceConnectorRequest) (*LookUpSourceConnectorResponse, error)
- func (UnimplementedConnectorServiceServer) ReadSourceConnector(context.Context, *ReadSourceConnectorRequest) (*ReadSourceConnectorResponse, error)
- func (UnimplementedConnectorServiceServer) Readiness(context.Context, *ReadinessRequest) (*ReadinessResponse, error)
- func (UnimplementedConnectorServiceServer) RenameDestinationConnector(context.Context, *RenameDestinationConnectorRequest) (*RenameDestinationConnectorResponse, error)
- func (UnimplementedConnectorServiceServer) RenameSourceConnector(context.Context, *RenameSourceConnectorRequest) (*RenameSourceConnectorResponse, error)
- func (UnimplementedConnectorServiceServer) UpdateDestinationConnector(context.Context, *UpdateDestinationConnectorRequest) (*UpdateDestinationConnectorResponse, error)
- func (UnimplementedConnectorServiceServer) UpdateSourceConnector(context.Context, *UpdateSourceConnectorRequest) (*UpdateSourceConnectorResponse, error)
- func (UnimplementedConnectorServiceServer) WriteDestinationConnector(context.Context, *WriteDestinationConnectorRequest) (*WriteDestinationConnectorResponse, error)
- type UnsafeConnectorServiceServer
- type UpdateDestinationConnectorRequest
- func (*UpdateDestinationConnectorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateDestinationConnectorRequest) GetDestinationConnector() *DestinationConnector
- func (x *UpdateDestinationConnectorRequest) GetUpdateMask() *fieldmaskpb.FieldMask
- func (*UpdateDestinationConnectorRequest) ProtoMessage()
- func (x *UpdateDestinationConnectorRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateDestinationConnectorRequest) Reset()
- func (x *UpdateDestinationConnectorRequest) String() string
- type UpdateDestinationConnectorResponse
- func (*UpdateDestinationConnectorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateDestinationConnectorResponse) GetDestinationConnector() *DestinationConnector
- func (*UpdateDestinationConnectorResponse) ProtoMessage()
- func (x *UpdateDestinationConnectorResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateDestinationConnectorResponse) Reset()
- func (x *UpdateDestinationConnectorResponse) String() string
- type UpdateSourceConnectorRequest
- func (*UpdateSourceConnectorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateSourceConnectorRequest) GetSourceConnector() *SourceConnector
- func (x *UpdateSourceConnectorRequest) GetUpdateMask() *fieldmaskpb.FieldMask
- func (*UpdateSourceConnectorRequest) ProtoMessage()
- func (x *UpdateSourceConnectorRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateSourceConnectorRequest) Reset()
- func (x *UpdateSourceConnectorRequest) String() string
- type UpdateSourceConnectorResponse
- func (*UpdateSourceConnectorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateSourceConnectorResponse) GetSourceConnector() *SourceConnector
- func (*UpdateSourceConnectorResponse) ProtoMessage()
- func (x *UpdateSourceConnectorResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateSourceConnectorResponse) Reset()
- func (x *UpdateSourceConnectorResponse) String() string
- type View
- type WriteDestinationConnectorRequest
- func (*WriteDestinationConnectorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WriteDestinationConnectorRequest) GetDataMappingIndices() []string
- func (x *WriteDestinationConnectorRequest) GetDestinationSyncMode() SupportedDestinationSyncModes
- func (x *WriteDestinationConnectorRequest) GetModelInstanceOutputs() []*v1alpha.ModelInstanceOutput
- func (x *WriteDestinationConnectorRequest) GetName() string
- func (x *WriteDestinationConnectorRequest) GetPipeline() string
- func (x *WriteDestinationConnectorRequest) GetRecipe() *v1alpha.Recipe
- func (x *WriteDestinationConnectorRequest) GetSyncMode() SupportedSyncModes
- func (*WriteDestinationConnectorRequest) ProtoMessage()
- func (x *WriteDestinationConnectorRequest) ProtoReflect() protoreflect.Message
- func (x *WriteDestinationConnectorRequest) Reset()
- func (x *WriteDestinationConnectorRequest) String() string
- type WriteDestinationConnectorResponse
- func (*WriteDestinationConnectorResponse) Descriptor() ([]byte, []int)deprecated
- func (*WriteDestinationConnectorResponse) ProtoMessage()
- func (x *WriteDestinationConnectorResponse) ProtoReflect() protoreflect.Message
- func (x *WriteDestinationConnectorResponse) Reset()
- func (x *WriteDestinationConnectorResponse) String() string
Constants ¶
This section is empty.
Variables ¶
var ( AdvancedAuth_AuthFlowType_name = map[int32]string{ 0: "AUTH_FLOW_TYPE_UNSPECIFIED", 1: "AUTH_FLOW_TYPE_OAUTH2_0", 2: "AUTH_FLOW_TYPE_OAUTH1_0", } AdvancedAuth_AuthFlowType_value = map[string]int32{ "AUTH_FLOW_TYPE_UNSPECIFIED": 0, "AUTH_FLOW_TYPE_OAUTH2_0": 1, "AUTH_FLOW_TYPE_OAUTH1_0": 2, } )
Enum value maps for AdvancedAuth_AuthFlowType.
var ( Connector_State_name = map[int32]string{ 0: "STATE_UNSPECIFIED", 1: "STATE_DISCONNECTED", 2: "STATE_CONNECTED", 3: "STATE_ERROR", } Connector_State_value = map[string]int32{ "STATE_UNSPECIFIED": 0, "STATE_DISCONNECTED": 1, "STATE_CONNECTED": 2, "STATE_ERROR": 3, } )
Enum value maps for Connector_State.
var ( View_name = map[int32]string{ 0: "VIEW_UNSPECIFIED", 1: "VIEW_BASIC", 2: "VIEW_FULL", } View_value = map[string]int32{ "VIEW_UNSPECIFIED": 0, "VIEW_BASIC": 1, "VIEW_FULL": 2, } )
Enum value maps for View.
var ( ConnectorType_name = map[int32]string{ 0: "CONNECTOR_TYPE_UNSPECIFIED", 1: "CONNECTOR_TYPE_SOURCE", 2: "CONNECTOR_TYPE_DESTINATION", } ConnectorType_value = map[string]int32{ "CONNECTOR_TYPE_UNSPECIFIED": 0, "CONNECTOR_TYPE_SOURCE": 1, "CONNECTOR_TYPE_DESTINATION": 2, } )
Enum value maps for ConnectorType.
var ( ReleaseStage_name = map[int32]string{ 0: "RELEASE_STAGE_UNSPECIFIED", 1: "RELEASE_STAGE_ALPHA", 2: "RELEASE_STAGE_BETA", 3: "RELEASE_STAGE_GENERALLY_AVAILABLE", 4: "RELEASE_STAGE_CUSTOM", } ReleaseStage_value = map[string]int32{ "RELEASE_STAGE_UNSPECIFIED": 0, "RELEASE_STAGE_ALPHA": 1, "RELEASE_STAGE_BETA": 2, "RELEASE_STAGE_GENERALLY_AVAILABLE": 3, "RELEASE_STAGE_CUSTOM": 4, } )
Enum value maps for ReleaseStage.
var ( SupportedSyncModes_name = map[int32]string{ 0: "SUPPORTED_SYNC_MODES_UNSPECIFIED", 1: "SUPPORTED_SYNC_MODES_FULL_REFRESH", 2: "SUPPORTED_SYNC_MODES_INCREMENTAL", } SupportedSyncModes_value = map[string]int32{ "SUPPORTED_SYNC_MODES_UNSPECIFIED": 0, "SUPPORTED_SYNC_MODES_FULL_REFRESH": 1, "SUPPORTED_SYNC_MODES_INCREMENTAL": 2, } )
Enum value maps for SupportedSyncModes.
var ( SupportedDestinationSyncModes_name = map[int32]string{ 0: "SUPPORTED_DESTINATION_SYNC_MODES_UNSPECIFIED", 1: "SUPPORTED_DESTINATION_SYNC_MODES_APPEND", 2: "SUPPORTED_DESTINATION_SYNC_MODES_OVERWRITE", 3: "SUPPORTED_DESTINATION_SYNC_MODES_APPEND_DEDUP", } SupportedDestinationSyncModes_value = map[string]int32{ "SUPPORTED_DESTINATION_SYNC_MODES_UNSPECIFIED": 0, "SUPPORTED_DESTINATION_SYNC_MODES_APPEND": 1, "SUPPORTED_DESTINATION_SYNC_MODES_OVERWRITE": 2, "SUPPORTED_DESTINATION_SYNC_MODES_APPEND_DEDUP": 3, } )
Enum value maps for SupportedDestinationSyncModes.
var ConnectorService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "vdp.connector.v1alpha.ConnectorService", HandlerType: (*ConnectorServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Liveness", Handler: _ConnectorService_Liveness_Handler, }, { MethodName: "Readiness", Handler: _ConnectorService_Readiness_Handler, }, { MethodName: "ListSourceConnectorDefinition", Handler: _ConnectorService_ListSourceConnectorDefinition_Handler, }, { MethodName: "GetSourceConnectorDefinition", Handler: _ConnectorService_GetSourceConnectorDefinition_Handler, }, { MethodName: "ListDestinationConnectorDefinition", Handler: _ConnectorService_ListDestinationConnectorDefinition_Handler, }, { MethodName: "GetDestinationConnectorDefinition", Handler: _ConnectorService_GetDestinationConnectorDefinition_Handler, }, { MethodName: "CreateSourceConnector", Handler: _ConnectorService_CreateSourceConnector_Handler, }, { MethodName: "ListSourceConnector", Handler: _ConnectorService_ListSourceConnector_Handler, }, { MethodName: "GetSourceConnector", Handler: _ConnectorService_GetSourceConnector_Handler, }, { MethodName: "UpdateSourceConnector", Handler: _ConnectorService_UpdateSourceConnector_Handler, }, { MethodName: "DeleteSourceConnector", Handler: _ConnectorService_DeleteSourceConnector_Handler, }, { MethodName: "LookUpSourceConnector", Handler: _ConnectorService_LookUpSourceConnector_Handler, }, { MethodName: "ConnectSourceConnector", Handler: _ConnectorService_ConnectSourceConnector_Handler, }, { MethodName: "DisconnectSourceConnector", Handler: _ConnectorService_DisconnectSourceConnector_Handler, }, { MethodName: "RenameSourceConnector", Handler: _ConnectorService_RenameSourceConnector_Handler, }, { MethodName: "ReadSourceConnector", Handler: _ConnectorService_ReadSourceConnector_Handler, }, { MethodName: "CreateDestinationConnector", Handler: _ConnectorService_CreateDestinationConnector_Handler, }, { MethodName: "ListDestinationConnector", Handler: _ConnectorService_ListDestinationConnector_Handler, }, { MethodName: "GetDestinationConnector", Handler: _ConnectorService_GetDestinationConnector_Handler, }, { MethodName: "UpdateDestinationConnector", Handler: _ConnectorService_UpdateDestinationConnector_Handler, }, { MethodName: "DeleteDestinationConnector", Handler: _ConnectorService_DeleteDestinationConnector_Handler, }, { MethodName: "LookUpDestinationConnector", Handler: _ConnectorService_LookUpDestinationConnector_Handler, }, { MethodName: "ConnectDestinationConnector", Handler: _ConnectorService_ConnectDestinationConnector_Handler, }, { MethodName: "DisconnectDestinationConnector", Handler: _ConnectorService_DisconnectDestinationConnector_Handler, }, { MethodName: "RenameDestinationConnector", Handler: _ConnectorService_RenameDestinationConnector_Handler, }, { MethodName: "WriteDestinationConnector", Handler: _ConnectorService_WriteDestinationConnector_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "vdp/connector/v1alpha/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)
var File_vdp_connector_v1alpha_auth_proto protoreflect.FileDescriptor
var File_vdp_connector_v1alpha_connector_definition_proto protoreflect.FileDescriptor
var File_vdp_connector_v1alpha_connector_proto protoreflect.FileDescriptor
var File_vdp_connector_v1alpha_connector_service_proto protoreflect.FileDescriptor
var File_vdp_connector_v1alpha_healthcheck_proto protoreflect.FileDescriptor
var File_vdp_connector_v1alpha_spec_proto protoreflect.FileDescriptor
Functions ¶
func RegisterConnectorServiceHandler ¶
func RegisterConnectorServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterConnectorServiceHandler registers the http handlers for service ConnectorService to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterConnectorServiceHandlerClient ¶
func RegisterConnectorServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ConnectorServiceClient) error
RegisterConnectorServiceHandlerClient registers the http handlers for service ConnectorService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ConnectorServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ConnectorServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ConnectorServiceClient" to call the correct interceptors.
func RegisterConnectorServiceHandlerFromEndpoint ¶
func RegisterConnectorServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterConnectorServiceHandlerFromEndpoint is same as RegisterConnectorServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterConnectorServiceHandlerServer ¶
func RegisterConnectorServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ConnectorServiceServer) error
RegisterConnectorServiceHandlerServer registers the http handlers for service ConnectorService to "mux". UnaryRPC :call ConnectorServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterConnectorServiceHandlerFromEndpoint instead.
func RegisterConnectorServiceServer ¶
func RegisterConnectorServiceServer(s grpc.ServiceRegistrar, srv ConnectorServiceServer)
Types ¶
type AdvancedAuth ¶
type AdvancedAuth struct { // AdvancedAuth auth flow type AuthFlowType AdvancedAuth_AuthFlowType `` /* 153-byte string literal not displayed */ // AdvancedAuth predicate key, i.e., the JSON Path to a field in the // connectorSpecification that should exist for the advanced auth to be // applicable PredicateKey []string `protobuf:"bytes,2,rep,name=predicate_key,json=predicateKey,proto3" json:"predicate_key,omitempty"` // AdvancedAuth predicate value, i.e., the value of the predicate key fields // for the advanced auth to be applicable PredicateValue string `protobuf:"bytes,3,opt,name=predicate_value,json=predicateValue,proto3" json:"predicate_value,omitempty"` // OauthConfigSpecification represents OAuth config specification OauthConfigSpecification *OauthConfigSpecification `` /* 135-byte string literal not displayed */ // contains filtered or unexported fields }
Additional and optional specification object to describe what an 'advanced' Auth flow would need to function. - A connector should be able to fully function with the configuration as described by the ConnectorSpecification in a 'basic' mode. - The 'advanced' mode provides easier UX for the user with UI improvements and automations. However, this requires further setup on the server side by instance or workspace admins beforehand. The trade-off is that the user does not have to provide as many technical inputs anymore and the auth process is faster and easier to complete.
func (*AdvancedAuth) Descriptor
deprecated
func (*AdvancedAuth) Descriptor() ([]byte, []int)
Deprecated: Use AdvancedAuth.ProtoReflect.Descriptor instead.
func (*AdvancedAuth) GetAuthFlowType ¶
func (x *AdvancedAuth) GetAuthFlowType() AdvancedAuth_AuthFlowType
func (*AdvancedAuth) GetOauthConfigSpecification ¶
func (x *AdvancedAuth) GetOauthConfigSpecification() *OauthConfigSpecification
func (*AdvancedAuth) GetPredicateKey ¶
func (x *AdvancedAuth) GetPredicateKey() []string
func (*AdvancedAuth) GetPredicateValue ¶
func (x *AdvancedAuth) GetPredicateValue() string
func (*AdvancedAuth) ProtoMessage ¶
func (*AdvancedAuth) ProtoMessage()
func (*AdvancedAuth) ProtoReflect ¶
func (x *AdvancedAuth) ProtoReflect() protoreflect.Message
func (*AdvancedAuth) Reset ¶
func (x *AdvancedAuth) Reset()
func (*AdvancedAuth) String ¶
func (x *AdvancedAuth) String() string
type AdvancedAuth_AuthFlowType ¶
type AdvancedAuth_AuthFlowType int32
AuthFlowType enumerates the type of auth
const ( // AuthFlowType: AUTH_TYPE_UNSPECIFIED AdvancedAuth_AUTH_FLOW_TYPE_UNSPECIFIED AdvancedAuth_AuthFlowType = 0 // AuthFlowType: AUTH_TYPE_OAUTH2_0 AdvancedAuth_AUTH_FLOW_TYPE_OAUTH2_0 AdvancedAuth_AuthFlowType = 1 // AuthFlowType: AUTH_TYPE_OAUTH1_0 AdvancedAuth_AUTH_FLOW_TYPE_OAUTH1_0 AdvancedAuth_AuthFlowType = 2 )
func (AdvancedAuth_AuthFlowType) Descriptor ¶
func (AdvancedAuth_AuthFlowType) Descriptor() protoreflect.EnumDescriptor
func (AdvancedAuth_AuthFlowType) Enum ¶
func (x AdvancedAuth_AuthFlowType) Enum() *AdvancedAuth_AuthFlowType
func (AdvancedAuth_AuthFlowType) EnumDescriptor
deprecated
func (AdvancedAuth_AuthFlowType) EnumDescriptor() ([]byte, []int)
Deprecated: Use AdvancedAuth_AuthFlowType.Descriptor instead.
func (AdvancedAuth_AuthFlowType) Number ¶
func (x AdvancedAuth_AuthFlowType) Number() protoreflect.EnumNumber
func (AdvancedAuth_AuthFlowType) String ¶
func (x AdvancedAuth_AuthFlowType) String() string
func (AdvancedAuth_AuthFlowType) Type ¶
func (AdvancedAuth_AuthFlowType) Type() protoreflect.EnumType
type ConnectDestinationConnectorRequest ¶
type ConnectDestinationConnectorRequest struct { // DestinationConnector resource name. It must have the format of // "destination-connectors/*" Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
ConnectDestinationConnectorRequest represents a request to connect a destination connector
func (*ConnectDestinationConnectorRequest) Descriptor
deprecated
func (*ConnectDestinationConnectorRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConnectDestinationConnectorRequest.ProtoReflect.Descriptor instead.
func (*ConnectDestinationConnectorRequest) GetName ¶
func (x *ConnectDestinationConnectorRequest) GetName() string
func (*ConnectDestinationConnectorRequest) ProtoMessage ¶
func (*ConnectDestinationConnectorRequest) ProtoMessage()
func (*ConnectDestinationConnectorRequest) ProtoReflect ¶
func (x *ConnectDestinationConnectorRequest) ProtoReflect() protoreflect.Message
func (*ConnectDestinationConnectorRequest) Reset ¶
func (x *ConnectDestinationConnectorRequest) Reset()
func (*ConnectDestinationConnectorRequest) String ¶
func (x *ConnectDestinationConnectorRequest) String() string
type ConnectDestinationConnectorResponse ¶
type ConnectDestinationConnectorResponse struct { // A DestinationConnector resource DestinationConnector *DestinationConnector `protobuf:"bytes,1,opt,name=destination_connector,json=destinationConnector,proto3" json:"destination_connector,omitempty"` // contains filtered or unexported fields }
ConnectDestinationConnectorResponse represents a connected destination connector
func (*ConnectDestinationConnectorResponse) Descriptor
deprecated
func (*ConnectDestinationConnectorResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConnectDestinationConnectorResponse.ProtoReflect.Descriptor instead.
func (*ConnectDestinationConnectorResponse) GetDestinationConnector ¶
func (x *ConnectDestinationConnectorResponse) GetDestinationConnector() *DestinationConnector
func (*ConnectDestinationConnectorResponse) ProtoMessage ¶
func (*ConnectDestinationConnectorResponse) ProtoMessage()
func (*ConnectDestinationConnectorResponse) ProtoReflect ¶
func (x *ConnectDestinationConnectorResponse) ProtoReflect() protoreflect.Message
func (*ConnectDestinationConnectorResponse) Reset ¶
func (x *ConnectDestinationConnectorResponse) Reset()
func (*ConnectDestinationConnectorResponse) String ¶
func (x *ConnectDestinationConnectorResponse) String() string
type ConnectSourceConnectorRequest ¶
type ConnectSourceConnectorRequest struct { // SourceConnector resource name. It must have the format of // "source-connectors/*" Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
ConnectSourceConnectorRequest represents a request to connect a source connector
func (*ConnectSourceConnectorRequest) Descriptor
deprecated
func (*ConnectSourceConnectorRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConnectSourceConnectorRequest.ProtoReflect.Descriptor instead.
func (*ConnectSourceConnectorRequest) GetName ¶
func (x *ConnectSourceConnectorRequest) GetName() string
func (*ConnectSourceConnectorRequest) ProtoMessage ¶
func (*ConnectSourceConnectorRequest) ProtoMessage()
func (*ConnectSourceConnectorRequest) ProtoReflect ¶
func (x *ConnectSourceConnectorRequest) ProtoReflect() protoreflect.Message
func (*ConnectSourceConnectorRequest) Reset ¶
func (x *ConnectSourceConnectorRequest) Reset()
func (*ConnectSourceConnectorRequest) String ¶
func (x *ConnectSourceConnectorRequest) String() string
type ConnectSourceConnectorResponse ¶
type ConnectSourceConnectorResponse struct { // A SourceConnector resource SourceConnector *SourceConnector `protobuf:"bytes,1,opt,name=source_connector,json=sourceConnector,proto3" json:"source_connector,omitempty"` // contains filtered or unexported fields }
ConnectSourceConnectorResponse represents a connected source connector
func (*ConnectSourceConnectorResponse) Descriptor
deprecated
func (*ConnectSourceConnectorResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConnectSourceConnectorResponse.ProtoReflect.Descriptor instead.
func (*ConnectSourceConnectorResponse) GetSourceConnector ¶
func (x *ConnectSourceConnectorResponse) GetSourceConnector() *SourceConnector
func (*ConnectSourceConnectorResponse) ProtoMessage ¶
func (*ConnectSourceConnectorResponse) ProtoMessage()
func (*ConnectSourceConnectorResponse) ProtoReflect ¶
func (x *ConnectSourceConnectorResponse) ProtoReflect() protoreflect.Message
func (*ConnectSourceConnectorResponse) Reset ¶
func (x *ConnectSourceConnectorResponse) Reset()
func (*ConnectSourceConnectorResponse) String ¶
func (x *ConnectSourceConnectorResponse) String() string
type Connector ¶
type Connector struct { // Connector description Description *string `protobuf:"bytes,1,opt,name=description,proto3,oneof" json:"description,omitempty"` // Connector configuration in JSON format Configuration *structpb.Struct `protobuf:"bytes,2,opt,name=configuration,proto3" json:"configuration,omitempty"` // Connector state State Connector_State `protobuf:"varint,3,opt,name=state,proto3,enum=vdp.connector.v1alpha.Connector_State" json:"state,omitempty"` // Connector tombstone Tombstone bool `protobuf:"varint,4,opt,name=tombstone,proto3" json:"tombstone,omitempty"` // Connector owner // // Types that are assignable to Owner: // *Connector_User // *Connector_Org Owner isConnector_Owner `protobuf_oneof:"owner"` // Connector creation time CreateTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` // Connector update time UpdateTime *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"` // contains filtered or unexported fields }
Connector represents a connector data model
func (*Connector) Descriptor
deprecated
func (*Connector) GetConfiguration ¶
func (*Connector) GetCreateTime ¶
func (x *Connector) GetCreateTime() *timestamppb.Timestamp
func (*Connector) GetDescription ¶
func (*Connector) GetState ¶
func (x *Connector) GetState() Connector_State
func (*Connector) GetTombstone ¶
func (*Connector) GetUpdateTime ¶
func (x *Connector) GetUpdateTime() *timestamppb.Timestamp
func (*Connector) ProtoMessage ¶
func (*Connector) ProtoMessage()
func (*Connector) ProtoReflect ¶
func (x *Connector) ProtoReflect() protoreflect.Message
type ConnectorDefinition ¶
type ConnectorDefinition struct { // ConnectorDefinition title Title string `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"` // ConnectorDefinition Docker repository DockerRepository string `protobuf:"bytes,2,opt,name=docker_repository,json=dockerRepository,proto3" json:"docker_repository,omitempty"` // ConnectorDefinition Docker image tag DockerImageTag string `protobuf:"bytes,3,opt,name=docker_image_tag,json=dockerImageTag,proto3" json:"docker_image_tag,omitempty"` // ConnectorDefinition documentation URL DocumentationUrl string `protobuf:"bytes,4,opt,name=documentation_url,json=documentationUrl,proto3" json:"documentation_url,omitempty"` // ConnectorDefinition icon Icon string `protobuf:"bytes,5,opt,name=icon,proto3" json:"icon,omitempty"` // ConnectorDefinition spec Spec *Spec `protobuf:"bytes,6,opt,name=spec,proto3" json:"spec,omitempty"` // ConnectorDefinition tombstone, i.e., if not set or false, the // configuration is active, or otherwise, if true, this configuration is // permanently off Tombstone bool `protobuf:"varint,7,opt,name=tombstone,proto3" json:"tombstone,omitempty"` // ConnectorDefinition public flag, i.e., true if this connector // definition is available to all workspaces Public bool `protobuf:"varint,8,opt,name=public,proto3" json:"public,omitempty"` // ConnectorDefinition custom flag, i.e., whether this is a custom // connector definition Custom bool `protobuf:"varint,9,opt,name=custom,proto3" json:"custom,omitempty"` // ConnectorDefinition release stage ReleaseStage ReleaseStage `` /* 139-byte string literal not displayed */ // ConnectorDefinition release date, i.e., the date when this connector // was first released, in yyyy-mm-dd format. ReleaseDate *date.Date `protobuf:"bytes,11,opt,name=release_date,json=releaseDate,proto3" json:"release_date,omitempty"` // ConnectorDefinition resource requirements ResourceRequirements *structpb.Struct `protobuf:"bytes,12,opt,name=resource_requirements,json=resourceRequirements,proto3" json:"resource_requirements,omitempty"` // ConnectorDefinition creation time CreateTime *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` // ConnectorDefinition update time UpdateTime *timestamppb.Timestamp `protobuf:"bytes,14,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"` // contains filtered or unexported fields }
ConnectorDefinition represents the connector definition data model
func (*ConnectorDefinition) Descriptor
deprecated
func (*ConnectorDefinition) Descriptor() ([]byte, []int)
Deprecated: Use ConnectorDefinition.ProtoReflect.Descriptor instead.
func (*ConnectorDefinition) GetCreateTime ¶
func (x *ConnectorDefinition) GetCreateTime() *timestamppb.Timestamp
func (*ConnectorDefinition) GetCustom ¶
func (x *ConnectorDefinition) GetCustom() bool
func (*ConnectorDefinition) GetDockerImageTag ¶
func (x *ConnectorDefinition) GetDockerImageTag() string
func (*ConnectorDefinition) GetDockerRepository ¶
func (x *ConnectorDefinition) GetDockerRepository() string
func (*ConnectorDefinition) GetDocumentationUrl ¶
func (x *ConnectorDefinition) GetDocumentationUrl() string
func (*ConnectorDefinition) GetIcon ¶
func (x *ConnectorDefinition) GetIcon() string
func (*ConnectorDefinition) GetPublic ¶
func (x *ConnectorDefinition) GetPublic() bool
func (*ConnectorDefinition) GetReleaseDate ¶
func (x *ConnectorDefinition) GetReleaseDate() *date.Date
func (*ConnectorDefinition) GetReleaseStage ¶
func (x *ConnectorDefinition) GetReleaseStage() ReleaseStage
func (*ConnectorDefinition) GetResourceRequirements ¶
func (x *ConnectorDefinition) GetResourceRequirements() *structpb.Struct
func (*ConnectorDefinition) GetSpec ¶
func (x *ConnectorDefinition) GetSpec() *Spec
func (*ConnectorDefinition) GetTitle ¶
func (x *ConnectorDefinition) GetTitle() string
func (*ConnectorDefinition) GetTombstone ¶
func (x *ConnectorDefinition) GetTombstone() bool
func (*ConnectorDefinition) GetUpdateTime ¶
func (x *ConnectorDefinition) GetUpdateTime() *timestamppb.Timestamp
func (*ConnectorDefinition) ProtoMessage ¶
func (*ConnectorDefinition) ProtoMessage()
func (*ConnectorDefinition) ProtoReflect ¶
func (x *ConnectorDefinition) ProtoReflect() protoreflect.Message
func (*ConnectorDefinition) Reset ¶
func (x *ConnectorDefinition) Reset()
func (*ConnectorDefinition) String ¶
func (x *ConnectorDefinition) String() string
type ConnectorServiceClient ¶
type ConnectorServiceClient interface { // Liveness method receives a LivenessRequest message and returns a // LivenessResponse message. // See https://github.com/grpc/grpc/blob/master/doc/health-checking.md Liveness(ctx context.Context, in *LivenessRequest, opts ...grpc.CallOption) (*LivenessResponse, error) // Readiness method receives a ReadinessRequest message and returns a // ReadinessResponse message. // See https://github.com/grpc/grpc/blob/master/doc/health-checking.md Readiness(ctx context.Context, in *ReadinessRequest, opts ...grpc.CallOption) (*ReadinessResponse, error) // ListSourceConnectorDefinition method receives a // ListSourceConnectorDefinitionRequest message and returns a // ListSourceConnectorDefinitionResponse message. ListSourceConnectorDefinition(ctx context.Context, in *ListSourceConnectorDefinitionRequest, opts ...grpc.CallOption) (*ListSourceConnectorDefinitionResponse, error) // GetSourceConnectorDefinition method receives a // GetSourceConnectorDefinitionRequest message and returns a // GetGetSourceConnectorDefinitionResponse message. GetSourceConnectorDefinition(ctx context.Context, in *GetSourceConnectorDefinitionRequest, opts ...grpc.CallOption) (*GetSourceConnectorDefinitionResponse, error) // ListDestinationConnectorDefinition method receives a // ListDestinationConnectorDefinitionRequest message and returns a // ListDestinationConnectorDefinitionResponse message. ListDestinationConnectorDefinition(ctx context.Context, in *ListDestinationConnectorDefinitionRequest, opts ...grpc.CallOption) (*ListDestinationConnectorDefinitionResponse, error) // GetDestinationConnectorDefinition method receives a // GetDestinationConnectorDefinitionRequest message and returns a // GetGetDestinationConnectorDefinitionResponse message. GetDestinationConnectorDefinition(ctx context.Context, in *GetDestinationConnectorDefinitionRequest, opts ...grpc.CallOption) (*GetDestinationConnectorDefinitionResponse, error) // CreateSourceConnector method receives a CreateSourceConnectorRequest // message and returns a CreateSourceConnectorResponse message. CreateSourceConnector(ctx context.Context, in *CreateSourceConnectorRequest, opts ...grpc.CallOption) (*CreateSourceConnectorResponse, error) // ListSourceConnector method receives a ListSourceConnectorRequest message // and returns a ListSourceConnectorResponse message. ListSourceConnector(ctx context.Context, in *ListSourceConnectorRequest, opts ...grpc.CallOption) (*ListSourceConnectorResponse, error) // GetSourceConnector method receives a GetSourceConnectorRequest message and // returns a GetSourceConnectorResponse message. GetSourceConnector(ctx context.Context, in *GetSourceConnectorRequest, opts ...grpc.CallOption) (*GetSourceConnectorResponse, error) // UpdateSourceConnector method receives a UpdateSourceConnectorRequest // message and returns a UpdateSourceConnectorResponse message. UpdateSourceConnector(ctx context.Context, in *UpdateSourceConnectorRequest, opts ...grpc.CallOption) (*UpdateSourceConnectorResponse, error) // DeleteSourceConnector method receives a DeleteSourceConnectorRequest // message and returns a DeleteSourceConnectorResponse message. DeleteSourceConnector(ctx context.Context, in *DeleteSourceConnectorRequest, opts ...grpc.CallOption) (*DeleteSourceConnectorResponse, error) // LookUpSourceConnector method receives a LookUpSourceConnectorRequest // message and returns a LookUpSourceConnectorResponse LookUpSourceConnector(ctx context.Context, in *LookUpSourceConnectorRequest, opts ...grpc.CallOption) (*LookUpSourceConnectorResponse, error) // Connect a source connector. // The "state" of the connector after connecting is "CONNECTED". // ConnectSourceConnector can be called on SourceConnector in the state // `DISCONNECTED`; SourceConnector in a different state (including // `CONNECTED`) returns an error. ConnectSourceConnector(ctx context.Context, in *ConnectSourceConnectorRequest, opts ...grpc.CallOption) (*ConnectSourceConnectorResponse, error) // Disconnect a source connector. // The "state" of the connector after disconnecting is "DISCONNECTED". // DisconnectSourceConnector can be called on SourceConnector in the state // `CONNECTED`; SourceConnector in a different state (including // `DISCONNECTED`) returns an error. DisconnectSourceConnector(ctx context.Context, in *DisconnectSourceConnectorRequest, opts ...grpc.CallOption) (*DisconnectSourceConnectorResponse, error) // RenameSourceConnector method receives a RenameSourceConnectorRequest // message and returns a RenameSourceConnectorResponse message. RenameSourceConnector(ctx context.Context, in *RenameSourceConnectorRequest, opts ...grpc.CallOption) (*RenameSourceConnectorResponse, error) // ReadSourceConnector method receives a ReadSourceConnectorRequest // message and returns a ReadSourceConnectorResponse message. ReadSourceConnector(ctx context.Context, in *ReadSourceConnectorRequest, opts ...grpc.CallOption) (*ReadSourceConnectorResponse, error) // CreateDestinationConnector method receives a // CreateDestinationConnectorRequest message and returns a // CreateDestinationConnectorResponse message. CreateDestinationConnector(ctx context.Context, in *CreateDestinationConnectorRequest, opts ...grpc.CallOption) (*CreateDestinationConnectorResponse, error) // ListDestinationConnector method receives a ListDestinationConnectorRequest // message and returns a ListDestinationConnectorResponse message. ListDestinationConnector(ctx context.Context, in *ListDestinationConnectorRequest, opts ...grpc.CallOption) (*ListDestinationConnectorResponse, error) // GetDestinationConnector method receives a GetDestinationConnectorRequest // message and returns a GetDestinationConnectorResponse message. GetDestinationConnector(ctx context.Context, in *GetDestinationConnectorRequest, opts ...grpc.CallOption) (*GetDestinationConnectorResponse, error) // UpdateDestinationConnector method receives a // UpdateDestinationConnectorRequest message and returns a // UpdateDestinationConnectorResponse message. UpdateDestinationConnector(ctx context.Context, in *UpdateDestinationConnectorRequest, opts ...grpc.CallOption) (*UpdateDestinationConnectorResponse, error) // DeleteDestinationConnector method receives a // DeleteDestinationConnectorRequest message and returns a // DeleteDestinationConnectorResponse message. DeleteDestinationConnector(ctx context.Context, in *DeleteDestinationConnectorRequest, opts ...grpc.CallOption) (*DeleteDestinationConnectorResponse, error) // LookUpDestinationConnector method receives a // LookUpDestinationConnectorRequest message and returns a // LookUpDestinationConnectorResponse LookUpDestinationConnector(ctx context.Context, in *LookUpDestinationConnectorRequest, opts ...grpc.CallOption) (*LookUpDestinationConnectorResponse, error) // Connect a destination connector. // The "state" of the connector after connecting is "CONNECTED". // ConnectDestinationConnector can be called on DestinationConnector in the // state `DISCONNECTED`; DestinationConnector in a different state (including // `CONNECTED`) returns an error. ConnectDestinationConnector(ctx context.Context, in *ConnectDestinationConnectorRequest, opts ...grpc.CallOption) (*ConnectDestinationConnectorResponse, error) // Disconnect a destination connector. // The "state" of the connector after disconnecting is "DISCONNECTED". // DisconnectDestinationConnector can be called on DestinationConnector in the // state `CONNECTED`; DestinationConnector in a different state (including // `DISCONNECTED`) returns an error. DisconnectDestinationConnector(ctx context.Context, in *DisconnectDestinationConnectorRequest, opts ...grpc.CallOption) (*DisconnectDestinationConnectorResponse, error) // RenameDestinationConnector method receives a // RenameDestinationConnectorRequest message and returns a // RenameDestinationConnectorResponse message. RenameDestinationConnector(ctx context.Context, in *RenameDestinationConnectorRequest, opts ...grpc.CallOption) (*RenameDestinationConnectorResponse, error) // WriteDestinationConnector method receives a // WriteDestinationConnectorRequest message and returns a // WriteDestinationConnectorResponse message. WriteDestinationConnector(ctx context.Context, in *WriteDestinationConnectorRequest, opts ...grpc.CallOption) (*WriteDestinationConnectorResponse, 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.
func NewConnectorServiceClient ¶
func NewConnectorServiceClient(cc grpc.ClientConnInterface) ConnectorServiceClient
type ConnectorServiceServer ¶
type ConnectorServiceServer interface { // Liveness method receives a LivenessRequest message and returns a // LivenessResponse message. // See https://github.com/grpc/grpc/blob/master/doc/health-checking.md Liveness(context.Context, *LivenessRequest) (*LivenessResponse, error) // Readiness method receives a ReadinessRequest message and returns a // ReadinessResponse message. // See https://github.com/grpc/grpc/blob/master/doc/health-checking.md Readiness(context.Context, *ReadinessRequest) (*ReadinessResponse, error) // ListSourceConnectorDefinition method receives a // ListSourceConnectorDefinitionRequest message and returns a // ListSourceConnectorDefinitionResponse message. ListSourceConnectorDefinition(context.Context, *ListSourceConnectorDefinitionRequest) (*ListSourceConnectorDefinitionResponse, error) // GetSourceConnectorDefinition method receives a // GetSourceConnectorDefinitionRequest message and returns a // GetGetSourceConnectorDefinitionResponse message. GetSourceConnectorDefinition(context.Context, *GetSourceConnectorDefinitionRequest) (*GetSourceConnectorDefinitionResponse, error) // ListDestinationConnectorDefinition method receives a // ListDestinationConnectorDefinitionRequest message and returns a // ListDestinationConnectorDefinitionResponse message. ListDestinationConnectorDefinition(context.Context, *ListDestinationConnectorDefinitionRequest) (*ListDestinationConnectorDefinitionResponse, error) // GetDestinationConnectorDefinition method receives a // GetDestinationConnectorDefinitionRequest message and returns a // GetGetDestinationConnectorDefinitionResponse message. GetDestinationConnectorDefinition(context.Context, *GetDestinationConnectorDefinitionRequest) (*GetDestinationConnectorDefinitionResponse, error) // CreateSourceConnector method receives a CreateSourceConnectorRequest // message and returns a CreateSourceConnectorResponse message. CreateSourceConnector(context.Context, *CreateSourceConnectorRequest) (*CreateSourceConnectorResponse, error) // ListSourceConnector method receives a ListSourceConnectorRequest message // and returns a ListSourceConnectorResponse message. ListSourceConnector(context.Context, *ListSourceConnectorRequest) (*ListSourceConnectorResponse, error) // GetSourceConnector method receives a GetSourceConnectorRequest message and // returns a GetSourceConnectorResponse message. GetSourceConnector(context.Context, *GetSourceConnectorRequest) (*GetSourceConnectorResponse, error) // UpdateSourceConnector method receives a UpdateSourceConnectorRequest // message and returns a UpdateSourceConnectorResponse message. UpdateSourceConnector(context.Context, *UpdateSourceConnectorRequest) (*UpdateSourceConnectorResponse, error) // DeleteSourceConnector method receives a DeleteSourceConnectorRequest // message and returns a DeleteSourceConnectorResponse message. DeleteSourceConnector(context.Context, *DeleteSourceConnectorRequest) (*DeleteSourceConnectorResponse, error) // LookUpSourceConnector method receives a LookUpSourceConnectorRequest // message and returns a LookUpSourceConnectorResponse LookUpSourceConnector(context.Context, *LookUpSourceConnectorRequest) (*LookUpSourceConnectorResponse, error) // Connect a source connector. // The "state" of the connector after connecting is "CONNECTED". // ConnectSourceConnector can be called on SourceConnector in the state // `DISCONNECTED`; SourceConnector in a different state (including // `CONNECTED`) returns an error. ConnectSourceConnector(context.Context, *ConnectSourceConnectorRequest) (*ConnectSourceConnectorResponse, error) // Disconnect a source connector. // The "state" of the connector after disconnecting is "DISCONNECTED". // DisconnectSourceConnector can be called on SourceConnector in the state // `CONNECTED`; SourceConnector in a different state (including // `DISCONNECTED`) returns an error. DisconnectSourceConnector(context.Context, *DisconnectSourceConnectorRequest) (*DisconnectSourceConnectorResponse, error) // RenameSourceConnector method receives a RenameSourceConnectorRequest // message and returns a RenameSourceConnectorResponse message. RenameSourceConnector(context.Context, *RenameSourceConnectorRequest) (*RenameSourceConnectorResponse, error) // ReadSourceConnector method receives a ReadSourceConnectorRequest // message and returns a ReadSourceConnectorResponse message. ReadSourceConnector(context.Context, *ReadSourceConnectorRequest) (*ReadSourceConnectorResponse, error) // CreateDestinationConnector method receives a // CreateDestinationConnectorRequest message and returns a // CreateDestinationConnectorResponse message. CreateDestinationConnector(context.Context, *CreateDestinationConnectorRequest) (*CreateDestinationConnectorResponse, error) // ListDestinationConnector method receives a ListDestinationConnectorRequest // message and returns a ListDestinationConnectorResponse message. ListDestinationConnector(context.Context, *ListDestinationConnectorRequest) (*ListDestinationConnectorResponse, error) // GetDestinationConnector method receives a GetDestinationConnectorRequest // message and returns a GetDestinationConnectorResponse message. GetDestinationConnector(context.Context, *GetDestinationConnectorRequest) (*GetDestinationConnectorResponse, error) // UpdateDestinationConnector method receives a // UpdateDestinationConnectorRequest message and returns a // UpdateDestinationConnectorResponse message. UpdateDestinationConnector(context.Context, *UpdateDestinationConnectorRequest) (*UpdateDestinationConnectorResponse, error) // DeleteDestinationConnector method receives a // DeleteDestinationConnectorRequest message and returns a // DeleteDestinationConnectorResponse message. DeleteDestinationConnector(context.Context, *DeleteDestinationConnectorRequest) (*DeleteDestinationConnectorResponse, error) // LookUpDestinationConnector method receives a // LookUpDestinationConnectorRequest message and returns a // LookUpDestinationConnectorResponse LookUpDestinationConnector(context.Context, *LookUpDestinationConnectorRequest) (*LookUpDestinationConnectorResponse, error) // Connect a destination connector. // The "state" of the connector after connecting is "CONNECTED". // ConnectDestinationConnector can be called on DestinationConnector in the // state `DISCONNECTED`; DestinationConnector in a different state (including // `CONNECTED`) returns an error. ConnectDestinationConnector(context.Context, *ConnectDestinationConnectorRequest) (*ConnectDestinationConnectorResponse, error) // Disconnect a destination connector. // The "state" of the connector after disconnecting is "DISCONNECTED". // DisconnectDestinationConnector can be called on DestinationConnector in the // state `CONNECTED`; DestinationConnector in a different state (including // `DISCONNECTED`) returns an error. DisconnectDestinationConnector(context.Context, *DisconnectDestinationConnectorRequest) (*DisconnectDestinationConnectorResponse, error) // RenameDestinationConnector method receives a // RenameDestinationConnectorRequest message and returns a // RenameDestinationConnectorResponse message. RenameDestinationConnector(context.Context, *RenameDestinationConnectorRequest) (*RenameDestinationConnectorResponse, error) // WriteDestinationConnector method receives a // WriteDestinationConnectorRequest message and returns a // WriteDestinationConnectorResponse message. WriteDestinationConnector(context.Context, *WriteDestinationConnectorRequest) (*WriteDestinationConnectorResponse, error) }
ConnectorServiceServer is the server API for ConnectorService service. All implementations should embed UnimplementedConnectorServiceServer for forward compatibility
type ConnectorType ¶
type ConnectorType int32
ConnectorType enumerates connector types
const ( // ConnectorType: UNSPECIFIED ConnectorType_CONNECTOR_TYPE_UNSPECIFIED ConnectorType = 0 // ConnectorType: SOURCE ConnectorType_CONNECTOR_TYPE_SOURCE ConnectorType = 1 // ConnectorType: DESTINATION ConnectorType_CONNECTOR_TYPE_DESTINATION ConnectorType = 2 )
func (ConnectorType) Descriptor ¶
func (ConnectorType) Descriptor() protoreflect.EnumDescriptor
func (ConnectorType) Enum ¶
func (x ConnectorType) Enum() *ConnectorType
func (ConnectorType) EnumDescriptor
deprecated
func (ConnectorType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ConnectorType.Descriptor instead.
func (ConnectorType) Number ¶
func (x ConnectorType) Number() protoreflect.EnumNumber
func (ConnectorType) String ¶
func (x ConnectorType) String() string
func (ConnectorType) Type ¶
func (ConnectorType) Type() protoreflect.EnumType
type Connector_Org ¶
type Connector_Org struct { // The resource name of an organization Org string `protobuf:"bytes,6,opt,name=org,proto3,oneof"` }
type Connector_State ¶
type Connector_State int32
State enumerates the connector state
const ( // State: UNSPECIFIED Connector_STATE_UNSPECIFIED Connector_State = 0 // State: DISCONNECTED Connector_STATE_DISCONNECTED Connector_State = 1 // State: CONNECTED Connector_STATE_CONNECTED Connector_State = 2 // State: ERROR Connector_STATE_ERROR Connector_State = 3 )
func (Connector_State) Descriptor ¶
func (Connector_State) Descriptor() protoreflect.EnumDescriptor
func (Connector_State) Enum ¶
func (x Connector_State) Enum() *Connector_State
func (Connector_State) EnumDescriptor
deprecated
func (Connector_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use Connector_State.Descriptor instead.
func (Connector_State) Number ¶
func (x Connector_State) Number() protoreflect.EnumNumber
func (Connector_State) String ¶
func (x Connector_State) String() string
func (Connector_State) Type ¶
func (Connector_State) Type() protoreflect.EnumType
type Connector_User ¶
type Connector_User struct { // The resource name of a user, e.g., "users/local-user". User string `protobuf:"bytes,5,opt,name=user,proto3,oneof"` }
type CreateDestinationConnectorRequest ¶
type CreateDestinationConnectorRequest struct { // DestinationConnector resource DestinationConnector *DestinationConnector `protobuf:"bytes,1,opt,name=destination_connector,json=destinationConnector,proto3" json:"destination_connector,omitempty"` // contains filtered or unexported fields }
DestinationConnector
CreateDestinationConnectorRequest represents a request to create a DestinationConnector resource
func (*CreateDestinationConnectorRequest) Descriptor
deprecated
func (*CreateDestinationConnectorRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateDestinationConnectorRequest.ProtoReflect.Descriptor instead.
func (*CreateDestinationConnectorRequest) GetDestinationConnector ¶
func (x *CreateDestinationConnectorRequest) GetDestinationConnector() *DestinationConnector
func (*CreateDestinationConnectorRequest) ProtoMessage ¶
func (*CreateDestinationConnectorRequest) ProtoMessage()
func (*CreateDestinationConnectorRequest) ProtoReflect ¶
func (x *CreateDestinationConnectorRequest) ProtoReflect() protoreflect.Message
func (*CreateDestinationConnectorRequest) Reset ¶
func (x *CreateDestinationConnectorRequest) Reset()
func (*CreateDestinationConnectorRequest) String ¶
func (x *CreateDestinationConnectorRequest) String() string
type CreateDestinationConnectorResponse ¶
type CreateDestinationConnectorResponse struct { // DestinationConnector resource DestinationConnector *DestinationConnector `protobuf:"bytes,1,opt,name=destination_connector,json=destinationConnector,proto3" json:"destination_connector,omitempty"` // contains filtered or unexported fields }
CreateDestinationConnectorResponse represents a response for a DestinationConnector resource
func (*CreateDestinationConnectorResponse) Descriptor
deprecated
func (*CreateDestinationConnectorResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateDestinationConnectorResponse.ProtoReflect.Descriptor instead.
func (*CreateDestinationConnectorResponse) GetDestinationConnector ¶
func (x *CreateDestinationConnectorResponse) GetDestinationConnector() *DestinationConnector
func (*CreateDestinationConnectorResponse) ProtoMessage ¶
func (*CreateDestinationConnectorResponse) ProtoMessage()
func (*CreateDestinationConnectorResponse) ProtoReflect ¶
func (x *CreateDestinationConnectorResponse) ProtoReflect() protoreflect.Message
func (*CreateDestinationConnectorResponse) Reset ¶
func (x *CreateDestinationConnectorResponse) Reset()
func (*CreateDestinationConnectorResponse) String ¶
func (x *CreateDestinationConnectorResponse) String() string
type CreateSourceConnectorRequest ¶
type CreateSourceConnectorRequest struct { // SourceConnector resource SourceConnector *SourceConnector `protobuf:"bytes,1,opt,name=source_connector,json=sourceConnector,proto3" json:"source_connector,omitempty"` // contains filtered or unexported fields }
SourceConnector
CreateSourceConnectorRequest represents a request to create a SourceConnector resource
func (*CreateSourceConnectorRequest) Descriptor
deprecated
func (*CreateSourceConnectorRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateSourceConnectorRequest.ProtoReflect.Descriptor instead.
func (*CreateSourceConnectorRequest) GetSourceConnector ¶
func (x *CreateSourceConnectorRequest) GetSourceConnector() *SourceConnector
func (*CreateSourceConnectorRequest) ProtoMessage ¶
func (*CreateSourceConnectorRequest) ProtoMessage()
func (*CreateSourceConnectorRequest) ProtoReflect ¶
func (x *CreateSourceConnectorRequest) ProtoReflect() protoreflect.Message
func (*CreateSourceConnectorRequest) Reset ¶
func (x *CreateSourceConnectorRequest) Reset()
func (*CreateSourceConnectorRequest) String ¶
func (x *CreateSourceConnectorRequest) String() string
type CreateSourceConnectorResponse ¶
type CreateSourceConnectorResponse struct { // SourceConnector resource SourceConnector *SourceConnector `protobuf:"bytes,1,opt,name=source_connector,json=sourceConnector,proto3" json:"source_connector,omitempty"` // contains filtered or unexported fields }
CreateSourceConnectorResponse represents a response for a SourceConnector resource
func (*CreateSourceConnectorResponse) Descriptor
deprecated
func (*CreateSourceConnectorResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateSourceConnectorResponse.ProtoReflect.Descriptor instead.
func (*CreateSourceConnectorResponse) GetSourceConnector ¶
func (x *CreateSourceConnectorResponse) GetSourceConnector() *SourceConnector
func (*CreateSourceConnectorResponse) ProtoMessage ¶
func (*CreateSourceConnectorResponse) ProtoMessage()
func (*CreateSourceConnectorResponse) ProtoReflect ¶
func (x *CreateSourceConnectorResponse) ProtoReflect() protoreflect.Message
func (*CreateSourceConnectorResponse) Reset ¶
func (x *CreateSourceConnectorResponse) Reset()
func (*CreateSourceConnectorResponse) String ¶
func (x *CreateSourceConnectorResponse) String() string
type DeleteDestinationConnectorRequest ¶
type DeleteDestinationConnectorRequest struct { // DestinationConnector resource name. It must have the format of // "destination-connectors/*" Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
DeleteDestinationConnectorRequest represents a request to delete a DestinationConnector resource
func (*DeleteDestinationConnectorRequest) Descriptor
deprecated
func (*DeleteDestinationConnectorRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteDestinationConnectorRequest.ProtoReflect.Descriptor instead.
func (*DeleteDestinationConnectorRequest) GetName ¶
func (x *DeleteDestinationConnectorRequest) GetName() string
func (*DeleteDestinationConnectorRequest) ProtoMessage ¶
func (*DeleteDestinationConnectorRequest) ProtoMessage()
func (*DeleteDestinationConnectorRequest) ProtoReflect ¶
func (x *DeleteDestinationConnectorRequest) ProtoReflect() protoreflect.Message
func (*DeleteDestinationConnectorRequest) Reset ¶
func (x *DeleteDestinationConnectorRequest) Reset()
func (*DeleteDestinationConnectorRequest) String ¶
func (x *DeleteDestinationConnectorRequest) String() string
type DeleteDestinationConnectorResponse ¶
type DeleteDestinationConnectorResponse struct {
// contains filtered or unexported fields
}
DeleteDestinationConnectorResponse represents an empty response
func (*DeleteDestinationConnectorResponse) Descriptor
deprecated
func (*DeleteDestinationConnectorResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteDestinationConnectorResponse.ProtoReflect.Descriptor instead.
func (*DeleteDestinationConnectorResponse) ProtoMessage ¶
func (*DeleteDestinationConnectorResponse) ProtoMessage()
func (*DeleteDestinationConnectorResponse) ProtoReflect ¶
func (x *DeleteDestinationConnectorResponse) ProtoReflect() protoreflect.Message
func (*DeleteDestinationConnectorResponse) Reset ¶
func (x *DeleteDestinationConnectorResponse) Reset()
func (*DeleteDestinationConnectorResponse) String ¶
func (x *DeleteDestinationConnectorResponse) String() string
type DeleteSourceConnectorRequest ¶
type DeleteSourceConnectorRequest struct { // SourceConnector resource name. It must have the format of // "source-connectors/*" Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
DeleteSourceConnectorRequest represents a request to delete a SourceConnector resource
func (*DeleteSourceConnectorRequest) Descriptor
deprecated
func (*DeleteSourceConnectorRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteSourceConnectorRequest.ProtoReflect.Descriptor instead.
func (*DeleteSourceConnectorRequest) GetName ¶
func (x *DeleteSourceConnectorRequest) GetName() string
func (*DeleteSourceConnectorRequest) ProtoMessage ¶
func (*DeleteSourceConnectorRequest) ProtoMessage()
func (*DeleteSourceConnectorRequest) ProtoReflect ¶
func (x *DeleteSourceConnectorRequest) ProtoReflect() protoreflect.Message
func (*DeleteSourceConnectorRequest) Reset ¶
func (x *DeleteSourceConnectorRequest) Reset()
func (*DeleteSourceConnectorRequest) String ¶
func (x *DeleteSourceConnectorRequest) String() string
type DeleteSourceConnectorResponse ¶
type DeleteSourceConnectorResponse struct {
// contains filtered or unexported fields
}
DeleteSourceConnectorResponse represents an empty response
func (*DeleteSourceConnectorResponse) Descriptor
deprecated
func (*DeleteSourceConnectorResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteSourceConnectorResponse.ProtoReflect.Descriptor instead.
func (*DeleteSourceConnectorResponse) ProtoMessage ¶
func (*DeleteSourceConnectorResponse) ProtoMessage()
func (*DeleteSourceConnectorResponse) ProtoReflect ¶
func (x *DeleteSourceConnectorResponse) ProtoReflect() protoreflect.Message
func (*DeleteSourceConnectorResponse) Reset ¶
func (x *DeleteSourceConnectorResponse) Reset()
func (*DeleteSourceConnectorResponse) String ¶
func (x *DeleteSourceConnectorResponse) String() string
type DestinationConnector ¶
type DestinationConnector struct { // DestinationConnector resource name. It must have the format of // "destination-connectors/*" Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // DestinationConnector UUID Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"` // DestinationConnector resource ID (the last segment of the resource name) // used to construct the resource name. This conforms to RFC-1034, which // restricts to letters, numbers, and hyphen, with the first character a // letter, the last a letter or a number, and a 63 character maximum. Id string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"` // DestinationConnectorDefinition resource DestinationConnectorDefinition string `` /* 153-byte string literal not displayed */ // DestinationConnector's connector data structure Connector *Connector `protobuf:"bytes,5,opt,name=connector,proto3" json:"connector,omitempty"` // contains filtered or unexported fields }
DestinationConnector represents a destination connector resource
func (*DestinationConnector) Descriptor
deprecated
func (*DestinationConnector) Descriptor() ([]byte, []int)
Deprecated: Use DestinationConnector.ProtoReflect.Descriptor instead.
func (*DestinationConnector) GetConnector ¶
func (x *DestinationConnector) GetConnector() *Connector
func (*DestinationConnector) GetDestinationConnectorDefinition ¶
func (x *DestinationConnector) GetDestinationConnectorDefinition() string
func (*DestinationConnector) GetId ¶
func (x *DestinationConnector) GetId() string
func (*DestinationConnector) GetName ¶
func (x *DestinationConnector) GetName() string
func (*DestinationConnector) GetUid ¶
func (x *DestinationConnector) GetUid() string
func (*DestinationConnector) ProtoMessage ¶
func (*DestinationConnector) ProtoMessage()
func (*DestinationConnector) ProtoReflect ¶
func (x *DestinationConnector) ProtoReflect() protoreflect.Message
func (*DestinationConnector) Reset ¶
func (x *DestinationConnector) Reset()
func (*DestinationConnector) String ¶
func (x *DestinationConnector) String() string
type DestinationConnectorDefinition ¶
type DestinationConnectorDefinition struct { // DestinationConnectorDefinition resource name. It must have the format of // "connector-definitions/*" Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // DestinationConnectorDefinition UUID Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"` // DestinationConnectorDefinition resource ID (the last segment of the // resource name) used to construct the resource name. This conforms to // RFC-1034, which restricts to letters, numbers, and hyphen, with the first // character a letter, the last a letter or a number, and a 63 character // maximum. Id string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"` // DestinationConnectorDefinition connector definition ConnectorDefinition *ConnectorDefinition `protobuf:"bytes,4,opt,name=connector_definition,json=connectorDefinition,proto3" json:"connector_definition,omitempty"` // contains filtered or unexported fields }
DestinationConnectorDefinition represents the destination connector definition resource
func (*DestinationConnectorDefinition) Descriptor
deprecated
func (*DestinationConnectorDefinition) Descriptor() ([]byte, []int)
Deprecated: Use DestinationConnectorDefinition.ProtoReflect.Descriptor instead.
func (*DestinationConnectorDefinition) GetConnectorDefinition ¶
func (x *DestinationConnectorDefinition) GetConnectorDefinition() *ConnectorDefinition
func (*DestinationConnectorDefinition) GetId ¶
func (x *DestinationConnectorDefinition) GetId() string
func (*DestinationConnectorDefinition) GetName ¶
func (x *DestinationConnectorDefinition) GetName() string
func (*DestinationConnectorDefinition) GetUid ¶
func (x *DestinationConnectorDefinition) GetUid() string
func (*DestinationConnectorDefinition) ProtoMessage ¶
func (*DestinationConnectorDefinition) ProtoMessage()
func (*DestinationConnectorDefinition) ProtoReflect ¶
func (x *DestinationConnectorDefinition) ProtoReflect() protoreflect.Message
func (*DestinationConnectorDefinition) Reset ¶
func (x *DestinationConnectorDefinition) Reset()
func (*DestinationConnectorDefinition) String ¶
func (x *DestinationConnectorDefinition) String() string
type DisconnectDestinationConnectorRequest ¶
type DisconnectDestinationConnectorRequest struct { // DestinationConnector resource name. It must have the format of // "destination-connectors/*" Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
DisconnectDestinationConnectorRequest represents a request to disconnect a destination connector
func (*DisconnectDestinationConnectorRequest) Descriptor
deprecated
func (*DisconnectDestinationConnectorRequest) Descriptor() ([]byte, []int)
Deprecated: Use DisconnectDestinationConnectorRequest.ProtoReflect.Descriptor instead.
func (*DisconnectDestinationConnectorRequest) GetName ¶
func (x *DisconnectDestinationConnectorRequest) GetName() string
func (*DisconnectDestinationConnectorRequest) ProtoMessage ¶
func (*DisconnectDestinationConnectorRequest) ProtoMessage()
func (*DisconnectDestinationConnectorRequest) ProtoReflect ¶
func (x *DisconnectDestinationConnectorRequest) ProtoReflect() protoreflect.Message
func (*DisconnectDestinationConnectorRequest) Reset ¶
func (x *DisconnectDestinationConnectorRequest) Reset()
func (*DisconnectDestinationConnectorRequest) String ¶
func (x *DisconnectDestinationConnectorRequest) String() string
type DisconnectDestinationConnectorResponse ¶
type DisconnectDestinationConnectorResponse struct { // A DestinationConnector resource DestinationConnector *DestinationConnector `protobuf:"bytes,1,opt,name=destination_connector,json=destinationConnector,proto3" json:"destination_connector,omitempty"` // contains filtered or unexported fields }
DisconnectDestinationConnectorResponse represents a disconnected destination connector
func (*DisconnectDestinationConnectorResponse) Descriptor
deprecated
func (*DisconnectDestinationConnectorResponse) Descriptor() ([]byte, []int)
Deprecated: Use DisconnectDestinationConnectorResponse.ProtoReflect.Descriptor instead.
func (*DisconnectDestinationConnectorResponse) GetDestinationConnector ¶
func (x *DisconnectDestinationConnectorResponse) GetDestinationConnector() *DestinationConnector
func (*DisconnectDestinationConnectorResponse) ProtoMessage ¶
func (*DisconnectDestinationConnectorResponse) ProtoMessage()
func (*DisconnectDestinationConnectorResponse) ProtoReflect ¶
func (x *DisconnectDestinationConnectorResponse) ProtoReflect() protoreflect.Message
func (*DisconnectDestinationConnectorResponse) Reset ¶
func (x *DisconnectDestinationConnectorResponse) Reset()
func (*DisconnectDestinationConnectorResponse) String ¶
func (x *DisconnectDestinationConnectorResponse) String() string
type DisconnectSourceConnectorRequest ¶
type DisconnectSourceConnectorRequest struct { // SourceConnector resource name. It must have the format of // "source-connectors/*" Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
DisconnectSourceConnectorRequest represents a request to disconnect a source connector
func (*DisconnectSourceConnectorRequest) Descriptor
deprecated
func (*DisconnectSourceConnectorRequest) Descriptor() ([]byte, []int)
Deprecated: Use DisconnectSourceConnectorRequest.ProtoReflect.Descriptor instead.
func (*DisconnectSourceConnectorRequest) GetName ¶
func (x *DisconnectSourceConnectorRequest) GetName() string
func (*DisconnectSourceConnectorRequest) ProtoMessage ¶
func (*DisconnectSourceConnectorRequest) ProtoMessage()
func (*DisconnectSourceConnectorRequest) ProtoReflect ¶
func (x *DisconnectSourceConnectorRequest) ProtoReflect() protoreflect.Message
func (*DisconnectSourceConnectorRequest) Reset ¶
func (x *DisconnectSourceConnectorRequest) Reset()
func (*DisconnectSourceConnectorRequest) String ¶
func (x *DisconnectSourceConnectorRequest) String() string
type DisconnectSourceConnectorResponse ¶
type DisconnectSourceConnectorResponse struct { // A SourceConnector resource SourceConnector *SourceConnector `protobuf:"bytes,1,opt,name=source_connector,json=sourceConnector,proto3" json:"source_connector,omitempty"` // contains filtered or unexported fields }
DisconnectSourceConnectorResponse represents a disconnected source connector
func (*DisconnectSourceConnectorResponse) Descriptor
deprecated
func (*DisconnectSourceConnectorResponse) Descriptor() ([]byte, []int)
Deprecated: Use DisconnectSourceConnectorResponse.ProtoReflect.Descriptor instead.
func (*DisconnectSourceConnectorResponse) GetSourceConnector ¶
func (x *DisconnectSourceConnectorResponse) GetSourceConnector() *SourceConnector
func (*DisconnectSourceConnectorResponse) ProtoMessage ¶
func (*DisconnectSourceConnectorResponse) ProtoMessage()
func (*DisconnectSourceConnectorResponse) ProtoReflect ¶
func (x *DisconnectSourceConnectorResponse) ProtoReflect() protoreflect.Message
func (*DisconnectSourceConnectorResponse) Reset ¶
func (x *DisconnectSourceConnectorResponse) Reset()
func (*DisconnectSourceConnectorResponse) String ¶
func (x *DisconnectSourceConnectorResponse) String() string
type DockerImageSpec ¶
type DockerImageSpec struct { // DockerImageSpec docker image DockerImage string `protobuf:"bytes,1,opt,name=docker_image,json=dockerImage,proto3" json:"docker_image,omitempty"` // DockerImageSpec spec data Spec *Spec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"` // contains filtered or unexported fields }
//////////////////////////////////////////////////////////////////////// DockerImageSpec represents a data model for docker image name and the connector specification associated with it
func (*DockerImageSpec) Descriptor
deprecated
func (*DockerImageSpec) Descriptor() ([]byte, []int)
Deprecated: Use DockerImageSpec.ProtoReflect.Descriptor instead.
func (*DockerImageSpec) GetDockerImage ¶
func (x *DockerImageSpec) GetDockerImage() string
func (*DockerImageSpec) GetSpec ¶
func (x *DockerImageSpec) GetSpec() *Spec
func (*DockerImageSpec) ProtoMessage ¶
func (*DockerImageSpec) ProtoMessage()
func (*DockerImageSpec) ProtoReflect ¶
func (x *DockerImageSpec) ProtoReflect() protoreflect.Message
func (*DockerImageSpec) Reset ¶
func (x *DockerImageSpec) Reset()
func (*DockerImageSpec) String ¶
func (x *DockerImageSpec) String() string
type GetDestinationConnectorDefinitionRequest ¶
type GetDestinationConnectorDefinitionRequest struct { // DestinationConnectorDefinition resource name. It must have the format of // "source-connector-definitions/*" Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // DestinationConnectorDefinition resource view (default is // DEFINITION_VIEW_BASIC) View *View `protobuf:"varint,2,opt,name=view,proto3,enum=vdp.connector.v1alpha.View,oneof" json:"view,omitempty"` // contains filtered or unexported fields }
GetDestinationConnectorDefinitionRequest represents a request to query a DestinationConnectorDefinition resource
func (*GetDestinationConnectorDefinitionRequest) Descriptor
deprecated
func (*GetDestinationConnectorDefinitionRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetDestinationConnectorDefinitionRequest.ProtoReflect.Descriptor instead.
func (*GetDestinationConnectorDefinitionRequest) GetName ¶
func (x *GetDestinationConnectorDefinitionRequest) GetName() string
func (*GetDestinationConnectorDefinitionRequest) GetView ¶
func (x *GetDestinationConnectorDefinitionRequest) GetView() View
func (*GetDestinationConnectorDefinitionRequest) ProtoMessage ¶
func (*GetDestinationConnectorDefinitionRequest) ProtoMessage()
func (*GetDestinationConnectorDefinitionRequest) ProtoReflect ¶
func (x *GetDestinationConnectorDefinitionRequest) ProtoReflect() protoreflect.Message
func (*GetDestinationConnectorDefinitionRequest) Reset ¶
func (x *GetDestinationConnectorDefinitionRequest) Reset()
func (*GetDestinationConnectorDefinitionRequest) String ¶
func (x *GetDestinationConnectorDefinitionRequest) String() string
type GetDestinationConnectorDefinitionResponse ¶
type GetDestinationConnectorDefinitionResponse struct { // A DestinationConnectorDefinition resource DestinationConnectorDefinition *DestinationConnectorDefinition `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
GetDestinationConnectorDefinitionResponse represents a DestinationConnectorDefinition response
func (*GetDestinationConnectorDefinitionResponse) Descriptor
deprecated
func (*GetDestinationConnectorDefinitionResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetDestinationConnectorDefinitionResponse.ProtoReflect.Descriptor instead.
func (*GetDestinationConnectorDefinitionResponse) GetDestinationConnectorDefinition ¶
func (x *GetDestinationConnectorDefinitionResponse) GetDestinationConnectorDefinition() *DestinationConnectorDefinition
func (*GetDestinationConnectorDefinitionResponse) ProtoMessage ¶
func (*GetDestinationConnectorDefinitionResponse) ProtoMessage()
func (*GetDestinationConnectorDefinitionResponse) ProtoReflect ¶
func (x *GetDestinationConnectorDefinitionResponse) ProtoReflect() protoreflect.Message
func (*GetDestinationConnectorDefinitionResponse) Reset ¶
func (x *GetDestinationConnectorDefinitionResponse) Reset()
func (*GetDestinationConnectorDefinitionResponse) String ¶
func (x *GetDestinationConnectorDefinitionResponse) String() string
type GetDestinationConnectorRequest ¶
type GetDestinationConnectorRequest struct { // DestinationConnectorConnector resource name. It must have the format of // "destination-connectors/*" Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // DestinationConnector view (default is VIEW_BASIC) View *View `protobuf:"varint,3,opt,name=view,proto3,enum=vdp.connector.v1alpha.View,oneof" json:"view,omitempty"` // contains filtered or unexported fields }
GetDestinationConnectorRequest represents a request to query a DestinationConnector resource
func (*GetDestinationConnectorRequest) Descriptor
deprecated
func (*GetDestinationConnectorRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetDestinationConnectorRequest.ProtoReflect.Descriptor instead.
func (*GetDestinationConnectorRequest) GetName ¶
func (x *GetDestinationConnectorRequest) GetName() string
func (*GetDestinationConnectorRequest) GetView ¶
func (x *GetDestinationConnectorRequest) GetView() View
func (*GetDestinationConnectorRequest) ProtoMessage ¶
func (*GetDestinationConnectorRequest) ProtoMessage()
func (*GetDestinationConnectorRequest) ProtoReflect ¶
func (x *GetDestinationConnectorRequest) ProtoReflect() protoreflect.Message
func (*GetDestinationConnectorRequest) Reset ¶
func (x *GetDestinationConnectorRequest) Reset()
func (*GetDestinationConnectorRequest) String ¶
func (x *GetDestinationConnectorRequest) String() string
type GetDestinationConnectorResponse ¶
type GetDestinationConnectorResponse struct { // DestinationConnector resource DestinationConnector *DestinationConnector `protobuf:"bytes,1,opt,name=destination_connector,json=destinationConnector,proto3" json:"destination_connector,omitempty"` // contains filtered or unexported fields }
GetDestinationConnectorResponse represents a response for a DestinationConnector resource
func (*GetDestinationConnectorResponse) Descriptor
deprecated
func (*GetDestinationConnectorResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetDestinationConnectorResponse.ProtoReflect.Descriptor instead.
func (*GetDestinationConnectorResponse) GetDestinationConnector ¶
func (x *GetDestinationConnectorResponse) GetDestinationConnector() *DestinationConnector
func (*GetDestinationConnectorResponse) ProtoMessage ¶
func (*GetDestinationConnectorResponse) ProtoMessage()
func (*GetDestinationConnectorResponse) ProtoReflect ¶
func (x *GetDestinationConnectorResponse) ProtoReflect() protoreflect.Message
func (*GetDestinationConnectorResponse) Reset ¶
func (x *GetDestinationConnectorResponse) Reset()
func (*GetDestinationConnectorResponse) String ¶
func (x *GetDestinationConnectorResponse) String() string
type GetSourceConnectorDefinitionRequest ¶
type GetSourceConnectorDefinitionRequest struct { // SourceConnectorDefinition resource name. It must have the format of // "source-connector-definitions/*" Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // SourceConnectorDefinition resource view (default is DEFINITION_VIEW_BASIC) View *View `protobuf:"varint,2,opt,name=view,proto3,enum=vdp.connector.v1alpha.View,oneof" json:"view,omitempty"` // contains filtered or unexported fields }
GetSourceConnectorDefinitionRequest represents a request to query a SourceConnectorDefinition resource
func (*GetSourceConnectorDefinitionRequest) Descriptor
deprecated
func (*GetSourceConnectorDefinitionRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetSourceConnectorDefinitionRequest.ProtoReflect.Descriptor instead.
func (*GetSourceConnectorDefinitionRequest) GetName ¶
func (x *GetSourceConnectorDefinitionRequest) GetName() string
func (*GetSourceConnectorDefinitionRequest) GetView ¶
func (x *GetSourceConnectorDefinitionRequest) GetView() View
func (*GetSourceConnectorDefinitionRequest) ProtoMessage ¶
func (*GetSourceConnectorDefinitionRequest) ProtoMessage()
func (*GetSourceConnectorDefinitionRequest) ProtoReflect ¶
func (x *GetSourceConnectorDefinitionRequest) ProtoReflect() protoreflect.Message
func (*GetSourceConnectorDefinitionRequest) Reset ¶
func (x *GetSourceConnectorDefinitionRequest) Reset()
func (*GetSourceConnectorDefinitionRequest) String ¶
func (x *GetSourceConnectorDefinitionRequest) String() string
type GetSourceConnectorDefinitionResponse ¶
type GetSourceConnectorDefinitionResponse struct { // A SourceConnectorDefinition resource SourceConnectorDefinition *SourceConnectorDefinition `` /* 138-byte string literal not displayed */ // contains filtered or unexported fields }
GetSourceConnectorDefinitionResponse represents a SourceConnectorDefinition response
func (*GetSourceConnectorDefinitionResponse) Descriptor
deprecated
func (*GetSourceConnectorDefinitionResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetSourceConnectorDefinitionResponse.ProtoReflect.Descriptor instead.
func (*GetSourceConnectorDefinitionResponse) GetSourceConnectorDefinition ¶
func (x *GetSourceConnectorDefinitionResponse) GetSourceConnectorDefinition() *SourceConnectorDefinition
func (*GetSourceConnectorDefinitionResponse) ProtoMessage ¶
func (*GetSourceConnectorDefinitionResponse) ProtoMessage()
func (*GetSourceConnectorDefinitionResponse) ProtoReflect ¶
func (x *GetSourceConnectorDefinitionResponse) ProtoReflect() protoreflect.Message
func (*GetSourceConnectorDefinitionResponse) Reset ¶
func (x *GetSourceConnectorDefinitionResponse) Reset()
func (*GetSourceConnectorDefinitionResponse) String ¶
func (x *GetSourceConnectorDefinitionResponse) String() string
type GetSourceConnectorRequest ¶
type GetSourceConnectorRequest struct { // SourceConnectorConnector resource name. It must have the format of // "source-connectors/*" Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // SourceConnector view (default is VIEW_BASIC) View *View `protobuf:"varint,3,opt,name=view,proto3,enum=vdp.connector.v1alpha.View,oneof" json:"view,omitempty"` // contains filtered or unexported fields }
GetSourceConnectorRequest represents a request to query a SourceConnector resource
func (*GetSourceConnectorRequest) Descriptor
deprecated
func (*GetSourceConnectorRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetSourceConnectorRequest.ProtoReflect.Descriptor instead.
func (*GetSourceConnectorRequest) GetName ¶
func (x *GetSourceConnectorRequest) GetName() string
func (*GetSourceConnectorRequest) GetView ¶
func (x *GetSourceConnectorRequest) GetView() View
func (*GetSourceConnectorRequest) ProtoMessage ¶
func (*GetSourceConnectorRequest) ProtoMessage()
func (*GetSourceConnectorRequest) ProtoReflect ¶
func (x *GetSourceConnectorRequest) ProtoReflect() protoreflect.Message
func (*GetSourceConnectorRequest) Reset ¶
func (x *GetSourceConnectorRequest) Reset()
func (*GetSourceConnectorRequest) String ¶
func (x *GetSourceConnectorRequest) String() string
type GetSourceConnectorResponse ¶
type GetSourceConnectorResponse struct { // SourceConnector resource SourceConnector *SourceConnector `protobuf:"bytes,1,opt,name=source_connector,json=sourceConnector,proto3" json:"source_connector,omitempty"` // contains filtered or unexported fields }
GetSourceConnectorResponse represents a response for a SourceConnector resource
func (*GetSourceConnectorResponse) Descriptor
deprecated
func (*GetSourceConnectorResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetSourceConnectorResponse.ProtoReflect.Descriptor instead.
func (*GetSourceConnectorResponse) GetSourceConnector ¶
func (x *GetSourceConnectorResponse) GetSourceConnector() *SourceConnector
func (*GetSourceConnectorResponse) ProtoMessage ¶
func (*GetSourceConnectorResponse) ProtoMessage()
func (*GetSourceConnectorResponse) ProtoReflect ¶
func (x *GetSourceConnectorResponse) ProtoReflect() protoreflect.Message
func (*GetSourceConnectorResponse) Reset ¶
func (x *GetSourceConnectorResponse) Reset()
func (*GetSourceConnectorResponse) String ¶
func (x *GetSourceConnectorResponse) String() string
type ListDestinationConnectorDefinitionRequest ¶
type ListDestinationConnectorDefinitionRequest struct { // The maximum number of DestinationConnectorDefinitions to return. The // service may return fewer than this value. If unspecified, at most 10 // DestinationConnectorDefinitions will be returned. The maximum value is 100; // values above 100 will be coerced to 100. PageSize *int64 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3,oneof" json:"page_size,omitempty"` // Page token PageToken *string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3,oneof" json:"page_token,omitempty"` // Definition view (default is DEFINITION_VIEW_BASIC) View *View `protobuf:"varint,3,opt,name=view,proto3,enum=vdp.connector.v1alpha.View,oneof" json:"view,omitempty"` // contains filtered or unexported fields }
/////////////////////////////////////////////////////////////////////
DestinationConnectorDefinition
ListDestinationConnectorDefinitionRequest represents a request to list DestinationConnectorDefinitions
func (*ListDestinationConnectorDefinitionRequest) Descriptor
deprecated
func (*ListDestinationConnectorDefinitionRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListDestinationConnectorDefinitionRequest.ProtoReflect.Descriptor instead.
func (*ListDestinationConnectorDefinitionRequest) GetPageSize ¶
func (x *ListDestinationConnectorDefinitionRequest) GetPageSize() int64
func (*ListDestinationConnectorDefinitionRequest) GetPageToken ¶
func (x *ListDestinationConnectorDefinitionRequest) GetPageToken() string
func (*ListDestinationConnectorDefinitionRequest) GetView ¶
func (x *ListDestinationConnectorDefinitionRequest) GetView() View
func (*ListDestinationConnectorDefinitionRequest) ProtoMessage ¶
func (*ListDestinationConnectorDefinitionRequest) ProtoMessage()
func (*ListDestinationConnectorDefinitionRequest) ProtoReflect ¶
func (x *ListDestinationConnectorDefinitionRequest) ProtoReflect() protoreflect.Message
func (*ListDestinationConnectorDefinitionRequest) Reset ¶
func (x *ListDestinationConnectorDefinitionRequest) Reset()
func (*ListDestinationConnectorDefinitionRequest) String ¶
func (x *ListDestinationConnectorDefinitionRequest) String() string
type ListDestinationConnectorDefinitionResponse ¶
type ListDestinationConnectorDefinitionResponse struct { // A list of DestinationConnectorDefinition resources DestinationConnectorDefinitions []*DestinationConnectorDefinition `` /* 156-byte string literal not displayed */ // Next page token NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // Total count of DestinationConnectorDefinition resources TotalSize int64 `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"` // contains filtered or unexported fields }
ListDestinationConnectorDefinitionResponse represents a response for a list of DestinationConnectorDefinitions
func (*ListDestinationConnectorDefinitionResponse) Descriptor
deprecated
func (*ListDestinationConnectorDefinitionResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListDestinationConnectorDefinitionResponse.ProtoReflect.Descriptor instead.
func (*ListDestinationConnectorDefinitionResponse) GetDestinationConnectorDefinitions ¶
func (x *ListDestinationConnectorDefinitionResponse) GetDestinationConnectorDefinitions() []*DestinationConnectorDefinition
func (*ListDestinationConnectorDefinitionResponse) GetNextPageToken ¶
func (x *ListDestinationConnectorDefinitionResponse) GetNextPageToken() string
func (*ListDestinationConnectorDefinitionResponse) GetTotalSize ¶
func (x *ListDestinationConnectorDefinitionResponse) GetTotalSize() int64
func (*ListDestinationConnectorDefinitionResponse) ProtoMessage ¶
func (*ListDestinationConnectorDefinitionResponse) ProtoMessage()
func (*ListDestinationConnectorDefinitionResponse) ProtoReflect ¶
func (x *ListDestinationConnectorDefinitionResponse) ProtoReflect() protoreflect.Message
func (*ListDestinationConnectorDefinitionResponse) Reset ¶
func (x *ListDestinationConnectorDefinitionResponse) Reset()
func (*ListDestinationConnectorDefinitionResponse) String ¶
func (x *ListDestinationConnectorDefinitionResponse) String() string
type ListDestinationConnectorRequest ¶
type ListDestinationConnectorRequest struct { // The maximum number of connectors to return. The service may return fewer // than this value. If unspecified, at most 10 connectors will be returned. // The maximum value is 100; values above 100 will be coerced to 100. PageSize *int64 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3,oneof" json:"page_size,omitempty"` // Page token PageToken *string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3,oneof" json:"page_token,omitempty"` // DestinationConnector view (default is VIEW_BASIC) View *View `protobuf:"varint,3,opt,name=view,proto3,enum=vdp.connector.v1alpha.View,oneof" json:"view,omitempty"` // contains filtered or unexported fields }
ListDestinationConnectorRequest represents a request to list DestinationConnector resources
func (*ListDestinationConnectorRequest) Descriptor
deprecated
func (*ListDestinationConnectorRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListDestinationConnectorRequest.ProtoReflect.Descriptor instead.
func (*ListDestinationConnectorRequest) GetPageSize ¶
func (x *ListDestinationConnectorRequest) GetPageSize() int64
func (*ListDestinationConnectorRequest) GetPageToken ¶
func (x *ListDestinationConnectorRequest) GetPageToken() string
func (*ListDestinationConnectorRequest) GetView ¶
func (x *ListDestinationConnectorRequest) GetView() View
func (*ListDestinationConnectorRequest) ProtoMessage ¶
func (*ListDestinationConnectorRequest) ProtoMessage()
func (*ListDestinationConnectorRequest) ProtoReflect ¶
func (x *ListDestinationConnectorRequest) ProtoReflect() protoreflect.Message
func (*ListDestinationConnectorRequest) Reset ¶
func (x *ListDestinationConnectorRequest) Reset()
func (*ListDestinationConnectorRequest) String ¶
func (x *ListDestinationConnectorRequest) String() string
type ListDestinationConnectorResponse ¶
type ListDestinationConnectorResponse struct { // A list of DestinationConnector resources DestinationConnectors []*DestinationConnector `protobuf:"bytes,1,rep,name=destination_connectors,json=destinationConnectors,proto3" json:"destination_connectors,omitempty"` // Next page token NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // Total count of connector resources TotalSize int64 `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"` // contains filtered or unexported fields }
ListDestinationConnectorResponse represents a response for a list of DestinationConnector resources
func (*ListDestinationConnectorResponse) Descriptor
deprecated
func (*ListDestinationConnectorResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListDestinationConnectorResponse.ProtoReflect.Descriptor instead.
func (*ListDestinationConnectorResponse) GetDestinationConnectors ¶
func (x *ListDestinationConnectorResponse) GetDestinationConnectors() []*DestinationConnector
func (*ListDestinationConnectorResponse) GetNextPageToken ¶
func (x *ListDestinationConnectorResponse) GetNextPageToken() string
func (*ListDestinationConnectorResponse) GetTotalSize ¶
func (x *ListDestinationConnectorResponse) GetTotalSize() int64
func (*ListDestinationConnectorResponse) ProtoMessage ¶
func (*ListDestinationConnectorResponse) ProtoMessage()
func (*ListDestinationConnectorResponse) ProtoReflect ¶
func (x *ListDestinationConnectorResponse) ProtoReflect() protoreflect.Message
func (*ListDestinationConnectorResponse) Reset ¶
func (x *ListDestinationConnectorResponse) Reset()
func (*ListDestinationConnectorResponse) String ¶
func (x *ListDestinationConnectorResponse) String() string
type ListSourceConnectorDefinitionRequest ¶
type ListSourceConnectorDefinitionRequest struct { // The maximum number of SourceConnectorDefinitions to return. The service may // return fewer than this value. If unspecified, at most 10 // SourceConnectorDefinitions will be returned. The maximum value is 100; // values above 100 will be coerced to 100. PageSize *int64 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3,oneof" json:"page_size,omitempty"` // Page token PageToken *string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3,oneof" json:"page_token,omitempty"` // Definition view (default is DEFINITION_VIEW_BASIC) View *View `protobuf:"varint,3,opt,name=view,proto3,enum=vdp.connector.v1alpha.View,oneof" json:"view,omitempty"` // contains filtered or unexported fields }
SourceConnectorDefinition
ListSourceConnectorDefinitionRequest represents a request to list SourceConnectorDefinitions
func (*ListSourceConnectorDefinitionRequest) Descriptor
deprecated
func (*ListSourceConnectorDefinitionRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListSourceConnectorDefinitionRequest.ProtoReflect.Descriptor instead.
func (*ListSourceConnectorDefinitionRequest) GetPageSize ¶
func (x *ListSourceConnectorDefinitionRequest) GetPageSize() int64
func (*ListSourceConnectorDefinitionRequest) GetPageToken ¶
func (x *ListSourceConnectorDefinitionRequest) GetPageToken() string
func (*ListSourceConnectorDefinitionRequest) GetView ¶
func (x *ListSourceConnectorDefinitionRequest) GetView() View
func (*ListSourceConnectorDefinitionRequest) ProtoMessage ¶
func (*ListSourceConnectorDefinitionRequest) ProtoMessage()
func (*ListSourceConnectorDefinitionRequest) ProtoReflect ¶
func (x *ListSourceConnectorDefinitionRequest) ProtoReflect() protoreflect.Message
func (*ListSourceConnectorDefinitionRequest) Reset ¶
func (x *ListSourceConnectorDefinitionRequest) Reset()
func (*ListSourceConnectorDefinitionRequest) String ¶
func (x *ListSourceConnectorDefinitionRequest) String() string
type ListSourceConnectorDefinitionResponse ¶
type ListSourceConnectorDefinitionResponse struct { // A list of SourceConnectorDefinition resources SourceConnectorDefinitions []*SourceConnectorDefinition `` /* 141-byte string literal not displayed */ // Next page token NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // Total count of SourceConnectorDefinition resources TotalSize int64 `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"` // contains filtered or unexported fields }
ListSourceConnectorDefinitionResponse represents a response for a list of SourceConnectorDefinitions
func (*ListSourceConnectorDefinitionResponse) Descriptor
deprecated
func (*ListSourceConnectorDefinitionResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListSourceConnectorDefinitionResponse.ProtoReflect.Descriptor instead.
func (*ListSourceConnectorDefinitionResponse) GetNextPageToken ¶
func (x *ListSourceConnectorDefinitionResponse) GetNextPageToken() string
func (*ListSourceConnectorDefinitionResponse) GetSourceConnectorDefinitions ¶
func (x *ListSourceConnectorDefinitionResponse) GetSourceConnectorDefinitions() []*SourceConnectorDefinition
func (*ListSourceConnectorDefinitionResponse) GetTotalSize ¶
func (x *ListSourceConnectorDefinitionResponse) GetTotalSize() int64
func (*ListSourceConnectorDefinitionResponse) ProtoMessage ¶
func (*ListSourceConnectorDefinitionResponse) ProtoMessage()
func (*ListSourceConnectorDefinitionResponse) ProtoReflect ¶
func (x *ListSourceConnectorDefinitionResponse) ProtoReflect() protoreflect.Message
func (*ListSourceConnectorDefinitionResponse) Reset ¶
func (x *ListSourceConnectorDefinitionResponse) Reset()
func (*ListSourceConnectorDefinitionResponse) String ¶
func (x *ListSourceConnectorDefinitionResponse) String() string
type ListSourceConnectorRequest ¶
type ListSourceConnectorRequest struct { // The maximum number of connectors to return. The service may return fewer // than this value. If unspecified, at most 10 connectors will be returned. // The maximum value is 100; values above 100 will be coerced to 100. PageSize *int64 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3,oneof" json:"page_size,omitempty"` // Page token PageToken *string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3,oneof" json:"page_token,omitempty"` // SourceConnector view (default is VIEW_BASIC) View *View `protobuf:"varint,3,opt,name=view,proto3,enum=vdp.connector.v1alpha.View,oneof" json:"view,omitempty"` // contains filtered or unexported fields }
ListSourceConnectorRequest represents a request to list SourceConnector resources
func (*ListSourceConnectorRequest) Descriptor
deprecated
func (*ListSourceConnectorRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListSourceConnectorRequest.ProtoReflect.Descriptor instead.
func (*ListSourceConnectorRequest) GetPageSize ¶
func (x *ListSourceConnectorRequest) GetPageSize() int64
func (*ListSourceConnectorRequest) GetPageToken ¶
func (x *ListSourceConnectorRequest) GetPageToken() string
func (*ListSourceConnectorRequest) GetView ¶
func (x *ListSourceConnectorRequest) GetView() View
func (*ListSourceConnectorRequest) ProtoMessage ¶
func (*ListSourceConnectorRequest) ProtoMessage()
func (*ListSourceConnectorRequest) ProtoReflect ¶
func (x *ListSourceConnectorRequest) ProtoReflect() protoreflect.Message
func (*ListSourceConnectorRequest) Reset ¶
func (x *ListSourceConnectorRequest) Reset()
func (*ListSourceConnectorRequest) String ¶
func (x *ListSourceConnectorRequest) String() string
type ListSourceConnectorResponse ¶
type ListSourceConnectorResponse struct { // A list of SourceConnector resources SourceConnectors []*SourceConnector `protobuf:"bytes,1,rep,name=source_connectors,json=sourceConnectors,proto3" json:"source_connectors,omitempty"` // Next page token NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // Total count of connector resources TotalSize int64 `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"` // contains filtered or unexported fields }
ListSourceConnectorResponse represents a response for a list of SourceConnector resources
func (*ListSourceConnectorResponse) Descriptor
deprecated
func (*ListSourceConnectorResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListSourceConnectorResponse.ProtoReflect.Descriptor instead.
func (*ListSourceConnectorResponse) GetNextPageToken ¶
func (x *ListSourceConnectorResponse) GetNextPageToken() string
func (*ListSourceConnectorResponse) GetSourceConnectors ¶
func (x *ListSourceConnectorResponse) GetSourceConnectors() []*SourceConnector
func (*ListSourceConnectorResponse) GetTotalSize ¶
func (x *ListSourceConnectorResponse) GetTotalSize() int64
func (*ListSourceConnectorResponse) ProtoMessage ¶
func (*ListSourceConnectorResponse) ProtoMessage()
func (*ListSourceConnectorResponse) ProtoReflect ¶
func (x *ListSourceConnectorResponse) ProtoReflect() protoreflect.Message
func (*ListSourceConnectorResponse) Reset ¶
func (x *ListSourceConnectorResponse) Reset()
func (*ListSourceConnectorResponse) String ¶
func (x *ListSourceConnectorResponse) String() string
type LivenessRequest ¶
type LivenessRequest struct { // HealthCheckRequest message HealthCheckRequest *v1alpha.HealthCheckRequest `protobuf:"bytes,1,opt,name=health_check_request,json=healthCheckRequest,proto3,oneof" json:"health_check_request,omitempty"` // contains filtered or unexported fields }
LivenessRequest represents a request to check a service liveness status
func (*LivenessRequest) Descriptor
deprecated
func (*LivenessRequest) Descriptor() ([]byte, []int)
Deprecated: Use LivenessRequest.ProtoReflect.Descriptor instead.
func (*LivenessRequest) GetHealthCheckRequest ¶
func (x *LivenessRequest) GetHealthCheckRequest() *v1alpha.HealthCheckRequest
func (*LivenessRequest) ProtoMessage ¶
func (*LivenessRequest) ProtoMessage()
func (*LivenessRequest) ProtoReflect ¶
func (x *LivenessRequest) ProtoReflect() protoreflect.Message
func (*LivenessRequest) Reset ¶
func (x *LivenessRequest) Reset()
func (*LivenessRequest) String ¶
func (x *LivenessRequest) String() string
type LivenessResponse ¶
type LivenessResponse struct { // HealthCheckResponse message HealthCheckResponse *v1alpha.HealthCheckResponse `protobuf:"bytes,1,opt,name=health_check_response,json=healthCheckResponse,proto3" json:"health_check_response,omitempty"` // contains filtered or unexported fields }
LivenessResponse represents a response for a service liveness status
func (*LivenessResponse) Descriptor
deprecated
func (*LivenessResponse) Descriptor() ([]byte, []int)
Deprecated: Use LivenessResponse.ProtoReflect.Descriptor instead.
func (*LivenessResponse) GetHealthCheckResponse ¶
func (x *LivenessResponse) GetHealthCheckResponse() *v1alpha.HealthCheckResponse
func (*LivenessResponse) ProtoMessage ¶
func (*LivenessResponse) ProtoMessage()
func (*LivenessResponse) ProtoReflect ¶
func (x *LivenessResponse) ProtoReflect() protoreflect.Message
func (*LivenessResponse) Reset ¶
func (x *LivenessResponse) Reset()
func (*LivenessResponse) String ¶
func (x *LivenessResponse) String() string
type LookUpDestinationConnectorRequest ¶
type LookUpDestinationConnectorRequest struct { // Permalink of a destination connector. For example: // "destination-connectors/{uid}" Permalink string `protobuf:"bytes,1,opt,name=permalink,proto3" json:"permalink,omitempty"` // SourceConnector view (default is VIEW_BASIC) View *View `protobuf:"varint,2,opt,name=view,proto3,enum=vdp.connector.v1alpha.View,oneof" json:"view,omitempty"` // contains filtered or unexported fields }
LookUpDestinationConnectorRequest represents a request to query a destination connector by permalink
func (*LookUpDestinationConnectorRequest) Descriptor
deprecated
func (*LookUpDestinationConnectorRequest) Descriptor() ([]byte, []int)
Deprecated: Use LookUpDestinationConnectorRequest.ProtoReflect.Descriptor instead.
func (*LookUpDestinationConnectorRequest) GetPermalink ¶
func (x *LookUpDestinationConnectorRequest) GetPermalink() string
func (*LookUpDestinationConnectorRequest) GetView ¶
func (x *LookUpDestinationConnectorRequest) GetView() View
func (*LookUpDestinationConnectorRequest) ProtoMessage ¶
func (*LookUpDestinationConnectorRequest) ProtoMessage()
func (*LookUpDestinationConnectorRequest) ProtoReflect ¶
func (x *LookUpDestinationConnectorRequest) ProtoReflect() protoreflect.Message
func (*LookUpDestinationConnectorRequest) Reset ¶
func (x *LookUpDestinationConnectorRequest) Reset()
func (*LookUpDestinationConnectorRequest) String ¶
func (x *LookUpDestinationConnectorRequest) String() string
type LookUpDestinationConnectorResponse ¶
type LookUpDestinationConnectorResponse struct { // DestinationConnector resource DestinationConnector *DestinationConnector `protobuf:"bytes,1,opt,name=destination_connector,json=destinationConnector,proto3" json:"destination_connector,omitempty"` // contains filtered or unexported fields }
LookUpDestinationConnectorResponse represents a response for a destination connector
func (*LookUpDestinationConnectorResponse) Descriptor
deprecated
func (*LookUpDestinationConnectorResponse) Descriptor() ([]byte, []int)
Deprecated: Use LookUpDestinationConnectorResponse.ProtoReflect.Descriptor instead.
func (*LookUpDestinationConnectorResponse) GetDestinationConnector ¶
func (x *LookUpDestinationConnectorResponse) GetDestinationConnector() *DestinationConnector
func (*LookUpDestinationConnectorResponse) ProtoMessage ¶
func (*LookUpDestinationConnectorResponse) ProtoMessage()
func (*LookUpDestinationConnectorResponse) ProtoReflect ¶
func (x *LookUpDestinationConnectorResponse) ProtoReflect() protoreflect.Message
func (*LookUpDestinationConnectorResponse) Reset ¶
func (x *LookUpDestinationConnectorResponse) Reset()
func (*LookUpDestinationConnectorResponse) String ¶
func (x *LookUpDestinationConnectorResponse) String() string
type LookUpSourceConnectorRequest ¶
type LookUpSourceConnectorRequest struct { // Permalink of a source connector. For example: // "source-connectors/{uid}" Permalink string `protobuf:"bytes,1,opt,name=permalink,proto3" json:"permalink,omitempty"` // SourceConnector view (default is VIEW_BASIC) View *View `protobuf:"varint,2,opt,name=view,proto3,enum=vdp.connector.v1alpha.View,oneof" json:"view,omitempty"` // contains filtered or unexported fields }
LookUpSourceConnectorRequest represents a request to query a source connector by permalink
func (*LookUpSourceConnectorRequest) Descriptor
deprecated
func (*LookUpSourceConnectorRequest) Descriptor() ([]byte, []int)
Deprecated: Use LookUpSourceConnectorRequest.ProtoReflect.Descriptor instead.
func (*LookUpSourceConnectorRequest) GetPermalink ¶
func (x *LookUpSourceConnectorRequest) GetPermalink() string
func (*LookUpSourceConnectorRequest) GetView ¶
func (x *LookUpSourceConnectorRequest) GetView() View
func (*LookUpSourceConnectorRequest) ProtoMessage ¶
func (*LookUpSourceConnectorRequest) ProtoMessage()
func (*LookUpSourceConnectorRequest) ProtoReflect ¶
func (x *LookUpSourceConnectorRequest) ProtoReflect() protoreflect.Message
func (*LookUpSourceConnectorRequest) Reset ¶
func (x *LookUpSourceConnectorRequest) Reset()
func (*LookUpSourceConnectorRequest) String ¶
func (x *LookUpSourceConnectorRequest) String() string
type LookUpSourceConnectorResponse ¶
type LookUpSourceConnectorResponse struct { // SourceConnector resource SourceConnector *SourceConnector `protobuf:"bytes,1,opt,name=source_connector,json=sourceConnector,proto3" json:"source_connector,omitempty"` // contains filtered or unexported fields }
LookUpSourceConnectorResponse represents a response for a source connector
func (*LookUpSourceConnectorResponse) Descriptor
deprecated
func (*LookUpSourceConnectorResponse) Descriptor() ([]byte, []int)
Deprecated: Use LookUpSourceConnectorResponse.ProtoReflect.Descriptor instead.
func (*LookUpSourceConnectorResponse) GetSourceConnector ¶
func (x *LookUpSourceConnectorResponse) GetSourceConnector() *SourceConnector
func (*LookUpSourceConnectorResponse) ProtoMessage ¶
func (*LookUpSourceConnectorResponse) ProtoMessage()
func (*LookUpSourceConnectorResponse) ProtoReflect ¶
func (x *LookUpSourceConnectorResponse) ProtoReflect() protoreflect.Message
func (*LookUpSourceConnectorResponse) Reset ¶
func (x *LookUpSourceConnectorResponse) Reset()
func (*LookUpSourceConnectorResponse) String ¶
func (x *LookUpSourceConnectorResponse) String() string
type OauthConfigSpecification ¶
type OauthConfigSpecification struct { // OAuth specific blob. This is a Json Schema used to validate Json // configurations used as input to OAuth. Must be a valid non-nested JSON that // refers to properties from ConnectorSpecification.connectionSpecification // using special annotation 'path_in_connector_config'. // These are input values the user is entering through the UI to authenticate // to the connector, that might also shared as inputs for syncing data via the // connector. // // Examples: // // if no connector values is shared during oauth flow, // oauth_user_input_from_connector_config_specification=[] if connector values // such as 'app_id' inside the top level are used to generate the API url for // the oauth flow, // oauth_user_input_from_connector_config_specification={ // app_id: { // type: string // path_in_connector_config: ['app_id'] // } // } // if connector values such as 'info.app_id' nested inside another object are // used to generate the API url for the oauth flow, // oauth_user_input_from_connector_config_specification={ // app_id: { // type: string // path_in_connector_config: ['info', 'app_id'] // } // } OauthUserInputFromConnectorConfigSpecification *structpb.Struct `` /* 209-byte string literal not displayed */ // OAuth specific blob. This is a Json Schema used to validate Json // configurations produced by the OAuth flows as they are returned by the // distant OAuth APIs. Must be a valid JSON describing the fields to merge // back to `ConnectorSpecification.connectionSpecification`. For each field, a // special annotation `path_in_connector_config` can be specified to determine // where to merge it, // // Examples: // // complete_oauth_output_specification={ // refresh_token: { // type: string, // path_in_connector_config: ['credentials', 'refresh_token'] // } // } CompleteOauthOutputSpecification *structpb.Struct `` /* 161-byte string literal not displayed */ // OAuth specific blob. This is a Json Schema used to validate Json // configurations persisted as Airbyte Server configurations. Must be a valid // non-nested JSON describing additional fields configured by the Airbyte // Instance or Workspace Admins to be used by the server when completing an // OAuth flow (typically exchanging an auth code for refresh token). // // Examples: // // complete_oauth_server_input_specification={ // client_id: { // type: string // }, // client_secret: { // type: string // } // } CompleteOauthServerInputSpecification *structpb.Struct `` /* 178-byte string literal not displayed */ // OAuth specific blob. This is a Json Schema used to validate Json // configurations persisted as Airbyte Server configurations that also need to // be merged back into the connector configuration at runtime. This is a // subset configuration of `complete_oauth_server_input_specification` that // filters fields out to retain only the ones that are necessary for the // connector to function with OAuth. (some fields could be used during oauth // flows but not needed afterwards, therefore they would be listed in the // `complete_oauth_server_input_specification` but not // `complete_oauth_server_output_specification`) Must be a valid non-nested // JSON describing additional fields configured by the Airbyte Instance or // Workspace Admins to be used by the connector when using OAuth flow APIs. // These fields are to be merged back to // `ConnectorSpecification.connectionSpecification`. For each field, a special // annotation `path_in_connector_config` can be specified to determine where // to merge it, // // Examples: // // complete_oauth_server_output_specification={ // client_id: { // type: string, // path_in_connector_config: ['credentials', 'client_id'] // }, // client_secret: { // type: string, // path_in_connector_config: ['credentials', 'client_secret'] // } // } CompleteOauthServerOutputSpecification *structpb.Struct `` /* 181-byte string literal not displayed */ // contains filtered or unexported fields }
OauthConfigSpecification represents oauth config specification
func (*OauthConfigSpecification) Descriptor
deprecated
func (*OauthConfigSpecification) Descriptor() ([]byte, []int)
Deprecated: Use OauthConfigSpecification.ProtoReflect.Descriptor instead.
func (*OauthConfigSpecification) GetCompleteOauthOutputSpecification ¶
func (x *OauthConfigSpecification) GetCompleteOauthOutputSpecification() *structpb.Struct
func (*OauthConfigSpecification) GetCompleteOauthServerInputSpecification ¶
func (x *OauthConfigSpecification) GetCompleteOauthServerInputSpecification() *structpb.Struct
func (*OauthConfigSpecification) GetCompleteOauthServerOutputSpecification ¶
func (x *OauthConfigSpecification) GetCompleteOauthServerOutputSpecification() *structpb.Struct
func (*OauthConfigSpecification) GetOauthUserInputFromConnectorConfigSpecification ¶
func (x *OauthConfigSpecification) GetOauthUserInputFromConnectorConfigSpecification() *structpb.Struct
func (*OauthConfigSpecification) ProtoMessage ¶
func (*OauthConfigSpecification) ProtoMessage()
func (*OauthConfigSpecification) ProtoReflect ¶
func (x *OauthConfigSpecification) ProtoReflect() protoreflect.Message
func (*OauthConfigSpecification) Reset ¶
func (x *OauthConfigSpecification) Reset()
func (*OauthConfigSpecification) String ¶
func (x *OauthConfigSpecification) String() string
type ReadSourceConnectorRequest ¶
type ReadSourceConnectorRequest struct { // SourceConnector resource name. It must have the format of // "source-connectors/*" Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
ReadSourceConnectorRequest represents a request to perform read operation of a SourceConnector given the resource name
func (*ReadSourceConnectorRequest) Descriptor
deprecated
func (*ReadSourceConnectorRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadSourceConnectorRequest.ProtoReflect.Descriptor instead.
func (*ReadSourceConnectorRequest) GetName ¶
func (x *ReadSourceConnectorRequest) GetName() string
func (*ReadSourceConnectorRequest) ProtoMessage ¶
func (*ReadSourceConnectorRequest) ProtoMessage()
func (*ReadSourceConnectorRequest) ProtoReflect ¶
func (x *ReadSourceConnectorRequest) ProtoReflect() protoreflect.Message
func (*ReadSourceConnectorRequest) Reset ¶
func (x *ReadSourceConnectorRequest) Reset()
func (*ReadSourceConnectorRequest) String ¶
func (x *ReadSourceConnectorRequest) String() string
type ReadSourceConnectorResponse ¶
type ReadSourceConnectorResponse struct { // Read data in bytes Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
ReadSourceConnectorResponse represents the read data from a SourceConnector resource
func (*ReadSourceConnectorResponse) Descriptor
deprecated
func (*ReadSourceConnectorResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReadSourceConnectorResponse.ProtoReflect.Descriptor instead.
func (*ReadSourceConnectorResponse) GetData ¶
func (x *ReadSourceConnectorResponse) GetData() []byte
func (*ReadSourceConnectorResponse) ProtoMessage ¶
func (*ReadSourceConnectorResponse) ProtoMessage()
func (*ReadSourceConnectorResponse) ProtoReflect ¶
func (x *ReadSourceConnectorResponse) ProtoReflect() protoreflect.Message
func (*ReadSourceConnectorResponse) Reset ¶
func (x *ReadSourceConnectorResponse) Reset()
func (*ReadSourceConnectorResponse) String ¶
func (x *ReadSourceConnectorResponse) String() string
type ReadinessRequest ¶
type ReadinessRequest struct { // HealthCheckRequest message HealthCheckRequest *v1alpha.HealthCheckRequest `protobuf:"bytes,1,opt,name=health_check_request,json=healthCheckRequest,proto3,oneof" json:"health_check_request,omitempty"` // contains filtered or unexported fields }
ReadinessRequest represents a request to check a service readiness status
func (*ReadinessRequest) Descriptor
deprecated
func (*ReadinessRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadinessRequest.ProtoReflect.Descriptor instead.
func (*ReadinessRequest) GetHealthCheckRequest ¶
func (x *ReadinessRequest) GetHealthCheckRequest() *v1alpha.HealthCheckRequest
func (*ReadinessRequest) ProtoMessage ¶
func (*ReadinessRequest) ProtoMessage()
func (*ReadinessRequest) ProtoReflect ¶
func (x *ReadinessRequest) ProtoReflect() protoreflect.Message
func (*ReadinessRequest) Reset ¶
func (x *ReadinessRequest) Reset()
func (*ReadinessRequest) String ¶
func (x *ReadinessRequest) String() string
type ReadinessResponse ¶
type ReadinessResponse struct { // HealthCheckResponse message HealthCheckResponse *v1alpha.HealthCheckResponse `protobuf:"bytes,1,opt,name=health_check_response,json=healthCheckResponse,proto3" json:"health_check_response,omitempty"` // contains filtered or unexported fields }
ReadinessResponse represents a response for a service readiness status
func (*ReadinessResponse) Descriptor
deprecated
func (*ReadinessResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReadinessResponse.ProtoReflect.Descriptor instead.
func (*ReadinessResponse) GetHealthCheckResponse ¶
func (x *ReadinessResponse) GetHealthCheckResponse() *v1alpha.HealthCheckResponse
func (*ReadinessResponse) ProtoMessage ¶
func (*ReadinessResponse) ProtoMessage()
func (*ReadinessResponse) ProtoReflect ¶
func (x *ReadinessResponse) ProtoReflect() protoreflect.Message
func (*ReadinessResponse) Reset ¶
func (x *ReadinessResponse) Reset()
func (*ReadinessResponse) String ¶
func (x *ReadinessResponse) String() string
type ReleaseStage ¶
type ReleaseStage int32
ReleaseStage enumerates the release stages
const ( // ReleaseStage: UNSPECIFIED ReleaseStage_RELEASE_STAGE_UNSPECIFIED ReleaseStage = 0 // ReleaseStage: ALPHA ReleaseStage_RELEASE_STAGE_ALPHA ReleaseStage = 1 // ReleaseStage: BETA ReleaseStage_RELEASE_STAGE_BETA ReleaseStage = 2 // ReleaseStage: GENERALLY_AVAILABLE ReleaseStage_RELEASE_STAGE_GENERALLY_AVAILABLE ReleaseStage = 3 // ReleaseStage: CUSTOM ReleaseStage_RELEASE_STAGE_CUSTOM ReleaseStage = 4 )
func (ReleaseStage) Descriptor ¶
func (ReleaseStage) Descriptor() protoreflect.EnumDescriptor
func (ReleaseStage) Enum ¶
func (x ReleaseStage) Enum() *ReleaseStage
func (ReleaseStage) EnumDescriptor
deprecated
func (ReleaseStage) EnumDescriptor() ([]byte, []int)
Deprecated: Use ReleaseStage.Descriptor instead.
func (ReleaseStage) Number ¶
func (x ReleaseStage) Number() protoreflect.EnumNumber
func (ReleaseStage) String ¶
func (x ReleaseStage) String() string
func (ReleaseStage) Type ¶
func (ReleaseStage) Type() protoreflect.EnumType
type RenameDestinationConnectorRequest ¶
type RenameDestinationConnectorRequest struct { // DestinationConnector resource name. It must have the format of // "destination-connectors/*" Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // DestinationConnector new resource id to replace with the // DestinationConnector resource name to be // "destination-connectors/{new_destination_connector_id}" NewDestinationConnectorId string `` /* 140-byte string literal not displayed */ // contains filtered or unexported fields }
RenameDestinationConnectorRequest represents a request to rename the DestinationConnector resource name
func (*RenameDestinationConnectorRequest) Descriptor
deprecated
func (*RenameDestinationConnectorRequest) Descriptor() ([]byte, []int)
Deprecated: Use RenameDestinationConnectorRequest.ProtoReflect.Descriptor instead.
func (*RenameDestinationConnectorRequest) GetName ¶
func (x *RenameDestinationConnectorRequest) GetName() string
func (*RenameDestinationConnectorRequest) GetNewDestinationConnectorId ¶
func (x *RenameDestinationConnectorRequest) GetNewDestinationConnectorId() string
func (*RenameDestinationConnectorRequest) ProtoMessage ¶
func (*RenameDestinationConnectorRequest) ProtoMessage()
func (*RenameDestinationConnectorRequest) ProtoReflect ¶
func (x *RenameDestinationConnectorRequest) ProtoReflect() protoreflect.Message
func (*RenameDestinationConnectorRequest) Reset ¶
func (x *RenameDestinationConnectorRequest) Reset()
func (*RenameDestinationConnectorRequest) String ¶
func (x *RenameDestinationConnectorRequest) String() string
type RenameDestinationConnectorResponse ¶
type RenameDestinationConnectorResponse struct { // A DestinationConnector resource DestinationConnector *DestinationConnector `protobuf:"bytes,1,opt,name=destination_connector,json=destinationConnector,proto3" json:"destination_connector,omitempty"` // contains filtered or unexported fields }
RenameDestinationConnectorResponse represents a renamed DestinationConnector resource
func (*RenameDestinationConnectorResponse) Descriptor
deprecated
func (*RenameDestinationConnectorResponse) Descriptor() ([]byte, []int)
Deprecated: Use RenameDestinationConnectorResponse.ProtoReflect.Descriptor instead.
func (*RenameDestinationConnectorResponse) GetDestinationConnector ¶
func (x *RenameDestinationConnectorResponse) GetDestinationConnector() *DestinationConnector
func (*RenameDestinationConnectorResponse) ProtoMessage ¶
func (*RenameDestinationConnectorResponse) ProtoMessage()
func (*RenameDestinationConnectorResponse) ProtoReflect ¶
func (x *RenameDestinationConnectorResponse) ProtoReflect() protoreflect.Message
func (*RenameDestinationConnectorResponse) Reset ¶
func (x *RenameDestinationConnectorResponse) Reset()
func (*RenameDestinationConnectorResponse) String ¶
func (x *RenameDestinationConnectorResponse) String() string
type RenameSourceConnectorRequest ¶
type RenameSourceConnectorRequest struct { // SourceConnector resource name. It must have the format of // "source-connectors/*" Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // SourceConnector new resource id to replace with the // SourceConnector resource name to be // "source-connectors/{new_source_connector_id}" NewSourceConnectorId string `protobuf:"bytes,2,opt,name=new_source_connector_id,json=newSourceConnectorId,proto3" json:"new_source_connector_id,omitempty"` // contains filtered or unexported fields }
RenameSourceConnectorRequest represents a request to rename the SourceConnector resource name
func (*RenameSourceConnectorRequest) Descriptor
deprecated
func (*RenameSourceConnectorRequest) Descriptor() ([]byte, []int)
Deprecated: Use RenameSourceConnectorRequest.ProtoReflect.Descriptor instead.
func (*RenameSourceConnectorRequest) GetName ¶
func (x *RenameSourceConnectorRequest) GetName() string
func (*RenameSourceConnectorRequest) GetNewSourceConnectorId ¶
func (x *RenameSourceConnectorRequest) GetNewSourceConnectorId() string
func (*RenameSourceConnectorRequest) ProtoMessage ¶
func (*RenameSourceConnectorRequest) ProtoMessage()
func (*RenameSourceConnectorRequest) ProtoReflect ¶
func (x *RenameSourceConnectorRequest) ProtoReflect() protoreflect.Message
func (*RenameSourceConnectorRequest) Reset ¶
func (x *RenameSourceConnectorRequest) Reset()
func (*RenameSourceConnectorRequest) String ¶
func (x *RenameSourceConnectorRequest) String() string
type RenameSourceConnectorResponse ¶
type RenameSourceConnectorResponse struct { // A SourceConnector resource SourceConnector *SourceConnector `protobuf:"bytes,1,opt,name=source_connector,json=sourceConnector,proto3" json:"source_connector,omitempty"` // contains filtered or unexported fields }
RenameSourceConnectorResponse represents a renamed SourceConnector resource
func (*RenameSourceConnectorResponse) Descriptor
deprecated
func (*RenameSourceConnectorResponse) Descriptor() ([]byte, []int)
Deprecated: Use RenameSourceConnectorResponse.ProtoReflect.Descriptor instead.
func (*RenameSourceConnectorResponse) GetSourceConnector ¶
func (x *RenameSourceConnectorResponse) GetSourceConnector() *SourceConnector
func (*RenameSourceConnectorResponse) ProtoMessage ¶
func (*RenameSourceConnectorResponse) ProtoMessage()
func (*RenameSourceConnectorResponse) ProtoReflect ¶
func (x *RenameSourceConnectorResponse) ProtoReflect() protoreflect.Message
func (*RenameSourceConnectorResponse) Reset ¶
func (x *RenameSourceConnectorResponse) Reset()
func (*RenameSourceConnectorResponse) String ¶
func (x *RenameSourceConnectorResponse) String() string
type SourceConnector ¶
type SourceConnector struct { // SourceConnector resource name. It must have the format of // "source-connectors/*" Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // SourceConnector UUID Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"` // SourceConnector resource ID (the last segment of the resource name) used to // construct the resource name. This conforms to RFC-1034, which restricts to // letters, numbers, and hyphen, with the first character a letter, the last a // letter or a number, and a 63 character maximum. Id string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"` // SourceConnectorDefinition resource SourceConnectorDefinition string `` /* 138-byte string literal not displayed */ // SourceConnector's connector data structure Connector *Connector `protobuf:"bytes,5,opt,name=connector,proto3" json:"connector,omitempty"` // contains filtered or unexported fields }
SourceConnector represents a source connector resource
func (*SourceConnector) Descriptor
deprecated
func (*SourceConnector) Descriptor() ([]byte, []int)
Deprecated: Use SourceConnector.ProtoReflect.Descriptor instead.
func (*SourceConnector) GetConnector ¶
func (x *SourceConnector) GetConnector() *Connector
func (*SourceConnector) GetId ¶
func (x *SourceConnector) GetId() string
func (*SourceConnector) GetName ¶
func (x *SourceConnector) GetName() string
func (*SourceConnector) GetSourceConnectorDefinition ¶
func (x *SourceConnector) GetSourceConnectorDefinition() string
func (*SourceConnector) GetUid ¶
func (x *SourceConnector) GetUid() string
func (*SourceConnector) ProtoMessage ¶
func (*SourceConnector) ProtoMessage()
func (*SourceConnector) ProtoReflect ¶
func (x *SourceConnector) ProtoReflect() protoreflect.Message
func (*SourceConnector) Reset ¶
func (x *SourceConnector) Reset()
func (*SourceConnector) String ¶
func (x *SourceConnector) String() string
type SourceConnectorDefinition ¶
type SourceConnectorDefinition struct { // SourceConnectorDefinition resource name. It must have the format of // "connector-definitions/*" Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // SourceConnectorDefinition UUID Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"` // SourceConnectorDefinition resource ID (the last segment of the resource // name) used to construct the resource name. This conforms to RFC-1034, which // restricts to letters, numbers, and hyphen, with the first character a // letter, the last a letter or a number, and a 63 character maximum. Id string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"` // SourceConnectorDefinition connector definition ConnectorDefinition *ConnectorDefinition `protobuf:"bytes,4,opt,name=connector_definition,json=connectorDefinition,proto3" json:"connector_definition,omitempty"` // contains filtered or unexported fields }
SourceConnectorDefinition represents the source connector definition resource
func (*SourceConnectorDefinition) Descriptor
deprecated
func (*SourceConnectorDefinition) Descriptor() ([]byte, []int)
Deprecated: Use SourceConnectorDefinition.ProtoReflect.Descriptor instead.
func (*SourceConnectorDefinition) GetConnectorDefinition ¶
func (x *SourceConnectorDefinition) GetConnectorDefinition() *ConnectorDefinition
func (*SourceConnectorDefinition) GetId ¶
func (x *SourceConnectorDefinition) GetId() string
func (*SourceConnectorDefinition) GetName ¶
func (x *SourceConnectorDefinition) GetName() string
func (*SourceConnectorDefinition) GetUid ¶
func (x *SourceConnectorDefinition) GetUid() string
func (*SourceConnectorDefinition) ProtoMessage ¶
func (*SourceConnectorDefinition) ProtoMessage()
func (*SourceConnectorDefinition) ProtoReflect ¶
func (x *SourceConnectorDefinition) ProtoReflect() protoreflect.Message
func (*SourceConnectorDefinition) Reset ¶
func (x *SourceConnectorDefinition) Reset()
func (*SourceConnectorDefinition) String ¶
func (x *SourceConnectorDefinition) String() string
type Spec ¶
type Spec struct { // Spec documentation URL DocumentationUrl string `protobuf:"bytes,1,opt,name=documentation_url,json=documentationUrl,proto3" json:"documentation_url,omitempty"` // Spec connection specification ConnectionSpecification *structpb.Struct `` /* 130-byte string literal not displayed */ // Spec supports incremental flag, i.e., if the connector supports incremental // mode or not SupportsIncremental bool `protobuf:"varint,3,opt,name=supports_incremental,json=supportsIncremental,proto3" json:"supports_incremental,omitempty"` // Spec supports normalization flag, i.e., if the connector supports // normalization or not SupportsNormalization bool `protobuf:"varint,4,opt,name=supports_normalization,json=supportsNormalization,proto3" json:"supports_normalization,omitempty"` // Spec supports dbt flag, i.e., if the connector supports DBT or not SupportsDbt bool `protobuf:"varint,5,opt,name=supports_dbt,json=supportsDbt,proto3" json:"supports_dbt,omitempty"` // Spec destination sync mode, i.e., a list of destination sync modes // supported by the connector SupportedDestinationSyncModes []SupportedDestinationSyncModes `` /* 217-byte string literal not displayed */ // Spec advanced auth, i.e., additional and optional specification object to // describe what an 'advanced' Auth flow would need to function AdvancedAuth *AdvancedAuth `protobuf:"bytes,7,opt,name=advanced_auth,json=advancedAuth,proto3" json:"advanced_auth,omitempty"` // contains filtered or unexported fields }
////////////////////////////////// Spec represents a spec data model
func (*Spec) Descriptor
deprecated
func (*Spec) GetAdvancedAuth ¶
func (x *Spec) GetAdvancedAuth() *AdvancedAuth
func (*Spec) GetConnectionSpecification ¶
func (*Spec) GetDocumentationUrl ¶
func (*Spec) GetSupportedDestinationSyncModes ¶
func (x *Spec) GetSupportedDestinationSyncModes() []SupportedDestinationSyncModes
func (*Spec) GetSupportsDbt ¶
func (*Spec) GetSupportsIncremental ¶
func (*Spec) GetSupportsNormalization ¶
func (*Spec) ProtoMessage ¶
func (*Spec) ProtoMessage()
func (*Spec) ProtoReflect ¶
func (x *Spec) ProtoReflect() protoreflect.Message
type SupportedDestinationSyncModes ¶
type SupportedDestinationSyncModes int32
SupportedDestinationSyncModes enumerates destination sync mode (this needs to be in plural form to match with Airbyte protocol)
const ( // SupportedDestinationSyncModes: DESTINATION_SYNC_MODES_UNSPECIFIED SupportedDestinationSyncModes_SUPPORTED_DESTINATION_SYNC_MODES_UNSPECIFIED SupportedDestinationSyncModes = 0 // SupportedDestinationSyncModes: DESTINATION_SYNC_MODES_APPEND SupportedDestinationSyncModes_SUPPORTED_DESTINATION_SYNC_MODES_APPEND SupportedDestinationSyncModes = 1 // SupportedDestinationSyncModes: DESTINATION_SYNC_MODES_OVERWRITE SupportedDestinationSyncModes_SUPPORTED_DESTINATION_SYNC_MODES_OVERWRITE SupportedDestinationSyncModes = 2 // SupportedDestinationSyncModes: DESTINATION_SYNC_MODES_APPEND_DEDUP SupportedDestinationSyncModes_SUPPORTED_DESTINATION_SYNC_MODES_APPEND_DEDUP SupportedDestinationSyncModes = 3 )
func (SupportedDestinationSyncModes) Descriptor ¶
func (SupportedDestinationSyncModes) Descriptor() protoreflect.EnumDescriptor
func (SupportedDestinationSyncModes) Enum ¶
func (x SupportedDestinationSyncModes) Enum() *SupportedDestinationSyncModes
func (SupportedDestinationSyncModes) EnumDescriptor
deprecated
func (SupportedDestinationSyncModes) EnumDescriptor() ([]byte, []int)
Deprecated: Use SupportedDestinationSyncModes.Descriptor instead.
func (SupportedDestinationSyncModes) Number ¶
func (x SupportedDestinationSyncModes) Number() protoreflect.EnumNumber
func (SupportedDestinationSyncModes) String ¶
func (x SupportedDestinationSyncModes) String() string
func (SupportedDestinationSyncModes) Type ¶
func (SupportedDestinationSyncModes) Type() protoreflect.EnumType
type SupportedSyncModes ¶
type SupportedSyncModes int32
SupportedSyncModes enumerates sync mode (this needs to be in plural form to match with Airbyte protocol)
const ( // SupportedSyncModes: SUPPORTED_SYNC_MODES_UNSPECIFIED SupportedSyncModes_SUPPORTED_SYNC_MODES_UNSPECIFIED SupportedSyncModes = 0 // SupportedSyncModes: SUPPORTED_SYNC_MODES_FULL_REFRESH SupportedSyncModes_SUPPORTED_SYNC_MODES_FULL_REFRESH SupportedSyncModes = 1 // SupportedSyncModes: SUPPORTED_SYNC_MODES_INCREMENTAL SupportedSyncModes_SUPPORTED_SYNC_MODES_INCREMENTAL SupportedSyncModes = 2 )
func (SupportedSyncModes) Descriptor ¶
func (SupportedSyncModes) Descriptor() protoreflect.EnumDescriptor
func (SupportedSyncModes) Enum ¶
func (x SupportedSyncModes) Enum() *SupportedSyncModes
func (SupportedSyncModes) EnumDescriptor
deprecated
func (SupportedSyncModes) EnumDescriptor() ([]byte, []int)
Deprecated: Use SupportedSyncModes.Descriptor instead.
func (SupportedSyncModes) Number ¶
func (x SupportedSyncModes) Number() protoreflect.EnumNumber
func (SupportedSyncModes) String ¶
func (x SupportedSyncModes) String() string
func (SupportedSyncModes) Type ¶
func (SupportedSyncModes) Type() protoreflect.EnumType
type UnimplementedConnectorServiceServer ¶
type UnimplementedConnectorServiceServer struct { }
UnimplementedConnectorServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedConnectorServiceServer) ConnectDestinationConnector ¶
func (UnimplementedConnectorServiceServer) ConnectDestinationConnector(context.Context, *ConnectDestinationConnectorRequest) (*ConnectDestinationConnectorResponse, error)
func (UnimplementedConnectorServiceServer) ConnectSourceConnector ¶
func (UnimplementedConnectorServiceServer) ConnectSourceConnector(context.Context, *ConnectSourceConnectorRequest) (*ConnectSourceConnectorResponse, error)
func (UnimplementedConnectorServiceServer) CreateDestinationConnector ¶
func (UnimplementedConnectorServiceServer) CreateDestinationConnector(context.Context, *CreateDestinationConnectorRequest) (*CreateDestinationConnectorResponse, error)
func (UnimplementedConnectorServiceServer) CreateSourceConnector ¶
func (UnimplementedConnectorServiceServer) CreateSourceConnector(context.Context, *CreateSourceConnectorRequest) (*CreateSourceConnectorResponse, error)
func (UnimplementedConnectorServiceServer) DeleteDestinationConnector ¶
func (UnimplementedConnectorServiceServer) DeleteDestinationConnector(context.Context, *DeleteDestinationConnectorRequest) (*DeleteDestinationConnectorResponse, error)
func (UnimplementedConnectorServiceServer) DeleteSourceConnector ¶
func (UnimplementedConnectorServiceServer) DeleteSourceConnector(context.Context, *DeleteSourceConnectorRequest) (*DeleteSourceConnectorResponse, error)
func (UnimplementedConnectorServiceServer) DisconnectDestinationConnector ¶
func (UnimplementedConnectorServiceServer) DisconnectDestinationConnector(context.Context, *DisconnectDestinationConnectorRequest) (*DisconnectDestinationConnectorResponse, error)
func (UnimplementedConnectorServiceServer) DisconnectSourceConnector ¶
func (UnimplementedConnectorServiceServer) DisconnectSourceConnector(context.Context, *DisconnectSourceConnectorRequest) (*DisconnectSourceConnectorResponse, error)
func (UnimplementedConnectorServiceServer) GetDestinationConnector ¶
func (UnimplementedConnectorServiceServer) GetDestinationConnector(context.Context, *GetDestinationConnectorRequest) (*GetDestinationConnectorResponse, error)
func (UnimplementedConnectorServiceServer) GetDestinationConnectorDefinition ¶
func (UnimplementedConnectorServiceServer) GetDestinationConnectorDefinition(context.Context, *GetDestinationConnectorDefinitionRequest) (*GetDestinationConnectorDefinitionResponse, error)
func (UnimplementedConnectorServiceServer) GetSourceConnector ¶
func (UnimplementedConnectorServiceServer) GetSourceConnector(context.Context, *GetSourceConnectorRequest) (*GetSourceConnectorResponse, error)
func (UnimplementedConnectorServiceServer) GetSourceConnectorDefinition ¶
func (UnimplementedConnectorServiceServer) GetSourceConnectorDefinition(context.Context, *GetSourceConnectorDefinitionRequest) (*GetSourceConnectorDefinitionResponse, error)
func (UnimplementedConnectorServiceServer) ListDestinationConnector ¶
func (UnimplementedConnectorServiceServer) ListDestinationConnector(context.Context, *ListDestinationConnectorRequest) (*ListDestinationConnectorResponse, error)
func (UnimplementedConnectorServiceServer) ListDestinationConnectorDefinition ¶
func (UnimplementedConnectorServiceServer) ListDestinationConnectorDefinition(context.Context, *ListDestinationConnectorDefinitionRequest) (*ListDestinationConnectorDefinitionResponse, error)
func (UnimplementedConnectorServiceServer) ListSourceConnector ¶
func (UnimplementedConnectorServiceServer) ListSourceConnector(context.Context, *ListSourceConnectorRequest) (*ListSourceConnectorResponse, error)
func (UnimplementedConnectorServiceServer) ListSourceConnectorDefinition ¶
func (UnimplementedConnectorServiceServer) ListSourceConnectorDefinition(context.Context, *ListSourceConnectorDefinitionRequest) (*ListSourceConnectorDefinitionResponse, error)
func (UnimplementedConnectorServiceServer) Liveness ¶
func (UnimplementedConnectorServiceServer) Liveness(context.Context, *LivenessRequest) (*LivenessResponse, error)
func (UnimplementedConnectorServiceServer) LookUpDestinationConnector ¶
func (UnimplementedConnectorServiceServer) LookUpDestinationConnector(context.Context, *LookUpDestinationConnectorRequest) (*LookUpDestinationConnectorResponse, error)
func (UnimplementedConnectorServiceServer) LookUpSourceConnector ¶
func (UnimplementedConnectorServiceServer) LookUpSourceConnector(context.Context, *LookUpSourceConnectorRequest) (*LookUpSourceConnectorResponse, error)
func (UnimplementedConnectorServiceServer) ReadSourceConnector ¶
func (UnimplementedConnectorServiceServer) ReadSourceConnector(context.Context, *ReadSourceConnectorRequest) (*ReadSourceConnectorResponse, error)
func (UnimplementedConnectorServiceServer) Readiness ¶
func (UnimplementedConnectorServiceServer) Readiness(context.Context, *ReadinessRequest) (*ReadinessResponse, error)
func (UnimplementedConnectorServiceServer) RenameDestinationConnector ¶
func (UnimplementedConnectorServiceServer) RenameDestinationConnector(context.Context, *RenameDestinationConnectorRequest) (*RenameDestinationConnectorResponse, error)
func (UnimplementedConnectorServiceServer) RenameSourceConnector ¶
func (UnimplementedConnectorServiceServer) RenameSourceConnector(context.Context, *RenameSourceConnectorRequest) (*RenameSourceConnectorResponse, error)
func (UnimplementedConnectorServiceServer) UpdateDestinationConnector ¶
func (UnimplementedConnectorServiceServer) UpdateDestinationConnector(context.Context, *UpdateDestinationConnectorRequest) (*UpdateDestinationConnectorResponse, error)
func (UnimplementedConnectorServiceServer) UpdateSourceConnector ¶
func (UnimplementedConnectorServiceServer) UpdateSourceConnector(context.Context, *UpdateSourceConnectorRequest) (*UpdateSourceConnectorResponse, error)
func (UnimplementedConnectorServiceServer) WriteDestinationConnector ¶
func (UnimplementedConnectorServiceServer) WriteDestinationConnector(context.Context, *WriteDestinationConnectorRequest) (*WriteDestinationConnectorResponse, error)
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 UpdateDestinationConnectorRequest ¶
type UpdateDestinationConnectorRequest struct { // DestinationConnector resource DestinationConnector *DestinationConnector `protobuf:"bytes,1,opt,name=destination_connector,json=destinationConnector,proto3" json:"destination_connector,omitempty"` // Update mask for a DestinationConnector resource UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"` // contains filtered or unexported fields }
UpdateDestinationConnectorRequest represents a request to update a DestinationConnector resource
func (*UpdateDestinationConnectorRequest) Descriptor
deprecated
func (*UpdateDestinationConnectorRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateDestinationConnectorRequest.ProtoReflect.Descriptor instead.
func (*UpdateDestinationConnectorRequest) GetDestinationConnector ¶
func (x *UpdateDestinationConnectorRequest) GetDestinationConnector() *DestinationConnector
func (*UpdateDestinationConnectorRequest) GetUpdateMask ¶
func (x *UpdateDestinationConnectorRequest) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdateDestinationConnectorRequest) ProtoMessage ¶
func (*UpdateDestinationConnectorRequest) ProtoMessage()
func (*UpdateDestinationConnectorRequest) ProtoReflect ¶
func (x *UpdateDestinationConnectorRequest) ProtoReflect() protoreflect.Message
func (*UpdateDestinationConnectorRequest) Reset ¶
func (x *UpdateDestinationConnectorRequest) Reset()
func (*UpdateDestinationConnectorRequest) String ¶
func (x *UpdateDestinationConnectorRequest) String() string
type UpdateDestinationConnectorResponse ¶
type UpdateDestinationConnectorResponse struct { // DestinationConnector resource DestinationConnector *DestinationConnector `protobuf:"bytes,1,opt,name=destination_connector,json=destinationConnector,proto3" json:"destination_connector,omitempty"` // contains filtered or unexported fields }
UpdateDestinationConnectorResponse represents a response for a DestinationConnector resource
func (*UpdateDestinationConnectorResponse) Descriptor
deprecated
func (*UpdateDestinationConnectorResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateDestinationConnectorResponse.ProtoReflect.Descriptor instead.
func (*UpdateDestinationConnectorResponse) GetDestinationConnector ¶
func (x *UpdateDestinationConnectorResponse) GetDestinationConnector() *DestinationConnector
func (*UpdateDestinationConnectorResponse) ProtoMessage ¶
func (*UpdateDestinationConnectorResponse) ProtoMessage()
func (*UpdateDestinationConnectorResponse) ProtoReflect ¶
func (x *UpdateDestinationConnectorResponse) ProtoReflect() protoreflect.Message
func (*UpdateDestinationConnectorResponse) Reset ¶
func (x *UpdateDestinationConnectorResponse) Reset()
func (*UpdateDestinationConnectorResponse) String ¶
func (x *UpdateDestinationConnectorResponse) String() string
type UpdateSourceConnectorRequest ¶
type UpdateSourceConnectorRequest struct { // SourceConnector resource SourceConnector *SourceConnector `protobuf:"bytes,1,opt,name=source_connector,json=sourceConnector,proto3" json:"source_connector,omitempty"` // Update mask for a SourceConnector resource UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"` // contains filtered or unexported fields }
UpdateSourceConnectorRequest represents a request to update a SourceConnector resource
func (*UpdateSourceConnectorRequest) Descriptor
deprecated
func (*UpdateSourceConnectorRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateSourceConnectorRequest.ProtoReflect.Descriptor instead.
func (*UpdateSourceConnectorRequest) GetSourceConnector ¶
func (x *UpdateSourceConnectorRequest) GetSourceConnector() *SourceConnector
func (*UpdateSourceConnectorRequest) GetUpdateMask ¶
func (x *UpdateSourceConnectorRequest) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdateSourceConnectorRequest) ProtoMessage ¶
func (*UpdateSourceConnectorRequest) ProtoMessage()
func (*UpdateSourceConnectorRequest) ProtoReflect ¶
func (x *UpdateSourceConnectorRequest) ProtoReflect() protoreflect.Message
func (*UpdateSourceConnectorRequest) Reset ¶
func (x *UpdateSourceConnectorRequest) Reset()
func (*UpdateSourceConnectorRequest) String ¶
func (x *UpdateSourceConnectorRequest) String() string
type UpdateSourceConnectorResponse ¶
type UpdateSourceConnectorResponse struct { // SourceConnector resource SourceConnector *SourceConnector `protobuf:"bytes,1,opt,name=source_connector,json=sourceConnector,proto3" json:"source_connector,omitempty"` // contains filtered or unexported fields }
UpdateSourceConnectorResponse represents a response for a SourceConnector resource
func (*UpdateSourceConnectorResponse) Descriptor
deprecated
func (*UpdateSourceConnectorResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateSourceConnectorResponse.ProtoReflect.Descriptor instead.
func (*UpdateSourceConnectorResponse) GetSourceConnector ¶
func (x *UpdateSourceConnectorResponse) GetSourceConnector() *SourceConnector
func (*UpdateSourceConnectorResponse) ProtoMessage ¶
func (*UpdateSourceConnectorResponse) ProtoMessage()
func (*UpdateSourceConnectorResponse) ProtoReflect ¶
func (x *UpdateSourceConnectorResponse) ProtoReflect() protoreflect.Message
func (*UpdateSourceConnectorResponse) Reset ¶
func (x *UpdateSourceConnectorResponse) Reset()
func (*UpdateSourceConnectorResponse) String ¶
func (x *UpdateSourceConnectorResponse) String() string
type View ¶
type View int32
View enumerates the definition views
func (View) Descriptor ¶
func (View) Descriptor() protoreflect.EnumDescriptor
func (View) EnumDescriptor
deprecated
func (View) Number ¶
func (x View) Number() protoreflect.EnumNumber
func (View) Type ¶
func (View) Type() protoreflect.EnumType
type WriteDestinationConnectorRequest ¶
type WriteDestinationConnectorRequest struct { // DestinationConnector resource name. It must have the format of // "destination-connectors/*" Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Sync mode: // https://docs.airbyte.com/understanding-airbyte/connections/#sync-modes SyncMode SupportedSyncModes `` /* 132-byte string literal not displayed */ // Destination sync mode: // https://docs.airbyte.com/understanding-airbyte/connections/#sync-modes DestinationSyncMode SupportedDestinationSyncModes `` /* 178-byte string literal not displayed */ // Pipeline resource name Pipeline string `protobuf:"bytes,4,opt,name=pipeline,proto3" json:"pipeline,omitempty"` // Pipeline recipe Recipe *v1alpha.Recipe `protobuf:"bytes,5,opt,name=recipe,proto3" json:"recipe,omitempty"` // Indices corresponds to each JSON data element DataMappingIndices []string `protobuf:"bytes,6,rep,name=data_mapping_indices,json=dataMappingIndices,proto3" json:"data_mapping_indices,omitempty"` // JSON data to write ModelInstanceOutputs []*v1alpha.ModelInstanceOutput `protobuf:"bytes,7,rep,name=model_instance_outputs,json=modelInstanceOutputs,proto3" json:"model_instance_outputs,omitempty"` // contains filtered or unexported fields }
WriteDestinationConnectorRequest represents a request to perform write operation of a DestinationConnector given the resource name
func (*WriteDestinationConnectorRequest) Descriptor
deprecated
func (*WriteDestinationConnectorRequest) Descriptor() ([]byte, []int)
Deprecated: Use WriteDestinationConnectorRequest.ProtoReflect.Descriptor instead.
func (*WriteDestinationConnectorRequest) GetDataMappingIndices ¶
func (x *WriteDestinationConnectorRequest) GetDataMappingIndices() []string
func (*WriteDestinationConnectorRequest) GetDestinationSyncMode ¶
func (x *WriteDestinationConnectorRequest) GetDestinationSyncMode() SupportedDestinationSyncModes
func (*WriteDestinationConnectorRequest) GetModelInstanceOutputs ¶
func (x *WriteDestinationConnectorRequest) GetModelInstanceOutputs() []*v1alpha.ModelInstanceOutput
func (*WriteDestinationConnectorRequest) GetName ¶
func (x *WriteDestinationConnectorRequest) GetName() string
func (*WriteDestinationConnectorRequest) GetPipeline ¶
func (x *WriteDestinationConnectorRequest) GetPipeline() string
func (*WriteDestinationConnectorRequest) GetRecipe ¶
func (x *WriteDestinationConnectorRequest) GetRecipe() *v1alpha.Recipe
func (*WriteDestinationConnectorRequest) GetSyncMode ¶
func (x *WriteDestinationConnectorRequest) GetSyncMode() SupportedSyncModes
func (*WriteDestinationConnectorRequest) ProtoMessage ¶
func (*WriteDestinationConnectorRequest) ProtoMessage()
func (*WriteDestinationConnectorRequest) ProtoReflect ¶
func (x *WriteDestinationConnectorRequest) ProtoReflect() protoreflect.Message
func (*WriteDestinationConnectorRequest) Reset ¶
func (x *WriteDestinationConnectorRequest) Reset()
func (*WriteDestinationConnectorRequest) String ¶
func (x *WriteDestinationConnectorRequest) String() string
type WriteDestinationConnectorResponse ¶
type WriteDestinationConnectorResponse struct {
// contains filtered or unexported fields
}
WriteDestinationConnectorResponse represents the read data from a DestinationConnector resource
func (*WriteDestinationConnectorResponse) Descriptor
deprecated
func (*WriteDestinationConnectorResponse) Descriptor() ([]byte, []int)
Deprecated: Use WriteDestinationConnectorResponse.ProtoReflect.Descriptor instead.
func (*WriteDestinationConnectorResponse) ProtoMessage ¶
func (*WriteDestinationConnectorResponse) ProtoMessage()
func (*WriteDestinationConnectorResponse) ProtoReflect ¶
func (x *WriteDestinationConnectorResponse) ProtoReflect() protoreflect.Message
func (*WriteDestinationConnectorResponse) Reset ¶
func (x *WriteDestinationConnectorResponse) Reset()
func (*WriteDestinationConnectorResponse) String ¶
func (x *WriteDestinationConnectorResponse) String() string