connector

package
v0.0.0-...-f60a318 Latest Latest
Warning

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

 Go to latest Published: May 5, 2021 License: Apache-2.0 Imports: 12 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	PayloadKind_name = map[int32]string{
		0: "PAYLOAD_KIND_UNSPECIFIED",
		1: "PAYLOAD_KIND_STREAM",
		2: "PAYLOAD_KIND_CONFIG",
	}
	PayloadKind_value = map[string]int32{
		"PAYLOAD_KIND_UNSPECIFIED": 0,
		"PAYLOAD_KIND_STREAM":      1,
		"PAYLOAD_KIND_CONFIG":      2,
	}
)

Enum value maps for PayloadKind.

View Source 
var (
	StreamDirection_name = map[int32]string{
		0: "STREAM_DIRECTION_UNSPECIFIED",
		1: "STREAM_DIRECTION_INGRESS",
		2: "STREAM_DIRECTION_EGRESS",
	}
	StreamDirection_value = map[string]int32{
		"STREAM_DIRECTION_UNSPECIFIED": 0,
		"STREAM_DIRECTION_INGRESS":     1,
		"STREAM_DIRECTION_EGRESS":      2,
	}
)

Enum value maps for StreamDirection.

View Source 
var (
	ResponseCode_name = map[int32]string{
		0:  "RESPONSE_CODE_UNSPECIFIED",
		1:  "RESPONSE_CODE_OK",
		2:  "RESPONSE_CODE_CANCELLED",
		3:  "RESPONSE_CODE_UNKNOWN",
		4:  "RESPONSE_CODE_INVALID_ARGUMENT",
		5:  "RESPONSE_CODE_DEADLINE_EXCEEDED",
		6:  "RESPONSE_CODE_NOT_FOUND",
		7:  "RESPONSE_CODE_ALREADY_EXISTS",
		8:  "RESPONSE_CODE_PERMISSION_DENIED",
		9:  "RESPONSE_CODE_UNAUTHENTICATED",
		10: "RESPONSE_CODE_RESOURCE_EXHAUSTED",
		11: "RESPONSE_CODE_FAILED_PRECONDITION",
		12: "RESPONSE_CODE_ABORTED",
		13: "RESPONSE_CODE_OUT_OF_RANGE",
		14: "RESPONSE_CODE_UNIMPLEMENTED",
		15: "RESPONSE_CODE_INTERNAL",
		16: "RESPONSE_CODE_UNAVAILABLE",
		17: "RESPONSE_CODE_DATA_LOSS",
	}
	ResponseCode_value = map[string]int32{
		"RESPONSE_CODE_UNSPECIFIED":         0,
		"RESPONSE_CODE_OK":                  1,
		"RESPONSE_CODE_CANCELLED":           2,
		"RESPONSE_CODE_UNKNOWN":             3,
		"RESPONSE_CODE_INVALID_ARGUMENT":    4,
		"RESPONSE_CODE_DEADLINE_EXCEEDED":   5,
		"RESPONSE_CODE_NOT_FOUND":           6,
		"RESPONSE_CODE_ALREADY_EXISTS":      7,
		"RESPONSE_CODE_PERMISSION_DENIED":   8,
		"RESPONSE_CODE_UNAUTHENTICATED":     9,
		"RESPONSE_CODE_RESOURCE_EXHAUSTED":  10,
		"RESPONSE_CODE_FAILED_PRECONDITION": 11,
		"RESPONSE_CODE_ABORTED":             12,
		"RESPONSE_CODE_OUT_OF_RANGE":        13,
		"RESPONSE_CODE_UNIMPLEMENTED":       14,
		"RESPONSE_CODE_INTERNAL":            15,
		"RESPONSE_CODE_UNAVAILABLE":         16,
		"RESPONSE_CODE_DATA_LOSS":           17,
	}
)

Enum value maps for ResponseCode.

View Source 
var (
	Severity_name = map[int32]string{
		0: "SEVERITY_UNSPECIFIED",
		1: "SEVERITY_INFO",
		2: "SEVERITY_WARNING",
		3: "SEVERITY_CRITICAL",
	}
	Severity_value = map[string]int32{
		"SEVERITY_UNSPECIFIED": 0,
		"SEVERITY_INFO":        1,
		"SEVERITY_WARNING":     2,
		"SEVERITY_CRITICAL":    3,
	}
)

