Documentation ¶
Index ¶
- Variables
- type DestinationType
- type ExportDestinationType
- type ExportSink
- func (*ExportSink) Descriptor() ([]byte, []int)
- func (this *ExportSink) Equal(that interface{}) bool
- func (m *ExportSink) GetErrorMessage() string
- func (m *ExportSink) GetHealth() ExportSinkHealth
- func (m *ExportSink) GetLastHealthCheckTime() *types.Timestamp
- func (m *ExportSink) GetLatestDataExportTime() *types.Timestamp
- func (m *ExportSink) GetName() string
- func (m *ExportSink) GetResourceVersion() string
- func (m *ExportSink) GetSpec() *ExportSinkSpec
- func (m *ExportSink) GetState() ExportSinkState
- func (this *ExportSink) GoString() string
- func (m *ExportSink) Marshal() (dAtA []byte, err error)
- func (m *ExportSink) MarshalTo(dAtA []byte) (int, error)
- func (m *ExportSink) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ExportSink) ProtoMessage()
- func (m *ExportSink) Reset()
- func (m *ExportSink) Size() (n int)
- func (this *ExportSink) String() string
- func (m *ExportSink) Unmarshal(dAtA []byte) error
- func (m *ExportSink) XXX_DiscardUnknown()
- func (m *ExportSink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExportSink) XXX_Merge(src proto.Message)
- func (m *ExportSink) XXX_Size() int
- func (m *ExportSink) XXX_Unmarshal(b []byte) error
- type ExportSinkHealth
- type ExportSinkSpec
- func (*ExportSinkSpec) Descriptor() ([]byte, []int)
- func (this *ExportSinkSpec) Equal(that interface{}) bool
- func (m *ExportSinkSpec) GetDestinationType() ExportDestinationType
- func (m *ExportSinkSpec) GetEnabled() bool
- func (m *ExportSinkSpec) GetGcsSink() *GCSSpec
- func (m *ExportSinkSpec) GetName() string
- func (m *ExportSinkSpec) GetS3Sink() *S3Spec
- func (this *ExportSinkSpec) GoString() string
- func (m *ExportSinkSpec) Marshal() (dAtA []byte, err error)
- func (m *ExportSinkSpec) MarshalTo(dAtA []byte) (int, error)
- func (m *ExportSinkSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ExportSinkSpec) ProtoMessage()
- func (m *ExportSinkSpec) Reset()
- func (m *ExportSinkSpec) Size() (n int)
- func (this *ExportSinkSpec) String() string
- func (m *ExportSinkSpec) Unmarshal(dAtA []byte) error
- func (m *ExportSinkSpec) XXX_DiscardUnknown()
- func (m *ExportSinkSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExportSinkSpec) XXX_Merge(src proto.Message)
- func (m *ExportSinkSpec) XXX_Size() int
- func (m *ExportSinkSpec) XXX_Unmarshal(b []byte) error
- type ExportSinkState
- 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) 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) GetAssumedRole() string
- func (m *KinesisSpec) GetDestinationUri() string
- func (m *KinesisSpec) GetRegion() 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) GetSaId() 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
- type Sink
- func (*Sink) Descriptor() ([]byte, []int)
- func (this *Sink) Equal(that interface{}) bool
- func (m *Sink) GetErrorMessage() string
- func (m *Sink) GetLastSucceededTime() *types.Timestamp
- func (m *Sink) GetName() string
- func (m *Sink) GetState() State
- func (this *Sink) GoString() string
- func (m *Sink) Marshal() (dAtA []byte, err error)
- func (m *Sink) MarshalTo(dAtA []byte) (int, error)
- func (m *Sink) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Sink) ProtoMessage()
- func (m *Sink) Reset()
- func (m *Sink) Size() (n int)
- func (this *Sink) String() string
- func (m *Sink) Unmarshal(dAtA []byte) error
- func (m *Sink) XXX_DiscardUnknown()
- func (m *Sink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Sink) XXX_Merge(src proto.Message)
- func (m *Sink) XXX_Size() int
- func (m *Sink) XXX_Unmarshal(b []byte) error
- type SinkSpec
- func (*SinkSpec) Descriptor() ([]byte, []int)
- func (this *SinkSpec) Equal(that interface{}) bool
- func (m *SinkSpec) GetDestinationType() DestinationType
- func (m *SinkSpec) GetEnabled() bool
- func (m *SinkSpec) GetKinesisSink() *KinesisSpec
- func (m *SinkSpec) GetName() string
- func (m *SinkSpec) GetPubSubSink() *PubSubSpec
- func (m *SinkSpec) GetS3Sink() *S3Spec
- func (m *SinkSpec) GetSinkType() Type
- func (this *SinkSpec) GoString() string
- func (m *SinkSpec) Marshal() (dAtA []byte, err error)
- func (m *SinkSpec) MarshalTo(dAtA []byte) (int, error)
- func (m *SinkSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SinkSpec) ProtoMessage()
- func (m *SinkSpec) Reset()
- func (m *SinkSpec) Size() (n int)
- func (this *SinkSpec) String() string
- func (m *SinkSpec) Unmarshal(dAtA []byte) error
- func (m *SinkSpec) XXX_DiscardUnknown()
- func (m *SinkSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SinkSpec) XXX_Merge(src proto.Message)
- func (m *SinkSpec) XXX_Size() int
- func (m *SinkSpec) XXX_Unmarshal(b []byte) error
- type State
- type Type
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") )
View Source
var DestinationType_name = map[int32]string{
0: "Unspecified",
1: "Kinesis",
2: "S3",
3: "Pubsub",
}
View Source
var DestinationType_value = map[string]int32{
"Unspecified": 0,
"Kinesis": 1,
"S3": 2,
"Pubsub": 3,
}
View Source
var ExportDestinationType_name = map[int32]string{
0: "Unspecified",
1: "S3",
2: "Gcs",
}
View Source
var ExportDestinationType_value = map[string]int32{
"Unspecified": 0,
"S3": 1,
"Gcs": 2,
}
View Source
var ExportSinkHealth_name = map[int32]string{
0: "Unspecified",
1: "Ok",
2: "ErrorInternal",
3: "ErrorUserConfiguration",
}
View Source
var ExportSinkHealth_value = map[string]int32{
"Unspecified": 0,
"Ok": 1,
"ErrorInternal": 2,
"ErrorUserConfiguration": 3,
}
View Source
var ExportSinkState_name = map[int32]string{
0: "Unspecified",
1: "Activating",
2: "Active",
3: "ActivationFailed",
4: "Deleting",
5: "Deleted",
6: "Updating",
7: "UpdateFailed",
}
View Source
var ExportSinkState_value = map[string]int32{
"Unspecified": 0,
"Activating": 1,
"Active": 2,
"ActivationFailed": 3,
"Deleting": 4,
"Deleted": 5,
"Updating": 6,
"UpdateFailed": 7,
}
View Source
var State_name = map[int32]string{
0: "Unspecified",
1: "Creating",
2: "Active",
3: "Deleted",
4: "InternalError",
5: "UserError",
}
View Source
var State_value = map[string]int32{
"Unspecified": 0,
"Creating": 1,
"Active": 2,
"Deleted": 3,
"InternalError": 4,
"UserError": 5,
}
View Source
var Type_name = map[int32]string{
0: "Unspecified",
1: "AuditLog",
2: "WorkflowHistoryExport",
}
View Source
var Type_value = map[string]int32{
"Unspecified": 0,
"AuditLog": 1,
"WorkflowHistoryExport": 2,
}
Functions ¶
This section is empty.
Types ¶
type DestinationType ¶
type DestinationType int32
DestinationType is only used by Audit Log
const ( DESTINATION_TYPE_UNSPECIFIED DestinationType = 0 DESTINATION_TYPE_KINESIS DestinationType = 1 DESTINATION_TYPE_S3 DestinationType = 2 DESTINATION_TYPE_PUBSUB DestinationType = 3 )
func (DestinationType) EnumDescriptor ¶
func (DestinationType) EnumDescriptor() ([]byte, []int)
func (DestinationType) String ¶
func (x DestinationType) String() string
type ExportDestinationType ¶
type ExportDestinationType int32
const ( EXPORT_DESTINATION_TYPE_UNSPECIFIED ExportDestinationType = 0 EXPORT_DESTINATION_TYPE_S3 ExportDestinationType = 1 EXPORT_DESTINATION_TYPE_GCS ExportDestinationType = 2 )
func (ExportDestinationType) EnumDescriptor ¶
func (ExportDestinationType) EnumDescriptor() ([]byte, []int)
func (ExportDestinationType) String ¶
func (x ExportDestinationType) String() string
type ExportSink ¶
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"` }
func (*ExportSink) Descriptor ¶
func (*ExportSink) Descriptor() ([]byte, []int)
func (*ExportSink) Equal ¶
func (this *ExportSink) Equal(that interface{}) bool
func (*ExportSink) GetErrorMessage ¶
func (m *ExportSink) GetErrorMessage() string
func (*ExportSink) GetHealth ¶
func (m *ExportSink) GetHealth() ExportSinkHealth
func (*ExportSink) GetLastHealthCheckTime ¶
func (m *ExportSink) GetLastHealthCheckTime() *types.Timestamp
func (*ExportSink) GetLatestDataExportTime ¶
func (m *ExportSink) GetLatestDataExportTime() *types.Timestamp
func (*ExportSink) GetName ¶
func (m *ExportSink) GetName() string
func (*ExportSink) GetResourceVersion ¶
func (m *ExportSink) GetResourceVersion() string
func (*ExportSink) GetSpec ¶
func (m *ExportSink) GetSpec() *ExportSinkSpec
func (*ExportSink) GetState ¶
func (m *ExportSink) GetState() ExportSinkState
func (*ExportSink) GoString ¶
func (this *ExportSink) GoString() string
func (*ExportSink) Marshal ¶
func (m *ExportSink) Marshal() (dAtA []byte, err error)
func (*ExportSink) MarshalToSizedBuffer ¶
func (m *ExportSink) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ExportSink) ProtoMessage ¶
func (*ExportSink) ProtoMessage()
func (*ExportSink) Reset ¶
func (m *ExportSink) Reset()
func (*ExportSink) Size ¶
func (m *ExportSink) Size() (n int)
func (*ExportSink) String ¶
func (this *ExportSink) String() string
func (*ExportSink) Unmarshal ¶
func (m *ExportSink) Unmarshal(dAtA []byte) error
func (*ExportSink) XXX_DiscardUnknown ¶
func (m *ExportSink) XXX_DiscardUnknown()
func (*ExportSink) XXX_Marshal ¶
func (m *ExportSink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExportSink) XXX_Merge ¶
func (m *ExportSink) XXX_Merge(src proto.Message)
func (*ExportSink) XXX_Size ¶
func (m *ExportSink) XXX_Size() int
func (*ExportSink) XXX_Unmarshal ¶
func (m *ExportSink) XXX_Unmarshal(b []byte) error
type ExportSinkHealth ¶
type ExportSinkHealth int32
const ( EXPORT_SINK_HEALTH_UNSPECIFIED ExportSinkHealth = 0 EXPORT_SINK_HEALTH_OK ExportSinkHealth = 1 EXPORT_SINK_HEALTH_ERROR_INTERNAL ExportSinkHealth = 2 EXPORT_SINK_HEALTH_ERROR_USER_CONFIGURATION ExportSinkHealth = 3 )
func (ExportSinkHealth) EnumDescriptor ¶
func (ExportSinkHealth) EnumDescriptor() ([]byte, []int)
func (ExportSinkHealth) String ¶
func (x ExportSinkHealth) String() string
type ExportSinkSpec ¶
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"` }
func (*ExportSinkSpec) Descriptor ¶
func (*ExportSinkSpec) Descriptor() ([]byte, []int)
func (*ExportSinkSpec) Equal ¶
func (this *ExportSinkSpec) Equal(that interface{}) bool
func (*ExportSinkSpec) GetDestinationType ¶
func (m *ExportSinkSpec) GetDestinationType() ExportDestinationType
func (*ExportSinkSpec) GetEnabled ¶
func (m *ExportSinkSpec) GetEnabled() bool
func (*ExportSinkSpec) GetGcsSink ¶ added in v0.15.0
func (m *ExportSinkSpec) GetGcsSink() *GCSSpec
func (*ExportSinkSpec) GetName ¶
func (m *ExportSinkSpec) GetName() string
func (*ExportSinkSpec) GetS3Sink ¶
func (m *ExportSinkSpec) GetS3Sink() *S3Spec
func (*ExportSinkSpec) GoString ¶
func (this *ExportSinkSpec) GoString() string
func (*ExportSinkSpec) Marshal ¶
func (m *ExportSinkSpec) Marshal() (dAtA []byte, err error)
func (*ExportSinkSpec) MarshalToSizedBuffer ¶
func (m *ExportSinkSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ExportSinkSpec) ProtoMessage ¶
func (*ExportSinkSpec) ProtoMessage()
func (*ExportSinkSpec) Reset ¶
func (m *ExportSinkSpec) Reset()
func (*ExportSinkSpec) Size ¶
func (m *ExportSinkSpec) Size() (n int)
func (*ExportSinkSpec) String ¶
func (this *ExportSinkSpec) String() string
func (*ExportSinkSpec) Unmarshal ¶
func (m *ExportSinkSpec) Unmarshal(dAtA []byte) error
func (*ExportSinkSpec) XXX_DiscardUnknown ¶
func (m *ExportSinkSpec) XXX_DiscardUnknown()
func (*ExportSinkSpec) XXX_Marshal ¶
func (m *ExportSinkSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExportSinkSpec) XXX_Merge ¶
func (m *ExportSinkSpec) XXX_Merge(src proto.Message)
func (*ExportSinkSpec) XXX_Size ¶
func (m *ExportSinkSpec) XXX_Size() int
func (*ExportSinkSpec) XXX_Unmarshal ¶
func (m *ExportSinkSpec) XXX_Unmarshal(b []byte) error
type ExportSinkState ¶
type ExportSinkState int32
const ( EXPORT_SINK_STATE_UNSPECIFIED ExportSinkState = 0 EXPORT_SINK_STATE_ACTIVATING ExportSinkState = 1 EXPORT_SINK_STATE_ACTIVE ExportSinkState = 2 EXPORT_SINK_STATE_ACTIVATION_FAILED ExportSinkState = 3 EXPORT_SINK_STATE_DELETING ExportSinkState = 4 EXPORT_SINK_STATE_DELETED ExportSinkState = 5 EXPORT_SINK_STATE_UPDATING ExportSinkState = 6 EXPORT_SINK_STATE_UPDATE_FAILED ExportSinkState = 7 )
func (ExportSinkState) EnumDescriptor ¶
func (ExportSinkState) EnumDescriptor() ([]byte, []int)
func (ExportSinkState) String ¶
func (x ExportSinkState) String() string
type GCSSpec ¶ added in v0.15.0
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"` }
func (*GCSSpec) Descriptor ¶ added in v0.15.0
func (*GCSSpec) GetBucketName ¶ added in v0.15.0
func (*GCSSpec) GetGcpProjectId ¶ added in v0.16.0
func (*GCSSpec) MarshalToSizedBuffer ¶ added in v0.15.0
func (*GCSSpec) ProtoMessage ¶ added in v0.15.0
func (*GCSSpec) ProtoMessage()
func (*GCSSpec) XXX_DiscardUnknown ¶ added in v0.15.0
func (m *GCSSpec) XXX_DiscardUnknown()
func (*GCSSpec) XXX_Marshal ¶ added in v0.15.0
func (*GCSSpec) XXX_Unmarshal ¶ added in v0.15.0
type KinesisSpec ¶
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"` }
func (*KinesisSpec) Descriptor ¶
func (*KinesisSpec) Descriptor() ([]byte, []int)
func (*KinesisSpec) Equal ¶
func (this *KinesisSpec) Equal(that interface{}) bool
func (*KinesisSpec) GetAssumedRole ¶
func (m *KinesisSpec) GetAssumedRole() string
func (*KinesisSpec) GetDestinationUri ¶
func (m *KinesisSpec) GetDestinationUri() string
func (*KinesisSpec) GetRegion ¶
func (m *KinesisSpec) GetRegion() string
func (*KinesisSpec) GoString ¶
func (this *KinesisSpec) GoString() string
func (*KinesisSpec) Marshal ¶
func (m *KinesisSpec) Marshal() (dAtA []byte, err error)
func (*KinesisSpec) MarshalToSizedBuffer ¶
func (m *KinesisSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*KinesisSpec) ProtoMessage ¶
func (*KinesisSpec) ProtoMessage()
func (*KinesisSpec) Reset ¶
func (m *KinesisSpec) Reset()
func (*KinesisSpec) Size ¶
func (m *KinesisSpec) Size() (n int)
func (*KinesisSpec) String ¶
func (this *KinesisSpec) String() string
func (*KinesisSpec) Unmarshal ¶
func (m *KinesisSpec) Unmarshal(dAtA []byte) error
func (*KinesisSpec) XXX_DiscardUnknown ¶
func (m *KinesisSpec) XXX_DiscardUnknown()
func (*KinesisSpec) XXX_Marshal ¶
func (m *KinesisSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KinesisSpec) XXX_Merge ¶
func (m *KinesisSpec) XXX_Merge(src proto.Message)
func (*KinesisSpec) XXX_Size ¶
func (m *KinesisSpec) XXX_Size() int
func (*KinesisSpec) XXX_Unmarshal ¶
func (m *KinesisSpec) XXX_Unmarshal(b []byte) error
type PubSubSpec ¶ added in v0.17.0
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"` }
func (*PubSubSpec) Descriptor ¶ added in v0.17.0
func (*PubSubSpec) Descriptor() ([]byte, []int)
func (*PubSubSpec) Equal ¶ added in v0.17.0
func (this *PubSubSpec) Equal(that interface{}) bool
func (*PubSubSpec) GetGcpProjectId ¶ added in v0.17.0
func (m *PubSubSpec) GetGcpProjectId() string
func (*PubSubSpec) GetSaId ¶ added in v0.17.0
func (m *PubSubSpec) GetSaId() string
func (*PubSubSpec) GetTopicName ¶ added in v0.17.0
func (m *PubSubSpec) GetTopicName() string
func (*PubSubSpec) GoString ¶ added in v0.17.0
func (this *PubSubSpec) GoString() string
func (*PubSubSpec) Marshal ¶ added in v0.17.0
func (m *PubSubSpec) Marshal() (dAtA []byte, err error)
func (*PubSubSpec) MarshalTo ¶ added in v0.17.0
func (m *PubSubSpec) MarshalTo(dAtA []byte) (int, error)
func (*PubSubSpec) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *PubSubSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PubSubSpec) ProtoMessage ¶ added in v0.17.0
func (*PubSubSpec) ProtoMessage()
func (*PubSubSpec) Reset ¶ added in v0.17.0
func (m *PubSubSpec) Reset()
func (*PubSubSpec) Size ¶ added in v0.17.0
func (m *PubSubSpec) Size() (n int)
func (*PubSubSpec) String ¶ added in v0.17.0
func (this *PubSubSpec) String() string
func (*PubSubSpec) Unmarshal ¶ added in v0.17.0
func (m *PubSubSpec) Unmarshal(dAtA []byte) error
func (*PubSubSpec) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *PubSubSpec) XXX_DiscardUnknown()
func (*PubSubSpec) XXX_Marshal ¶ added in v0.17.0
func (m *PubSubSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PubSubSpec) XXX_Merge ¶ added in v0.17.0
func (m *PubSubSpec) XXX_Merge(src proto.Message)
func (*PubSubSpec) XXX_Size ¶ added in v0.17.0
func (m *PubSubSpec) XXX_Size() int
func (*PubSubSpec) XXX_Unmarshal ¶ added in v0.17.0
func (m *PubSubSpec) XXX_Unmarshal(b []byte) error
type S3Spec ¶
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"` }
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 ¶
type Sink ¶
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"` }
Sink is only used by Audit Log
func (*Sink) Descriptor ¶
func (*Sink) GetErrorMessage ¶
func (*Sink) GetLastSucceededTime ¶
func (*Sink) ProtoMessage ¶
func (*Sink) ProtoMessage()
func (*Sink) XXX_DiscardUnknown ¶
func (m *Sink) XXX_DiscardUnknown()
func (*Sink) XXX_Unmarshal ¶
type SinkSpec ¶
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"` }
SinkSpec is only used by Audit Log
func (*SinkSpec) Descriptor ¶
func (*SinkSpec) GetDestinationType ¶
func (m *SinkSpec) GetDestinationType() DestinationType
func (*SinkSpec) GetEnabled ¶
func (*SinkSpec) GetKinesisSink ¶
func (m *SinkSpec) GetKinesisSink() *KinesisSpec
func (*SinkSpec) GetPubSubSink ¶ added in v0.17.0
func (m *SinkSpec) GetPubSubSink() *PubSubSpec
func (*SinkSpec) GetSinkType ¶
func (*SinkSpec) MarshalToSizedBuffer ¶
func (*SinkSpec) ProtoMessage ¶
func (*SinkSpec) ProtoMessage()
func (*SinkSpec) XXX_DiscardUnknown ¶
func (m *SinkSpec) XXX_DiscardUnknown()
func (*SinkSpec) XXX_Marshal ¶
func (*SinkSpec) XXX_Unmarshal ¶
Click to show internal directories.
Click to hide internal directories.