Help us shape the future of Go! Take the 2026 Go Developer Survey

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