connectorv1alpha

package
v0.3.3-alpha Latest Latest
Warning

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

Go to latest
Published: Sep 14, 2022 License: Apache-2.0 Imports: 23 Imported by: 22

Documentation

Overview

Package connectorv1alpha is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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)

View Source
var File_vdp_connector_v1alpha_auth_proto protoreflect.FileDescriptor
View Source
var File_vdp_connector_v1alpha_connector_definition_proto protoreflect.FileDescriptor
View Source
var File_vdp_connector_v1alpha_connector_proto protoreflect.FileDescriptor
View Source
var File_vdp_connector_v1alpha_connector_service_proto protoreflect.FileDescriptor
View Source
var File_vdp_connector_v1alpha_healthcheck_proto protoreflect.FileDescriptor
View Source
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) Enum

func (AdvancedAuth_AuthFlowType) EnumDescriptor deprecated

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

Deprecated: Use AdvancedAuth_AuthFlowType.Descriptor instead.

func (AdvancedAuth_AuthFlowType) Number

func (AdvancedAuth_AuthFlowType) String

func (x AdvancedAuth_AuthFlowType) String() string

func (AdvancedAuth_AuthFlowType) Type

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 (*ConnectDestinationConnectorRequest) ProtoMessage

func (*ConnectDestinationConnectorRequest) ProtoMessage()

func (*ConnectDestinationConnectorRequest) ProtoReflect

func (*ConnectDestinationConnectorRequest) Reset

func (*ConnectDestinationConnectorRequest) 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 (*ConnectDestinationConnectorResponse) Reset

func (*ConnectDestinationConnectorResponse) 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 (*ConnectSourceConnectorRequest) ProtoMessage

func (*ConnectSourceConnectorRequest) ProtoMessage()

func (*ConnectSourceConnectorRequest) ProtoReflect

func (*ConnectSourceConnectorRequest) Reset

func (x *ConnectSourceConnectorRequest) Reset()

func (*ConnectSourceConnectorRequest) 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 (*ConnectSourceConnectorResponse) Reset

func (x *ConnectSourceConnectorResponse) Reset()

func (*ConnectSourceConnectorResponse) 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) Descriptor() ([]byte, []int)

Deprecated: Use Connector.ProtoReflect.Descriptor instead.

func (*Connector) GetConfiguration

func (x *Connector) GetConfiguration() *structpb.Struct

func (*Connector) GetCreateTime

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

func (*Connector) GetDescription

func (x *Connector) GetDescription() string

func (*Connector) GetOrg

func (x *Connector) GetOrg() string

func (*Connector) GetOwner

func (m *Connector) GetOwner() isConnector_Owner

func (*Connector) GetState

func (x *Connector) GetState() Connector_State

func (*Connector) GetTombstone

func (x *Connector) GetTombstone() bool

func (*Connector) GetUpdateTime

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

func (*Connector) GetUser

func (x *Connector) GetUser() string

func (*Connector) ProtoMessage

func (*Connector) ProtoMessage()

func (*Connector) ProtoReflect

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

func (*Connector) Reset

func (x *Connector) Reset()

func (*Connector) String

func (x *Connector) String() string

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.

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) Enum

func (x ConnectorType) Enum() *ConnectorType

func (ConnectorType) EnumDescriptor deprecated

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

Deprecated: Use ConnectorType.Descriptor instead.

func (ConnectorType) Number

func (ConnectorType) String

func (x ConnectorType) String() string

func (ConnectorType) Type

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) 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 (Connector_State) String

func (x Connector_State) String() string

func (Connector_State) Type

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 (*CreateDestinationConnectorRequest) Reset

func (*CreateDestinationConnectorRequest) 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 (*CreateDestinationConnectorResponse) Reset

func (*CreateDestinationConnectorResponse) 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 (*CreateSourceConnectorRequest) Reset

func (x *CreateSourceConnectorRequest) Reset()

func (*CreateSourceConnectorRequest) 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 (*CreateSourceConnectorResponse) Reset

func (x *CreateSourceConnectorResponse) Reset()

func (*CreateSourceConnectorResponse) 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 (*DeleteDestinationConnectorRequest) ProtoMessage

func (*DeleteDestinationConnectorRequest) ProtoMessage()

