sink

package
v0.45.0 Latest Latest
Warning

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

Go to latest
Published: Aug 13, 2025 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 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