Enum value maps for Severity.

View Source 
var (
	State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "STATE_PROVISIONING",
		2: "STATE_PROVISIONED",
		3: "STATE_FAILED",
		4: "STATE_HEALTHY",
		5: "STATE_UNHEALTHY",
	}
	State_value = map[string]int32{
		"STATE_UNSPECIFIED":  0,
		"STATE_PROVISIONING": 1,
		"STATE_PROVISIONED":  2,
		"STATE_FAILED":       3,
		"STATE_HEALTHY":      4,
		"STATE_UNHEALTHY":    5,
	}
)

Enum value maps for State.

View Source 
var ConnectorService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "connector.v1.ConnectorService",
	HandlerType: (*ConnectorServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetPayload",
			Handler:    _ConnectorService_GetPayload_Handler,
		},
		{
			MethodName: "SetPayload",
			Handler:    _ConnectorService_SetPayload_Handler,
		},
		{
			MethodName: "GetEvents",
			Handler:    _ConnectorService_GetEvents_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "connector/v1/connector.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_connector_v1_connector_proto protoreflect.FileDescriptor

Functions

func RegisterConnectorServiceServer 

func RegisterConnectorServiceServer(s grpc.ServiceRegistrar, srv ConnectorServiceServer)

Types

type Alert 

type Alert struct {
	Id        string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	StreamId  string               `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Message   string               `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Severity  Severity             `protobuf:"varint,4,opt,name=severity,proto3,enum=connector.v1.Severity" json:"severity,omitempty"`
	State     State                `protobuf:"varint,5,opt,name=state,proto3,enum=connector.v1.State" json:"state,omitempty"`
	CreatedAt *timestamp.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	Metadata  *_struct.Struct      `protobuf:"bytes,7,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Alert

func (*Alert) Descriptor deprecated 

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

Deprecated: Use Alert.ProtoReflect.Descriptor instead.

func (*Alert) GetCreatedAt 

func (x *Alert) GetCreatedAt() *timestamp.Timestamp

func (*Alert) GetId 

func (x *Alert) GetId() string

func (*Alert) GetMessage 

func (x *Alert) GetMessage() string

func (*Alert) GetMetadata 

func (x *Alert) GetMetadata() *_struct.Struct

func (*Alert) GetSeverity 

func (x *Alert) GetSeverity() Severity

func (*Alert) GetState 

func (x *Alert) GetState() State

func (*Alert) GetStreamId 

func (x *Alert) GetStreamId() string

func (*Alert) ProtoMessage 

func (*Alert) ProtoMessage()

func (*Alert) ProtoReflect 

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

func (*Alert) Reset 

func (x *Alert) Reset()

func (*Alert) String 

func (x *Alert) String() string

type Config 

type Config struct {
	Metadata *_struct.Struct `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Config is a mechanism for handling dynamic config in the connector. For static config, we recommend using config defined in kubernetes resource definition.

func (*Config) Descriptor deprecated 

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

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetMetadata 

func (x *Config) GetMetadata() *_struct.Struct

func (*Config) ProtoMessage 

func (*Config) ProtoMessage()

func (*Config) ProtoReflect 

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

func (*Config) Reset 

func (x *Config) Reset()

func (*Config) String 

func (x *Config) String() string

type ConnectorServiceClient 

type ConnectorServiceClient interface {
	// GetPayload should return all payloads given a payload kind:
	//   - If payload kind is set to STREAM, it should return all available streams (including discovered streams)
	//   - If payload kind is set to CONFIG, it should return the current config in use.
	GetPayload(ctx context.Context, in *GetPayloadRequest, opts ...grpc.CallOption) (*GetPayloadResponse, error)
	// SetPayload takes a connector ID and a list of payloads and applies those
	// payloads to the relevant connector:
	//   - Payloads of kind STREAM should be subscribed to by the connector
	//   - Payloads of kind CONFIG should be used to update the current connector config
	SetPayload(ctx context.Context, in *SetPayloadRequest, opts ...grpc.CallOption) (*SetPayloadResponse, error)
	// GetEvents returns all the events for a given connector ID. Events can be of type Alert or Status
	GetEvents(ctx context.Context, in *GetEventsRequest, opts ...grpc.CallOption) (*GetEventsResponse, error)
}

ConnectorServiceClient is the client API for ConnectorService service.

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

func NewConnectorServiceClient 

func NewConnectorServiceClient(cc grpc.ClientConnInterface) ConnectorServiceClient

type ConnectorServiceServer 

type ConnectorServiceServer interface {
	// GetPayload should return all payloads given a payload kind:
	//   - If payload kind is set to STREAM, it should return all available streams (including discovered streams)
	//   - If payload kind is set to CONFIG, it should return the current config in use.
	GetPayload(context.Context, *GetPayloadRequest) (*GetPayloadResponse, error)
	// SetPayload takes a connector ID and a list of payloads and applies those
	// payloads to the relevant connector:
	//   - Payloads of kind STREAM should be subscribed to by the connector
	//   - Payloads of kind CONFIG should be used to update the current connector config
	SetPayload(context.Context, *SetPayloadRequest) (*SetPayloadResponse, error)
	// GetEvents returns all the events for a given connector ID. Events can be of type Alert or Status
	GetEvents(context.Context, *GetEventsRequest) (*GetEventsResponse, error)
	// contains filtered or unexported methods
}

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

type EventPayload 

type EventPayload struct {

	// Types that are assignable to Object:
	//	*EventPayload_Alert
	//	*EventPayload_Status
	Object isEventPayload_Object `protobuf_oneof:"object"`
	// contains filtered or unexported fields
}

Payload is a union of possible payload types

func (*EventPayload) Descriptor deprecated 

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

Deprecated: Use EventPayload.ProtoReflect.Descriptor instead.

func (*EventPayload) GetAlert 

func (x *EventPayload) GetAlert() *Alert

func (*EventPayload) GetObject 

func (m *EventPayload) GetObject() isEventPayload_Object

func (*EventPayload) GetStatus 

func (x *EventPayload) GetStatus() *Status

func (*EventPayload) ProtoMessage 

func (*EventPayload) ProtoMessage()

func (*EventPayload) ProtoReflect 

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

func (*EventPayload) Reset 

func (x *EventPayload) Reset()

func (*EventPayload) String 

func (x *EventPayload) String() string

type EventPayload_Alert 

type EventPayload_Alert struct {
	Alert *Alert `protobuf:"bytes,1,opt,name=alert,proto3,oneof"`
}

type EventPayload_Status 

type EventPayload_Status struct {
	Status *Status `protobuf:"bytes,2,opt,name=status,proto3,oneof"`
}

type GetEventsRequest 

type GetEventsRequest struct {
	ConnectorId string `protobuf:"bytes,1,opt,name=connector_id,json=connectorId,proto3" json:"connector_id,omitempty"`
	// contains filtered or unexported fields
}

GetEventsRequest specifies the connector ID of the connector to fetch the events from

func (*GetEventsRequest) Descriptor deprecated 

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

Deprecated: Use GetEventsRequest.ProtoReflect.Descriptor instead.

func (*GetEventsRequest) GetConnectorId 

func (x *GetEventsRequest) GetConnectorId() string

func (*GetEventsRequest) ProtoMessage 

func (*GetEventsRequest) ProtoMessage()

func (*GetEventsRequest) ProtoReflect 

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

func (*GetEventsRequest) Reset 

func (x *GetEventsRequest) Reset()

func (*GetEventsRequest) String 

func (x *GetEventsRequest) String() string

type GetEventsResponse 

type GetEventsResponse struct {
	Status        *ResponseStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	EventPayloads []*EventPayload `protobuf:"bytes,2,rep,name=event_payloads,json=eventPayloads,proto3" json:"event_payloads,omitempty"`
	// contains filtered or unexported fields
}

GetEventsResponse specifies the status of the request along with the list of events

func (*GetEventsResponse) Descriptor deprecated 

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

Deprecated: Use GetEventsResponse.ProtoReflect.Descriptor instead.

func (*GetEventsResponse) GetEventPayloads 

func (x *GetEventsResponse) GetEventPayloads() []*EventPayload

func (*GetEventsResponse) GetStatus 

func (x *GetEventsResponse) GetStatus() *ResponseStatus

func (*GetEventsResponse) ProtoMessage 

func (*GetEventsResponse) ProtoMessage()

func (*GetEventsResponse) ProtoReflect 

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

func (*GetEventsResponse) Reset 

func (x *GetEventsResponse) Reset()

func (*GetEventsResponse) String 

func (x *GetEventsResponse) String() string

type GetPayloadRequest 

type GetPayloadRequest struct {
	ConnectorId string      `protobuf:"bytes,1,opt,name=connector_id,json=connectorId,proto3" json:"connector_id,omitempty"`
	Kind        PayloadKind `protobuf:"varint,2,opt,name=kind,proto3,enum=connector.v1.PayloadKind" json:"kind,omitempty"`
	// contains filtered or unexported fields
}

GetPayloadRequest specifies the PayloadKind of expected Payloads requested for a given connector ID. e.g. A GetPayloadRequest with kind set to STREAM is expected to return all available streams for that connector ID.

func (*GetPayloadRequest) Descriptor deprecated 

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

Deprecated: Use GetPayloadRequest.ProtoReflect.Descriptor instead.

func (*GetPayloadRequest) GetConnectorId 

func (x *GetPayloadRequest) GetConnectorId() string

func (*GetPayloadRequest) GetKind 

func (x *GetPayloadRequest) GetKind() PayloadKind

func (*GetPayloadRequest) ProtoMessage 

func (*GetPayloadRequest) ProtoMessage()

func (*GetPayloadRequest) ProtoReflect 

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

func (*GetPayloadRequest) Reset 

func (x *GetPayloadRequest) Reset()

func (*GetPayloadRequest) String 

func (x *GetPayloadRequest) String() string

type GetPayloadResponse 

type GetPayloadResponse struct {
	Status   *ResponseStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Payloads []*Payload      `protobuf:"bytes,2,rep,name=payloads,proto3" json:"payloads,omitempty"`
	// contains filtered or unexported fields
}

GetPayloadResponse specifies the status of the request and the Payloads

func (*GetPayloadResponse) Descriptor deprecated 

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

Deprecated: Use GetPayloadResponse.ProtoReflect.Descriptor instead.

func (*GetPayloadResponse) GetPayloads 

func (x *GetPayloadResponse) GetPayloads() []*Payload

func (*GetPayloadResponse) GetStatus 

func (x *GetPayloadResponse) GetStatus() *ResponseStatus

func (*GetPayloadResponse) ProtoMessage 

func (*GetPayloadResponse) ProtoMessage()

func (*GetPayloadResponse) ProtoReflect 

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

func (*GetPayloadResponse) Reset 

func (x *GetPayloadResponse) Reset()

func (*GetPayloadResponse) String 

func (x *GetPayloadResponse) String() string

type Payload 

type Payload struct {

	// Types that are assignable to Object:
	//	*Payload_Config
	//	*Payload_Stream
	Object isPayload_Object `protobuf_oneof:"object"`
	// contains filtered or unexported fields
}

Payload is a union of possible payload types

func (*Payload) Descriptor deprecated 

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

Deprecated: Use Payload.ProtoReflect.Descriptor instead.

func (*Payload) GetConfig 

func (x *Payload) GetConfig() *Config

func (*Payload) GetObject 

func (m *Payload) GetObject() isPayload_Object

func (*Payload) GetStream 

func (x *Payload) GetStream() *Stream

func (*Payload) ProtoMessage 

func (*Payload) ProtoMessage()

func (*Payload) ProtoReflect 

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

func (*Payload) Reset 

func (x *Payload) Reset()

func (*Payload) String 

func (x *Payload) String() string

type PayloadKind 

type PayloadKind int32

PayloadKind specifies the type of Payload e.g. Stream, Config, etc. The enum is expected to grow as new use cases arise. We do not intend to have credentials as a payload kind as it is not a good practice to transfer credentials via a cleartext API. We recommend developers use Kubernetes secrets for credentials management. 

const (
	PayloadKind_PAYLOAD_KIND_UNSPECIFIED PayloadKind = 0
	PayloadKind_PAYLOAD_KIND_STREAM      PayloadKind = 1
	PayloadKind_PAYLOAD_KIND_CONFIG      PayloadKind = 2
)

func (PayloadKind) Descriptor 

func (PayloadKind) Descriptor() protoreflect.EnumDescriptor

func (PayloadKind) Enum 

func (x PayloadKind) Enum() *PayloadKind

func (PayloadKind) EnumDescriptor deprecated 

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

Deprecated: Use PayloadKind.Descriptor instead.

func (PayloadKind) Number 

func (x PayloadKind) Number() protoreflect.EnumNumber

func (PayloadKind) String 

func (x PayloadKind) String() string

func (PayloadKind) Type 

func (PayloadKind) Type() protoreflect.EnumType

type Payload_Config 

type Payload_Config struct {
	Config *Config `protobuf:"bytes,1,opt,name=config,proto3,oneof"`
}

type Payload_Stream 

type Payload_Stream struct {
	Stream *Stream `protobuf:"bytes,2,opt,name=stream,proto3,oneof"`
}

type ResponseCode 

type ResponseCode int32

ResponseCode provides a subset of response codes that are modelled after the HTTP-style error codes for specifying the state of the request. All successful requests should return OK. All other requests should appropriately set the right error code. 

const (
	ResponseCode_RESPONSE_CODE_UNSPECIFIED ResponseCode = 0
	// Not an error; returned on success
	//
	// HTTP Mapping: 200 OK
	ResponseCode_RESPONSE_CODE_OK ResponseCode = 1
	// The operation was cancelled, typically by the caller.
	//
	// HTTP Mapping: 499 Client Closed Request
	ResponseCode_RESPONSE_CODE_CANCELLED ResponseCode = 2
	// Unknown error.  For example, this error may be returned when
	// a `Status` value received from another address space belongs to
	// an error space that is not known in this address space.  Also
	// errors raised by APIs that do not return enough error information
	// may be converted to this error.
	//
	// HTTP Mapping: 500 Internal Server Error
	ResponseCode_RESPONSE_CODE_UNKNOWN ResponseCode = 3
	// The client specified an invalid argument.  Note that this differs
	// from `FAILED_PRECONDITION`.  `INVALID_ARGUMENT` indicates arguments
	// that are problematic regardless of the state of the system
	// (e.g., a malformed file name).
	//
	// HTTP Mapping: 400 Bad Request
	ResponseCode_RESPONSE_CODE_INVALID_ARGUMENT ResponseCode = 4
	// The deadline expired before the operation could complete. For operations
	// that change the state of the system, this error may be returned
	// even if the operation has completed successfully.  For example, a
	// successful response from a server could have been delayed long
	// enough for the deadline to expire.
	//
	// HTTP Mapping: 504 Gateway Timeout
	ResponseCode_RESPONSE_CODE_DEADLINE_EXCEEDED ResponseCode = 5
	// Some requested entity (e.g., file or directory) was not found.
	//
	// Note to server developers: if a request is denied for an entire class
	// of users, such as gradual feature rollout or undocumented whitelist,
	// `NOT_FOUND` may be used. If a request is denied for some users within
	// a class of users, such as user-based access control, `PERMISSION_DENIED`
	// must be used.
	//
	// HTTP Mapping: 404 Not Found
	ResponseCode_RESPONSE_CODE_NOT_FOUND ResponseCode = 6
	// The entity that a client attempted to create (e.g., file or directory)
	// already exists.
	//
	// HTTP Mapping: 409 Conflict
	ResponseCode_RESPONSE_CODE_ALREADY_EXISTS ResponseCode = 7
	// The caller does not have permission to execute the specified
	// operation. `PERMISSION_DENIED` must not be used for rejections
	// caused by exhausting some resource (use `RESOURCE_EXHAUSTED`
	// instead for those errors). `PERMISSION_DENIED` must not be
	// used if the caller can not be identified (use `UNAUTHENTICATED`
	// instead for those errors). This error code does not imply the
	// request is valid or the requested entity exists or satisfies
	// other pre-conditions.
	//
	// HTTP Mapping: 403 Forbidden
	ResponseCode_RESPONSE_CODE_PERMISSION_DENIED ResponseCode = 8
	// The request does not have valid authentication credentials for the
	// operation.
	//
	// HTTP Mapping: 401 Unauthorized
	ResponseCode_RESPONSE_CODE_UNAUTHENTICATED ResponseCode = 9
	// Some resource has been exhausted, perhaps a per-user quota, or
	// perhaps the entire file system is out of space.
	//
	// HTTP Mapping: 429 Too Many Requests
	ResponseCode_RESPONSE_CODE_RESOURCE_EXHAUSTED ResponseCode = 10
	// The operation was rejected because the system is not in a state
	// required for the operation's execution.  For example, the directory
	// to be deleted is non-empty, an rmdir operation is applied to
	// a non-directory, etc.
	//
	// HTTP Mapping: 400 Bad Request
	ResponseCode_RESPONSE_CODE_FAILED_PRECONDITION ResponseCode = 11
	// The operation was aborted, typically due to a concurrency issue such as
	// a sequencer check failure or transaction abort.
	//
	// HTTP Mapping: 409 Conflict
	ResponseCode_RESPONSE_CODE_ABORTED ResponseCode = 12
	// The operation was attempted past the valid range.  E.g., seeking or
	// reading past end-of-file.
	//
	// Unlike `INVALID_ARGUMENT`, this error indicates a problem that may
	// be fixed if the system state changes. For example, a 32-bit file
	// system will generate `INVALID_ARGUMENT` if asked to read at an
	// offset that is not in the range [0,2^32-1], but it will generate
	// `OUT_OF_RANGE` if asked to read from an offset past the current
	// file size.
	//
	// HTTP Mapping: 400 Bad Request
	ResponseCode_RESPONSE_CODE_OUT_OF_RANGE ResponseCode = 13
	// The operation is not implemented or is not supported/enabled in this
	// service.
	//
	// HTTP Mapping: 501 Not Implemented
	ResponseCode_RESPONSE_CODE_UNIMPLEMENTED ResponseCode = 14
	// Internal errors.  This means that some invariants expected by the
	// underlying system have been broken.  This error code is reserved
	// for serious errors.
	//
	// HTTP Mapping: 500 Internal Server Error
	ResponseCode_RESPONSE_CODE_INTERNAL ResponseCode = 15
	// The service is currently unavailable.  This is most likely a
	// transient condition, which can be corrected by retrying with
	// a backoff. Note that it is not always safe to retry
	// non-idempotent operations.
	//
	// HTTP Mapping: 503 Service Unavailable
	ResponseCode_RESPONSE_CODE_UNAVAILABLE ResponseCode = 16
	// Unrecoverable data loss or corruption.
	//
	// HTTP Mapping: 500 Internal Server Error
	ResponseCode_RESPONSE_CODE_DATA_LOSS ResponseCode = 17
)

func (ResponseCode) Descriptor 

func (ResponseCode) Descriptor() protoreflect.EnumDescriptor

func (ResponseCode) Enum 

func (x ResponseCode) Enum() *ResponseCode

func (ResponseCode) EnumDescriptor deprecated 

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

Deprecated: Use ResponseCode.Descriptor instead.

func (ResponseCode) Number 

func (x ResponseCode) Number() protoreflect.EnumNumber

func (ResponseCode) String 

func (x ResponseCode) String() string

func (ResponseCode) Type 

func (ResponseCode) Type() protoreflect.EnumType

type ResponseStatus 

type ResponseStatus struct {
	Code    ResponseCode `protobuf:"varint,1,opt,name=code,proto3,enum=connector.v1.ResponseCode" json:"code,omitempty"`
	Message string       `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Details []*any.Any   `protobuf:"bytes,3,rep,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

Status wraps the code, message, and details necessary for understanding the response from the connector

func (*ResponseStatus) Descriptor deprecated 

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

Deprecated: Use ResponseStatus.ProtoReflect.Descriptor instead.

func (*ResponseStatus) GetCode 

func (x *ResponseStatus) GetCode() ResponseCode

func (*ResponseStatus) GetDetails 

func (x *ResponseStatus) GetDetails() []*any.Any

func (*ResponseStatus) GetMessage 

func (x *ResponseStatus) GetMessage() string

func (*ResponseStatus) ProtoMessage 

func (*ResponseStatus) ProtoMessage()

func (*ResponseStatus) ProtoReflect 

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

func (*ResponseStatus) Reset 

func (x *ResponseStatus) Reset()

func (*ResponseStatus) String 

func (x *ResponseStatus) String() string

type SetPayloadRequest 

type SetPayloadRequest struct {
	ConnectorId string     `protobuf:"bytes,1,opt,name=connector_id,json=connectorId,proto3" json:"connector_id,omitempty"`
	Payloads    []*Payload `protobuf:"bytes,2,rep,name=payloads,proto3" json:"payloads,omitempty"`
	// contains filtered or unexported fields
}

SetPayloadRequest specifies the Payloads to be applied to a connector with a given connector ID.

func (*SetPayloadRequest) Descriptor deprecated 

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

Deprecated: Use SetPayloadRequest.ProtoReflect.Descriptor instead.

func (*SetPayloadRequest) GetConnectorId 

func (x *SetPayloadRequest) GetConnectorId() string

func (*SetPayloadRequest) GetPayloads 

func (x *SetPayloadRequest) GetPayloads() []*Payload

func (*SetPayloadRequest) ProtoMessage 

func (*SetPayloadRequest) ProtoMessage()

func (*SetPayloadRequest) ProtoReflect 

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

func (*SetPayloadRequest) Reset 

func (x *SetPayloadRequest) Reset()

func (*SetPayloadRequest) String 

func (x *SetPayloadRequest) String() string

type SetPayloadResponse 

type SetPayloadResponse struct {
	Status *ResponseStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

SetPayloadResponse specifies the status of the request

func (*SetPayloadResponse) Descriptor deprecated 

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

Deprecated: Use SetPayloadResponse.ProtoReflect.Descriptor instead.

func (*SetPayloadResponse) GetStatus 

func (x *SetPayloadResponse) GetStatus() *ResponseStatus

func (*SetPayloadResponse) ProtoMessage 

func (*SetPayloadResponse) ProtoMessage()

func (*SetPayloadResponse) ProtoReflect 

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

func (*SetPayloadResponse) Reset 

func (x *SetPayloadResponse) Reset()

func (*SetPayloadResponse) String 

func (x *SetPayloadResponse) String() string

type Severity 

type Severity int32
const (
	Severity_SEVERITY_UNSPECIFIED Severity = 0
	Severity_SEVERITY_INFO        Severity = 1
	Severity_SEVERITY_WARNING     Severity = 2
	Severity_SEVERITY_CRITICAL    Severity = 3
)

func (Severity) Descriptor 

func (Severity) Descriptor() protoreflect.EnumDescriptor

func (Severity) Enum 

func (x Severity) Enum() *Severity

func (Severity) EnumDescriptor deprecated 

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

Deprecated: Use Severity.Descriptor instead.

func (Severity) Number 

func (x Severity) Number() protoreflect.EnumNumber

func (Severity) String 

func (x Severity) String() string

func (Severity) Type 

func (Severity) Type() protoreflect.EnumType

type State 

type State int32
const (
	State_STATE_UNSPECIFIED  State = 0
	State_STATE_PROVISIONING State = 1
	State_STATE_PROVISIONED  State = 2
	State_STATE_FAILED       State = 3
	State_STATE_HEALTHY      State = 4
	State_STATE_UNHEALTHY    State = 5
)

func (State) Descriptor 

func (State) Descriptor() protoreflect.EnumDescriptor

func (State) Enum 

func (x State) Enum() *State

func (State) EnumDescriptor deprecated 

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

Deprecated: Use State.Descriptor instead.

func (State) Number 

func (x State) Number() protoreflect.EnumNumber

func (State) String 

func (x State) String() string

func (State) Type 

func (State) Type() protoreflect.EnumType

type Status 

type Status struct {
	Id        string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	StreamId  string               `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Message   string               `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	State     State                `protobuf:"varint,4,opt,name=state,proto3,enum=connector.v1.State" json:"state,omitempty"`
	CreatedAt *timestamp.Timestamp `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	Metadata  *_struct.Struct      `protobuf:"bytes,6,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Status

func (*Status) Descriptor deprecated 

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetCreatedAt 

func (x *Status) GetCreatedAt() *timestamp.Timestamp

func (*Status) GetId 

func (x *Status) GetId() string

func (*Status) GetMessage 

func (x *Status) GetMessage() string

func (*Status) GetMetadata 

func (x *Status) GetMetadata() *_struct.Struct

func (*Status) GetState 

func (x *Status) GetState() State

func (*Status) GetStreamId 

func (x *Status) GetStreamId() string

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect 

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

func (*Status) Reset 

func (x *Status) Reset()

func (*Status) String 

func (x *Status) String() string

type Stream 

type Stream struct {

	// name is an identifier for the stream
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// subscribed specifies whether the stream is already subscribed to
	Subscribed bool `protobuf:"varint,2,opt,name=subscribed,proto3" json:"subscribed,omitempty"`
	// discovered specifies whether the stream was discovered by the connector instance
	Discovered bool `protobuf:"varint,3,opt,name=discovered,proto3" json:"discovered,omitempty"`
	// direction specifies the direction of data flow for a given stream i.e. ingress / egress
	Direction StreamDirection `protobuf:"varint,4,opt,name=direction,proto3,enum=connector.v1.StreamDirection" json:"direction,omitempty"`
	// transport_channel specifies the channel for sending the stream through or receiving the stream from
	TransportChannel string `protobuf:"bytes,5,opt,name=transport_channel,json=transportChannel,proto3" json:"transport_channel,omitempty"`
	// metadata is for storing the stream object
	Metadata *_struct.Struct `protobuf:"bytes,6,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Stream is a mechanism for:

  • Discovering what available streams can be subscribed to via GetPayloadRequest
  • Subscribing/Unsubscribing to those streams via SetPayloadRequest

func (*Stream) Descriptor deprecated 

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

Deprecated: Use Stream.ProtoReflect.Descriptor instead.

func (*Stream) GetDirection 

func (x *Stream) GetDirection() StreamDirection

func (*Stream) GetDiscovered 

func (x *Stream) GetDiscovered() bool

func (*Stream) GetId 

func (x *Stream) GetId() string

func (*Stream) GetMetadata 

func (x *Stream) GetMetadata() *_struct.Struct

func (*Stream) GetSubscribed 

func (x *Stream) GetSubscribed() bool

func (*Stream) GetTransportChannel 

func (x *Stream) GetTransportChannel() string

func (*Stream) ProtoMessage 

func (*Stream) ProtoMessage()

func (*Stream) ProtoReflect 

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

func (*Stream) Reset 

func (x *Stream) Reset()

func (*Stream) String 

func (x *Stream) String() string

type StreamDirection 

type StreamDirection int32
const (
	StreamDirection_STREAM_DIRECTION_UNSPECIFIED StreamDirection = 0
	// INGRESS specifies a direction where data flows from the stream to data pipeline transport
	StreamDirection_STREAM_DIRECTION_INGRESS StreamDirection = 1
	// EGRESS specifies a direction where data flows from data pipeline transport to the stream
	StreamDirection_STREAM_DIRECTION_EGRESS StreamDirection = 2
)

func (StreamDirection) Descriptor 

func (StreamDirection) Descriptor() protoreflect.EnumDescriptor

func (StreamDirection) Enum 

func (x StreamDirection) Enum() *StreamDirection

func (StreamDirection) EnumDescriptor deprecated 

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

Deprecated: Use StreamDirection.Descriptor instead.

func (StreamDirection) Number 

func (x StreamDirection) Number() protoreflect.EnumNumber

func (StreamDirection) String 

func (x StreamDirection) String() string

func (StreamDirection) Type 

func (StreamDirection) Type() protoreflect.EnumType

type TransportMessage 

type TransportMessage struct {
	Timestamp int64    `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // Epoch time in nanosecs
	Payload   [][]byte `protobuf:"bytes,3,rep,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*TransportMessage) Descriptor deprecated 

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

Deprecated: Use TransportMessage.ProtoReflect.Descriptor instead.

func (*TransportMessage) GetPayload 

func (x *TransportMessage) GetPayload() [][]byte

func (*TransportMessage) GetTimestamp 

func (x *TransportMessage) GetTimestamp() int64

func (*TransportMessage) ProtoMessage 

func (*TransportMessage) ProtoMessage()

func (*TransportMessage) ProtoReflect 

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

func (*TransportMessage) Reset 

func (x *TransportMessage) Reset()

func (*TransportMessage) String 

func (x *TransportMessage) String() string

type UnimplementedConnectorServiceServer 

type UnimplementedConnectorServiceServer struct {
}

UnimplementedConnectorServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedConnectorServiceServer) GetEvents 

func (UnimplementedConnectorServiceServer) GetEvents(context.Context, *GetEventsRequest) (*GetEventsResponse, error)

func (UnimplementedConnectorServiceServer) GetPayload 

func (UnimplementedConnectorServiceServer) GetPayload(context.Context, *GetPayloadRequest) (*GetPayloadResponse, error)

func (UnimplementedConnectorServiceServer) SetPayload 

func (UnimplementedConnectorServiceServer) SetPayload(context.Context, *SetPayloadRequest) (*SetPayloadResponse, error)

type UnsafeConnectorServiceServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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