func (*DeleteDestinationConnectorRequest) ProtoReflect

func (*DeleteDestinationConnectorRequest) Reset

func (*DeleteDestinationConnectorRequest) 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 (*DeleteDestinationConnectorResponse) Reset

func (*DeleteDestinationConnectorResponse) 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 (*DeleteSourceConnectorRequest) Reset

func (x *DeleteSourceConnectorRequest) Reset()

func (*DeleteSourceConnectorRequest) 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 (*DeleteSourceConnectorResponse) Reset

func (x *DeleteSourceConnectorResponse) Reset()

func (*DeleteSourceConnectorResponse) 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 (*DestinationConnectorDefinition) GetName

func (*DestinationConnectorDefinition) GetUid

func (*DestinationConnectorDefinition) ProtoMessage

func (*DestinationConnectorDefinition) ProtoMessage()

func (*DestinationConnectorDefinition) ProtoReflect

func (*DestinationConnectorDefinition) Reset

func (x *DestinationConnectorDefinition) Reset()

func (*DestinationConnectorDefinition) 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 (*DisconnectDestinationConnectorRequest) ProtoMessage

func (*DisconnectDestinationConnectorRequest) ProtoMessage()

func (*DisconnectDestinationConnectorRequest) ProtoReflect

func (*DisconnectDestinationConnectorRequest) Reset

func (*DisconnectDestinationConnectorRequest) 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) ProtoReflect

func (*DisconnectDestinationConnectorResponse) Reset

func (*DisconnectDestinationConnectorResponse) 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 (*DisconnectSourceConnectorRequest) ProtoMessage

func (*DisconnectSourceConnectorRequest) ProtoMessage()

func (*DisconnectSourceConnectorRequest) ProtoReflect

func (*DisconnectSourceConnectorRequest) Reset

func (*DisconnectSourceConnectorRequest) 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 (*DisconnectSourceConnectorResponse) Reset

func (*DisconnectSourceConnectorResponse) 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 (*GetDestinationConnectorDefinitionRequest) GetView

func (*GetDestinationConnectorDefinitionRequest) ProtoMessage

func (*GetDestinationConnectorDefinitionRequest) ProtoReflect

func (*GetDestinationConnectorDefinitionRequest) Reset

func (*GetDestinationConnectorDefinitionRequest) 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) ProtoReflect

func (*GetDestinationConnectorDefinitionResponse) Reset

func (*GetDestinationConnectorDefinitionResponse) 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 (*GetDestinationConnectorRequest) GetView

func (x *GetDestinationConnectorRequest) GetView() View

func (*GetDestinationConnectorRequest) ProtoMessage

func (*GetDestinationConnectorRequest) ProtoMessage()

func (*GetDestinationConnectorRequest) ProtoReflect

func (*GetDestinationConnectorRequest) Reset

func (x *GetDestinationConnectorRequest) Reset()

func (*GetDestinationConnectorRequest) 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 (*GetDestinationConnectorResponse) Reset

func (*GetDestinationConnectorResponse) 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 (*GetSourceConnectorDefinitionRequest) GetView

func (*GetSourceConnectorDefinitionRequest) ProtoMessage

func (*GetSourceConnectorDefinitionRequest) ProtoMessage()

func (*GetSourceConnectorDefinitionRequest) ProtoReflect

func (*GetSourceConnectorDefinitionRequest) Reset

func (*GetSourceConnectorDefinitionRequest) 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 (*GetSourceConnectorDefinitionResponse) Reset

