sink

type DestinationType int32

type ExportDestinationType int32

type ExportSink struct {
	Name                 string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ResourceVersion      string           `protobuf:"bytes,2,opt,name=resource_version,json=resourceVersion,proto3" json:"resource_version,omitempty"`
	State                ExportSinkState  `protobuf:"varint,3,opt,name=state,proto3,enum=api.sink.v1.ExportSinkState" json:"state,omitempty"`
	Spec                 *ExportSinkSpec  `protobuf:"bytes,4,opt,name=spec,proto3" json:"spec,omitempty"`
	Health               ExportSinkHealth `protobuf:"varint,5,opt,name=health,proto3,enum=api.sink.v1.ExportSinkHealth" json:"health,omitempty"`
	ErrorMessage         string           `protobuf:"bytes,6,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	LatestDataExportTime *types.Timestamp `protobuf:"bytes,7,opt,name=latest_data_export_time,json=latestDataExportTime,proto3" json:"latest_data_export_time,omitempty"`
	LastHealthCheckTime  *types.Timestamp `protobuf:"bytes,8,opt,name=last_health_check_time,json=lastHealthCheckTime,proto3" json:"last_health_check_time,omitempty"`
}

type ExportSinkHealth int32

type ExportSinkSpec struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Enabled bool   `protobuf:"varint,2,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// The receiving service type.
	DestinationType ExportDestinationType `` /* 146-byte string literal not displayed */
	// The S3spec when destination_type is S3
	S3Sink *S3Spec `protobuf:"bytes,4,opt,name=s3_sink,json=s3Sink,proto3" json:"s3_sink,omitempty"`
	// The GCSspec when destination_type is GCS
	GcsSink *GCSSpec `protobuf:"bytes,5,opt,name=gcs_sink,json=gcsSink,proto3" json:"gcs_sink,omitempty"`
}

type ExportSinkState int32

type GCSSpec struct {
	// The customer service account id that Temporal Cloud impersonates for writing records to customer's gcs bucket
	SaId string `protobuf:"bytes,1,opt,name=sa_id,json=saId,proto3" json:"sa_id,omitempty"`
	// Destination gcs bucket name for temporal to send data to
	BucketName string `protobuf:"bytes,2,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// The gcp project id of gcs bucket and service account
	GcpProjectId string `protobuf:"bytes,3,opt,name=gcp_project_id,json=gcpProjectId,proto3" json:"gcp_project_id,omitempty"`
}

type KinesisSpec struct {
	// The role Temporal Cloud assumes when writing records to Kinesis
	AssumedRole string `protobuf:"bytes,1,opt,name=assumed_role,json=assumedRole,proto3" json:"assumed_role,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"`
}

type PubSubSpec struct {
	// The customer service account id that Temporal Cloud impersonates for writing records to customer's pubsub topic
	SaId string `protobuf:"bytes,1,opt,name=sa_id,json=saId,proto3" json:"sa_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"`
}

type S3Spec struct {
	// The role that Temporal Cloud assumes for writing records to customer's S3 bucket
	RoleName string `protobuf:"bytes,1,opt,name=role_name,json=roleName,proto3" json:"role_name,omitempty"`
	// Destination S3 bucket name for temporal to send data to
	BucketName string `protobuf:"bytes,2,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// The region of the S3 bucket
	Region string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
	// The kms key ARN used for encryption
	KmsArn string `protobuf:"bytes,4,opt,name=kms_arn,json=kmsArn,proto3" json:"kms_arn,omitempty"`
	// The aws account id of s3 bucket and assumed role
	AwsAccountId string `protobuf:"bytes,5,opt,name=aws_account_id,json=awsAccountId,proto3" json:"aws_account_id,omitempty"`
}

type Sink struct {
	// Name of the sink e.g. "audit_log_01"
	Name         string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	State        State  `protobuf:"varint,2,opt,name=state,proto3,enum=api.sink.v1.State" json:"state,omitempty"`
	ErrorMessage string `protobuf:"bytes,3,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// The last succeeded timestamp for the internal workflow responsible for adding data to the sink.
	LastSucceededTime *types.Timestamp `protobuf:"bytes,4,opt,name=last_succeeded_time,json=lastSucceededTime,proto3" json:"last_succeeded_time,omitempty"`
}

type SinkSpec struct {
	// Name of the sink e.g. "audit_log_01"
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Type of the sink.
	SinkType Type `protobuf:"varint,2,opt,name=sink_type,json=sinkType,proto3,enum=api.sink.v1.Type" json:"sink_type,omitempty"`
	// The receiving service type.
	DestinationType DestinationType `` /* 140-byte string literal not displayed */
	// The KinesisSpec when destination_type is Kinesis
	KinesisSink *KinesisSpec `protobuf:"bytes,4,opt,name=kinesis_sink,json=kinesisSink,proto3" json:"kinesis_sink,omitempty"`
	// The S3spec when destination_type is S3
	S3Sink  *S3Spec `protobuf:"bytes,5,opt,name=s3_sink,json=s3Sink,proto3" json:"s3_sink,omitempty"`
	Enabled bool    `protobuf:"varint,6,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// The PubSubSpec when destination_type is PubSub
	PubSubSink *PubSubSpec `protobuf:"bytes,7,opt,name=pub_sub_sink,json=pubSubSink,proto3" json:"pub_sub_sink,omitempty"`
}

type State int32

type Type int32