sink

Documentation

Overview

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

Index

• Variables
• type GCSSpec
  • func (*GCSSpec) Descriptor() ([]byte, []int)
  • func (this *GCSSpec) Equal(that interface{}) bool
  • func (x *GCSSpec) GetBucketName() string
  • func (x *GCSSpec) GetGcpProjectId() string
  • func (x *GCSSpec) GetRegion() string
  • func (x *GCSSpec) GetSaId() string
  • func (val *GCSSpec) Marshal() ([]byte, error)
  • func (*GCSSpec) ProtoMessage()
  • func (x *GCSSpec) ProtoReflect() protoreflect.Message
  • func (x *GCSSpec) Reset()
  • func (val *GCSSpec) Size() int
  • func (x *GCSSpec) String() string
  • func (val *GCSSpec) Unmarshal(buf []byte) error
• type S3Spec
  • func (*S3Spec) Descriptor() ([]byte, []int)
  • func (this *S3Spec) Equal(that interface{}) bool
  • func (x *S3Spec) GetAwsAccountId() string
  • func (x *S3Spec) GetBucketName() string
  • func (x *S3Spec) GetKmsArn() string
  • func (x *S3Spec) GetRegion() string
  • func (x *S3Spec) GetRoleName() string
  • func (val *S3Spec) Marshal() ([]byte, error)
  • func (*S3Spec) ProtoMessage()
  • func (x *S3Spec) ProtoReflect() protoreflect.Message
  • func (x *S3Spec) Reset()
  • func (val *S3Spec) Size() int
  • func (x *S3Spec) String() string
  • func (val *S3Spec) Unmarshal(buf []byte) error

Variables

var File_temporal_api_cloud_sink_v1_message_proto protoreflect.FileDescriptor

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"`
	// contains filtered or unexported fields
}

func (*GCSSpec) Descriptor

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

Deprecated: Use GCSSpec.ProtoReflect.Descriptor instead.

func (*GCSSpec) Equal

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

Equal returns whether two GCSSpec values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GCSSpec) GetBucketName

func (x *GCSSpec) GetBucketName() string

func (*GCSSpec) GetGcpProjectId

func (x *GCSSpec) GetGcpProjectId() string

func (*GCSSpec) GetRegion

func (x *GCSSpec) GetRegion() string

func (*GCSSpec) GetSaId

func (x *GCSSpec) GetSaId() string

func (*GCSSpec) Marshal

func (val *GCSSpec) Marshal() ([]byte, error)

Marshal an object of type GCSSpec to the protobuf v3 wire format

func (*GCSSpec) ProtoMessage

func (*GCSSpec) ProtoMessage()

func (*GCSSpec) ProtoReflect

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

func (*GCSSpec) Reset

func (x *GCSSpec) Reset()

func (*GCSSpec) Size

func (val *GCSSpec) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GCSSpec) String

func (x *GCSSpec) String() string

func (*GCSSpec) Unmarshal

func (val *GCSSpec) Unmarshal(buf []byte) error

Unmarshal an object of type GCSSpec from the protobuf v3 wire format

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"`
	// contains filtered or unexported fields
}

func (*S3Spec) Descriptor

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

Deprecated: Use S3Spec.ProtoReflect.Descriptor instead.

func (*S3Spec) Equal

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

Equal returns whether two S3Spec values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*S3Spec) GetAwsAccountId

func (x *S3Spec) GetAwsAccountId() string

func (*S3Spec) GetBucketName

func (x *S3Spec) GetBucketName() string

func (*S3Spec) GetKmsArn

func (x *S3Spec) GetKmsArn() string

func (*S3Spec) GetRegion

func (x *S3Spec) GetRegion() string

func (*S3Spec) GetRoleName

func (x *S3Spec) GetRoleName() string

func (*S3Spec) Marshal

func (val *S3Spec) Marshal() ([]byte, error)

Marshal an object of type S3Spec to the protobuf v3 wire format

func (*S3Spec) ProtoMessage

func (*S3Spec) ProtoMessage()

func (*S3Spec) ProtoReflect

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

func (*S3Spec) Reset

func (x *S3Spec) Reset()

func (*S3Spec) Size

func (val *S3Spec) Size() int

Size returns the size of the object, in bytes, once serialized

func (*S3Spec) String

func (x *S3Spec) String() string

func (*S3Spec) Unmarshal

func (val *S3Spec) Unmarshal(buf []byte) error

Unmarshal an object of type S3Spec from the protobuf v3 wire format