func (*GetSourceConnectorDefinitionResponse) 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 (*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 (*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 (*ListDestinationConnectorDefinitionRequest) GetPageToken

func (*ListDestinationConnectorDefinitionRequest) GetView

func (*ListDestinationConnectorDefinitionRequest) ProtoMessage

func (*ListDestinationConnectorDefinitionRequest) ProtoReflect

func (*ListDestinationConnectorDefinitionRequest) Reset

func (*ListDestinationConnectorDefinitionRequest) 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

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 (*ListDestinationConnectorDefinitionResponse) ProtoMessage

func (*ListDestinationConnectorDefinitionResponse) ProtoReflect

func (*ListDestinationConnectorDefinitionResponse) Reset

func (*ListDestinationConnectorDefinitionResponse) 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 (*ListDestinationConnectorRequest) ProtoMessage

func (*ListDestinationConnectorRequest) ProtoMessage()

func (*ListDestinationConnectorRequest) ProtoReflect

func (*ListDestinationConnectorRequest) Reset

func (*ListDestinationConnectorRequest) 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 (*ListDestinationConnectorResponse) Reset

func (*ListDestinationConnectorResponse) 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 (*ListSourceConnectorDefinitionRequest) GetPageToken

func (x *ListSourceConnectorDefinitionRequest) GetPageToken() string

func (*ListSourceConnectorDefinitionRequest) GetView

func (*ListSourceConnectorDefinitionRequest) ProtoMessage

func (*ListSourceConnectorDefinitionRequest) ProtoMessage()

func (*ListSourceConnectorDefinitionRequest) ProtoReflect

func (*ListSourceConnectorDefinitionRequest) Reset

func (*ListSourceConnectorDefinitionRequest) 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 (*ListSourceConnectorDefinitionResponse) Reset

func (*ListSourceConnectorDefinitionResponse) 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 (*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 (*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 (x *LookUpDestinationConnectorRequest) GetPermalink() string

func (*LookUpDestinationConnectorRequest) GetView

func (*LookUpDestinationConnectorRequest) ProtoMessage

func (*LookUpDestinationConnectorRequest) ProtoMessage()

func (*LookUpDestinationConnectorRequest) ProtoReflect

func (*LookUpDestinationConnectorRequest) Reset

func (*LookUpDestinationConnectorRequest) 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 (*LookUpDestinationConnectorResponse) Reset

func (*LookUpDestinationConnectorResponse) 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 (x *LookUpSourceConnectorRequest) GetPermalink() string

func (*LookUpSourceConnectorRequest) GetView

func (x *LookUpSourceConnectorRequest) GetView() View

func (*LookUpSourceConnectorRequest) ProtoMessage

func (*LookUpSourceConnectorRequest) ProtoMessage()

func (*LookUpSourceConnectorRequest) ProtoReflect

func (*LookUpSourceConnectorRequest) Reset

func (x *LookUpSourceConnectorRequest) Reset()

func (*LookUpSourceConnectorRequest) 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 (*LookUpSourceConnectorResponse) Reset

func (x *LookUpSourceConnectorResponse) Reset()

func (*LookUpSourceConnectorResponse) 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 (*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 (*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) Enum

func (x ReleaseStage) Enum() *ReleaseStage

func (ReleaseStage) EnumDescriptor deprecated

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

Deprecated: Use ReleaseStage.Descriptor instead.

func (ReleaseStage) Number

func (ReleaseStage) String

func (x ReleaseStage) String() string

func (ReleaseStage) Type

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 (*RenameDestinationConnectorRequest) GetNewDestinationConnectorId

func (x *RenameDestinationConnectorRequest) GetNewDestinationConnectorId() string

func (*RenameDestinationConnectorRequest) ProtoMessage

func (*RenameDestinationConnectorRequest) ProtoMessage()

func (*RenameDestinationConnectorRequest) ProtoReflect

func (*RenameDestinationConnectorRequest) Reset

func (*RenameDestinationConnectorRequest) 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 (*RenameDestinationConnectorResponse) Reset

func (*RenameDestinationConnectorResponse) 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 (*RenameSourceConnectorRequest) Reset

func (x *RenameSourceConnectorRequest) Reset()

func (*RenameSourceConnectorRequest) 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 (*RenameSourceConnectorResponse) Reset

func (x *RenameSourceConnectorResponse) Reset()

func (*RenameSourceConnectorResponse) 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 (*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) Descriptor() ([]byte, []int)

Deprecated: Use Spec.ProtoReflect.Descriptor instead.

func (*Spec) GetAdvancedAuth

func (x *Spec) GetAdvancedAuth() *AdvancedAuth

func (*Spec) GetConnectionSpecification

func (x *Spec) GetConnectionSpecification() *structpb.Struct

func (*Spec) GetDocumentationUrl

func (x *Spec) GetDocumentationUrl() string

func (*Spec) GetSupportedDestinationSyncModes

func (x *Spec) GetSupportedDestinationSyncModes() []SupportedDestinationSyncModes

func (*Spec) GetSupportsDbt

func (x *Spec) GetSupportsDbt() bool

func (*Spec) GetSupportsIncremental

func (x *Spec) GetSupportsIncremental() bool

func (*Spec) GetSupportsNormalization

func (x *Spec) GetSupportsNormalization() bool

func (*Spec) ProtoMessage

func (*Spec) ProtoMessage()

func (*Spec) ProtoReflect

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

func (*Spec) Reset

func (x *Spec) Reset()

func (*Spec) String

func (x *Spec) String() string

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) Enum

func (SupportedDestinationSyncModes) EnumDescriptor deprecated

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

Deprecated: Use SupportedDestinationSyncModes.Descriptor instead.

func (SupportedDestinationSyncModes) Number

func (SupportedDestinationSyncModes) String

func (SupportedDestinationSyncModes) Type

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) Enum

func (SupportedSyncModes) EnumDescriptor deprecated

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

Deprecated: Use SupportedSyncModes.Descriptor instead.

func (SupportedSyncModes) Number

func (SupportedSyncModes) String

func (x SupportedSyncModes) String() string

func (SupportedSyncModes) Type

type UnimplementedConnectorServiceServer

type UnimplementedConnectorServiceServer struct {
}

UnimplementedConnectorServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedConnectorServiceServer) GetSourceConnector

func (UnimplementedConnectorServiceServer) ListSourceConnector

func (UnimplementedConnectorServiceServer) Liveness

func (UnimplementedConnectorServiceServer) ReadSourceConnector

func (UnimplementedConnectorServiceServer) Readiness

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 (*UpdateDestinationConnectorRequest) ProtoMessage

func (*UpdateDestinationConnectorRequest) ProtoMessage()

func (*UpdateDestinationConnectorRequest) ProtoReflect

func (*UpdateDestinationConnectorRequest) Reset

func (*UpdateDestinationConnectorRequest) 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 (*UpdateDestinationConnectorResponse) Reset

func (*UpdateDestinationConnectorResponse) 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 (*UpdateSourceConnectorRequest) ProtoMessage

func (*UpdateSourceConnectorRequest) ProtoMessage()

func (*UpdateSourceConnectorRequest) ProtoReflect

func (*UpdateSourceConnectorRequest) Reset

func (x *UpdateSourceConnectorRequest) Reset()

func (*UpdateSourceConnectorRequest) 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 (*UpdateSourceConnectorResponse) Reset

func (x *UpdateSourceConnectorResponse) Reset()

func (*UpdateSourceConnectorResponse) String

type View

type View int32

View enumerates the definition views

const (
	// View: UNSPECIFIED
	View_VIEW_UNSPECIFIED View = 0
	// View: BASIC
	View_VIEW_BASIC View = 1
	// View: FULL
	View_VIEW_FULL View = 2
)

func (View) Descriptor

func (View) Descriptor() protoreflect.EnumDescriptor

func (View) Enum

func (x View) Enum() *View

func (View) EnumDescriptor deprecated

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

Deprecated: Use View.Descriptor instead.

func (View) Number

func (x View) Number() protoreflect.EnumNumber

func (View) String

func (x View) String() string

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 (*WriteDestinationConnectorRequest) GetModelInstanceOutputs

func (x *WriteDestinationConnectorRequest) GetModelInstanceOutputs() []*v1alpha.ModelInstanceOutput

func (*WriteDestinationConnectorRequest) GetName

func (*WriteDestinationConnectorRequest) GetPipeline

func (x *WriteDestinationConnectorRequest) GetPipeline() string

func (*WriteDestinationConnectorRequest) GetRecipe

func (*WriteDestinationConnectorRequest) GetSyncMode

func (*WriteDestinationConnectorRequest) ProtoMessage

func (*WriteDestinationConnectorRequest) ProtoMessage()

func (*WriteDestinationConnectorRequest) ProtoReflect

func (*WriteDestinationConnectorRequest) Reset

func (*WriteDestinationConnectorRequest) 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 (*WriteDestinationConnectorResponse) Reset

func (*WriteDestinationConnectorResponse) String

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL