sink

package
v0.55.0 Latest Latest
Warning

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

Go to latest
Published: Feb 17, 2026 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthMessage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type GCSSpec

type GCSSpec struct {
	// The customer service account ID that Temporal Cloud impersonates for writing records to the customer's GCS bucket.
	SaId string `protobuf:"bytes,1,opt,name=sa_id,json=saId,proto3" json:"sa_id,omitempty"`
	// The name of the destination GCS bucket where Temporal will send data.
	BucketName string `protobuf:"bytes,2,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// The GCP project ID associated with the GCS bucket and service account.
	GcpProjectId string `protobuf:"bytes,3,opt,name=gcp_project_id,json=gcpProjectId,proto3" json:"gcp_project_id,omitempty"`
	// The region of the gcs bucket
	Region string `protobuf:"bytes,4,opt,name=region,proto3" json:"region,omitempty"`
}

func (*GCSSpec) Descriptor

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

func (*GCSSpec) Equal

func (this *GCSSpec) Equal(that interface{}) bool

func (*GCSSpec) GetBucketName

func (m *GCSSpec) GetBucketName() string

func (*GCSSpec) GetGcpProjectId

func (m *GCSSpec) GetGcpProjectId() string

func (*GCSSpec) GetRegion added in v0.38.0

func (m *GCSSpec) GetRegion() string

func (*GCSSpec) GetSaId

func (m *GCSSpec) GetSaId() string

func (*GCSSpec) GoString

func (this *GCSSpec) GoString() string

func (*GCSSpec) Marshal

func (m *GCSSpec) Marshal() (dAtA []byte, err error)

func (*GCSSpec) MarshalTo

func (m *GCSSpec) MarshalTo(dAtA []byte) (int, error)

func (*GCSSpec) MarshalToSizedBuffer

func (m *GCSSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GCSSpec) ProtoMessage

func (*GCSSpec) ProtoMessage()

func (*GCSSpec) Reset

func (m *GCSSpec) Reset()

func (*GCSSpec) Size

func (m *GCSSpec) Size() (n int)

func (*GCSSpec) String

func (this *GCSSpec) String() string

func (*GCSSpec) Unmarshal

func (m *GCSSpec) Unmarshal(dAtA []byte) error

func (*GCSSpec) XXX_DiscardUnknown

func (m *GCSSpec) XXX_DiscardUnknown()

func (*GCSSpec) XXX_Marshal

func (m *GCSSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GCSSpec) XXX_Merge

func (m *GCSSpec) XXX_Merge(src proto.Message)

func (*GCSSpec) XXX_Size

func (m *GCSSpec) XXX_Size() int

func (*GCSSpec) XXX_Unmarshal

func (m *GCSSpec) XXX_Unmarshal(b []byte) error

type KinesisSpec added in v0.51.0

type KinesisSpec struct {
	// The role Temporal Cloud assumes when writing records to Kinesis
	RoleName string `protobuf:"bytes,1,opt,name=role_name,json=roleName,proto3" json:"role_name,omitempty"`
	// Destination Kinesis endpoint arn for temporal to send data to.
	DestinationUri string `protobuf:"bytes,2,opt,name=destination_uri,json=destinationUri,proto3" json:"destination_uri,omitempty"`
	// The sink's region.
	Region string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
}

func (*KinesisSpec) Descriptor added in v0.51.0

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

func (*KinesisSpec) Equal added in v0.51.0

func (this *KinesisSpec) Equal(that interface{}) bool

func (*KinesisSpec) GetDestinationUri added in v0.51.0

func (m *KinesisSpec) GetDestinationUri() string

func (*KinesisSpec) GetRegion added in v0.51.0

func (m *KinesisSpec) GetRegion() string

func (*KinesisSpec) GetRoleName added in v0.51.0

func (m *KinesisSpec) GetRoleName() string

func (*KinesisSpec) GoString added in v0.51.0

func (this *KinesisSpec) GoString() string

func (*KinesisSpec) Marshal added in v0.51.0

func (m *KinesisSpec) Marshal() (dAtA []byte, err error)

func (*KinesisSpec) MarshalTo added in v0.51.0

func (m *KinesisSpec) MarshalTo(dAtA []byte) (int, error)

func (*KinesisSpec) MarshalToSizedBuffer added in v0.51.0

func (m *KinesisSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KinesisSpec) ProtoMessage added in v0.51.0

func (*KinesisSpec) ProtoMessage()

func (*KinesisSpec) Reset added in v0.51.0

func (m *KinesisSpec) Reset()

func (*KinesisSpec) Size added in v0.51.0

func (m *KinesisSpec) Size() (n int)

func (*KinesisSpec) String added in v0.51.0

func (this *KinesisSpec) String() string

func (*KinesisSpec) Unmarshal added in v0.51.0

func (m *KinesisSpec) Unmarshal(dAtA []byte) error

func (*KinesisSpec) XXX_DiscardUnknown added in v0.51.0

func (m *KinesisSpec) XXX_DiscardUnknown()

func (*KinesisSpec) XXX_Marshal added in v0.51.0

func (m *KinesisSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KinesisSpec) XXX_Merge added in v0.51.0

func (m *KinesisSpec) XXX_Merge(src proto.Message)

func (*KinesisSpec) XXX_Size added in v0.51.0

func (m *KinesisSpec) XXX_Size() int

func (*KinesisSpec) XXX_Unmarshal added in v0.51.0

func (m *KinesisSpec) XXX_Unmarshal(b []byte) error

type PubSubSpec added in v0.51.0

type PubSubSpec struct {
	// The customer service account id that Temporal Cloud impersonates for writing records to customer's pubsub topic
	ServiceAccountId string `protobuf:"bytes,1,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"`
	// Destination pubsub topic name for us
	TopicName string `protobuf:"bytes,2,opt,name=topic_name,json=topicName,proto3" json:"topic_name,omitempty"`
	// The gcp project id of pubsub topic and service account
	GcpProjectId string `protobuf:"bytes,3,opt,name=gcp_project_id,json=gcpProjectId,proto3" json:"gcp_project_id,omitempty"`
}

func (*PubSubSpec) Descriptor added in v0.51.0

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

func (*PubSubSpec) Equal added in v0.51.0

func (this *PubSubSpec) Equal(that interface{}) bool

func (*PubSubSpec) GetGcpProjectId added in v0.51.0

func (m *PubSubSpec) GetGcpProjectId() string

func (*PubSubSpec) GetServiceAccountId added in v0.51.0

func (m *PubSubSpec) GetServiceAccountId() string

func (*PubSubSpec) GetTopicName added in v0.51.0

func (m *PubSubSpec) GetTopicName() string

func (*PubSubSpec) GoString added in v0.51.0

func (this *PubSubSpec) GoString() string

func (*PubSubSpec) Marshal added in v0.51.0

func (m *PubSubSpec) Marshal() (dAtA []byte, err error)

func (*PubSubSpec) MarshalTo added in v0.51.0

func (m *PubSubSpec) MarshalTo(dAtA []byte) (int, error)

func (*PubSubSpec) MarshalToSizedBuffer added in v0.51.0

func (m *PubSubSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PubSubSpec) ProtoMessage added in v0.51.0

func (*PubSubSpec) ProtoMessage()

func (*PubSubSpec) Reset added in v0.51.0

func (m *PubSubSpec) Reset()

func (*PubSubSpec) Size added in v0.51.0

func (m *PubSubSpec) Size() (n int)

func (*PubSubSpec) String added in v0.51.0

func (this *PubSubSpec) String() string

func (*PubSubSpec) Unmarshal added in v0.51.0

func (m *PubSubSpec) Unmarshal(dAtA []byte) error

func (*PubSubSpec) XXX_DiscardUnknown added in v0.51.0

func (m *PubSubSpec) XXX_DiscardUnknown()

func (*PubSubSpec) XXX_Marshal added in v0.51.0

func (m *PubSubSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PubSubSpec) XXX_Merge added in v0.51.0

func (m *PubSubSpec) XXX_Merge(src proto.Message)

func (*PubSubSpec) XXX_Size added in v0.51.0

func (m *PubSubSpec) XXX_Size() int

func (*PubSubSpec) XXX_Unmarshal added in v0.51.0

func (m *PubSubSpec) XXX_Unmarshal(b []byte) error

type S3Spec

type S3Spec struct {
	// The IAM role that Temporal Cloud assumes for writing records to the customer's S3 bucket.
	RoleName string `protobuf:"bytes,1,opt,name=role_name,json=roleName,proto3" json:"role_name,omitempty"`
	// The name of the destination S3 bucket where Temporal will send data.
	BucketName string `protobuf:"bytes,2,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// The region where the S3 bucket is located.
	Region string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
	// The AWS Key Management Service (KMS) ARN used for encryption.
	KmsArn string `protobuf:"bytes,4,opt,name=kms_arn,json=kmsArn,proto3" json:"kms_arn,omitempty"`
	// The AWS account ID associated with the S3 bucket and the assumed role.
	AwsAccountId string `protobuf:"bytes,5,opt,name=aws_account_id,json=awsAccountId,proto3" json:"aws_account_id,omitempty"`
}

func (*S3Spec) Descriptor

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

func (*S3Spec) Equal

func (this *S3Spec) Equal(that interface{}) bool

func (*S3Spec) GetAwsAccountId

func (m *S3Spec) GetAwsAccountId() string

func (*S3Spec) GetBucketName

func (m *S3Spec) GetBucketName() string

func (*S3Spec) GetKmsArn

func (m *S3Spec) GetKmsArn() string

func (*S3Spec) GetRegion

func (m *S3Spec) GetRegion() string

func (*S3Spec) GetRoleName

func (m *S3Spec) GetRoleName() string

func (*S3Spec) GoString

func (this *S3Spec) GoString() string

func (*S3Spec) Marshal

func (m *S3Spec) Marshal() (dAtA []byte, err error)

func (*S3Spec) MarshalTo

func (m *S3Spec) MarshalTo(dAtA []byte) (int, error)

func (*S3Spec) MarshalToSizedBuffer

func (m *S3Spec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*S3Spec) ProtoMessage

func (*S3Spec) ProtoMessage()

func (*S3Spec) Reset

func (m *S3Spec) Reset()

func (*S3Spec) Size

func (m *S3Spec) Size() (n int)

func (*S3Spec) String

func (this *S3Spec) String() string

func (*S3Spec) Unmarshal

func (m *S3Spec) Unmarshal(dAtA []byte) error

func (*S3Spec) XXX_DiscardUnknown

func (m *S3Spec) XXX_DiscardUnknown()

func (*S3Spec) XXX_Marshal

func (m *S3Spec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*S3Spec) XXX_Merge

func (m *S3Spec) XXX_Merge(src proto.Message)

func (*S3Spec) XXX_Size

func (m *S3Spec) XXX_Size() int

func (*S3Spec) XXX_Unmarshal

func (m *S3Spec) XXX_Unmarshal(b []byte) error

Jump to

Keyboard shortcuts

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