Documentation
¶
Index ¶
- Variables
- type GCSSpec
- func (*GCSSpec) Descriptor() ([]byte, []int)
- func (this *GCSSpec) Equal(that interface{}) bool
- func (m *GCSSpec) GetBucketName() string
- func (m *GCSSpec) GetGcpProjectId() string
- func (m *GCSSpec) GetRegion() string
- func (m *GCSSpec) GetSaId() string
- func (this *GCSSpec) GoString() string
- func (m *GCSSpec) Marshal() (dAtA []byte, err error)
- func (m *GCSSpec) MarshalTo(dAtA []byte) (int, error)
- func (m *GCSSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GCSSpec) ProtoMessage()
- func (m *GCSSpec) Reset()
- func (m *GCSSpec) Size() (n int)
- func (this *GCSSpec) String() string
- func (m *GCSSpec) Unmarshal(dAtA []byte) error
- func (m *GCSSpec) XXX_DiscardUnknown()
- func (m *GCSSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GCSSpec) XXX_Merge(src proto.Message)
- func (m *GCSSpec) XXX_Size() int
- func (m *GCSSpec) XXX_Unmarshal(b []byte) error
- type KinesisSpec
- func (*KinesisSpec) Descriptor() ([]byte, []int)
- func (this *KinesisSpec) Equal(that interface{}) bool
- func (m *KinesisSpec) GetDestinationUri() string
- func (m *KinesisSpec) GetRegion() string
- func (m *KinesisSpec) GetRoleName() string
- func (this *KinesisSpec) GoString() string
- func (m *KinesisSpec) Marshal() (dAtA []byte, err error)
- func (m *KinesisSpec) MarshalTo(dAtA []byte) (int, error)
- func (m *KinesisSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*KinesisSpec) ProtoMessage()
- func (m *KinesisSpec) Reset()
- func (m *KinesisSpec) Size() (n int)
- func (this *KinesisSpec) String() string
- func (m *KinesisSpec) Unmarshal(dAtA []byte) error
- func (m *KinesisSpec) XXX_DiscardUnknown()
- func (m *KinesisSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KinesisSpec) XXX_Merge(src proto.Message)
- func (m *KinesisSpec) XXX_Size() int
- func (m *KinesisSpec) XXX_Unmarshal(b []byte) error
- type PubSubSpec
- func (*PubSubSpec) Descriptor() ([]byte, []int)
- func (this *PubSubSpec) Equal(that interface{}) bool
- func (m *PubSubSpec) GetGcpProjectId() string
- func (m *PubSubSpec) GetServiceAccountId() string
- func (m *PubSubSpec) GetTopicName() string
- func (this *PubSubSpec) GoString() string
- func (m *PubSubSpec) Marshal() (dAtA []byte, err error)
- func (m *PubSubSpec) MarshalTo(dAtA []byte) (int, error)
- func (m *PubSubSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PubSubSpec) ProtoMessage()
- func (m *PubSubSpec) Reset()
- func (m *PubSubSpec) Size() (n int)
- func (this *PubSubSpec) String() string
- func (m *PubSubSpec) Unmarshal(dAtA []byte) error
- func (m *PubSubSpec) XXX_DiscardUnknown()
- func (m *PubSubSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PubSubSpec) XXX_Merge(src proto.Message)
- func (m *PubSubSpec) XXX_Size() int
- func (m *PubSubSpec) XXX_Unmarshal(b []byte) error
- type S3Spec
- func (*S3Spec) Descriptor() ([]byte, []int)
- func (this *S3Spec) Equal(that interface{}) bool
- func (m *S3Spec) GetAwsAccountId() string
- func (m *S3Spec) GetBucketName() string
- func (m *S3Spec) GetKmsArn() string
- func (m *S3Spec) GetRegion() string
- func (m *S3Spec) GetRoleName() string
- func (this *S3Spec) GoString() string
- func (m *S3Spec) Marshal() (dAtA []byte, err error)
- func (m *S3Spec) MarshalTo(dAtA []byte) (int, error)
- func (m *S3Spec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*S3Spec) ProtoMessage()
- func (m *S3Spec) Reset()
- func (m *S3Spec) Size() (n int)
- func (this *S3Spec) String() string
- func (m *S3Spec) Unmarshal(dAtA []byte) error
- func (m *S3Spec) XXX_DiscardUnknown()
- func (m *S3Spec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *S3Spec) XXX_Merge(src proto.Message)
- func (m *S3Spec) XXX_Size() int
- func (m *S3Spec) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
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) GetBucketName ¶
func (*GCSSpec) GetGcpProjectId ¶
func (*GCSSpec) MarshalToSizedBuffer ¶
func (*GCSSpec) ProtoMessage ¶
func (*GCSSpec) ProtoMessage()
func (*GCSSpec) XXX_DiscardUnknown ¶
func (m *GCSSpec) XXX_DiscardUnknown()
func (*GCSSpec) XXX_Marshal ¶
func (*GCSSpec) XXX_Unmarshal ¶
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) GetAwsAccountId ¶
func (*S3Spec) GetBucketName ¶
func (*S3Spec) GetRoleName ¶
func (*S3Spec) MarshalToSizedBuffer ¶
func (*S3Spec) ProtoMessage ¶
func (*S3Spec) ProtoMessage()
func (*S3Spec) XXX_DiscardUnknown ¶
func (m *S3Spec) XXX_DiscardUnknown()
func (*S3Spec) XXX_Marshal ¶
func (*S3Spec) XXX_Unmarshal ¶
Click to show internal directories.
Click to hide internal directories.