sink

package
v0.13.1-embed-version-... Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 30, 2023 License: MIT Imports: 9 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")
)
View Source 
var DestinationType_name = map[int32]string{
	0: "Unspecified",
	1: "Kinesis",
	2: "S3",
}
View Source 
var DestinationType_value = map[string]int32{
	"Unspecified": 0,
	"Kinesis":     1,
	"S3":          2,
}
View Source 
var ExportDestinationType_name = map[int32]string{
	0: "Unspecified",
	1: "S3",
}
View Source 
var ExportDestinationType_value = map[string]int32{
	"Unspecified": 0,
	"S3":          1,
}
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
const (
	DESTINATION_TYPE_UNSPECIFIED DestinationType = 0
	DESTINATION_TYPE_KINESIS     DestinationType = 1
	DESTINATION_TYPE_S3          DestinationType = 2
)

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
)

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) MarshalTo 

func (m *ExportSink) MarshalTo(dAtA []byte) (int, 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"`
}

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) 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) MarshalTo 

func (m *ExportSinkSpec) MarshalTo(dAtA []byte) (int, 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 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 us 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) MarshalTo 

func (m *KinesisSpec) MarshalTo(dAtA []byte) (int, 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 S3Spec 

type S3Spec struct {
	// The role to be created 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 us 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) 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

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"`
}

func (*Sink) Descriptor 

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

func (*Sink) Equal 

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

func (*Sink) GetErrorMessage 

func (m *Sink) GetErrorMessage() string

func (*Sink) GetLastSucceededTime 

func (m *Sink) GetLastSucceededTime() *types.Timestamp

func (*Sink) GetName 

func (m *Sink) GetName() string

func (*Sink) GetState 

func (m *Sink) GetState() State

func (*Sink) GoString 

func (this *Sink) GoString() string

func (*Sink) Marshal 

func (m *Sink) Marshal() (dAtA []byte, err error)

func (*Sink) MarshalTo 

func (m *Sink) MarshalTo(dAtA []byte) (int, error)

func (*Sink) MarshalToSizedBuffer 

func (m *Sink) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Sink) ProtoMessage 

func (*Sink) ProtoMessage()

func (*Sink) Reset 

func (m *Sink) Reset()

func (*Sink) Size 

func (m *Sink) Size() (n int)

func (*Sink) String 

func (this *Sink) String() string

func (*Sink) Unmarshal 

func (m *Sink) Unmarshal(dAtA []byte) error

func (*Sink) XXX_DiscardUnknown 

func (m *Sink) XXX_DiscardUnknown()

func (*Sink) XXX_Marshal 

func (m *Sink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Sink) XXX_Merge 

func (m *Sink) XXX_Merge(src proto.Message)

func (*Sink) XXX_Size 

func (m *Sink) XXX_Size() int

func (*Sink) XXX_Unmarshal 

func (m *Sink) XXX_Unmarshal(b []byte) error

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"`
}

func (*SinkSpec) Descriptor 

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

func (*SinkSpec) Equal 

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

func (*SinkSpec) GetDestinationType 

func (m *SinkSpec) GetDestinationType() DestinationType

func (*SinkSpec) GetEnabled 

func (m *SinkSpec) GetEnabled() bool

func (*SinkSpec) GetKinesisSink 

func (m *SinkSpec) GetKinesisSink() *KinesisSpec

func (*SinkSpec) GetName 

func (m *SinkSpec) GetName() string

func (*SinkSpec) GetS3Sink 

func (m *SinkSpec) GetS3Sink() *S3Spec

func (*SinkSpec) GetSinkType 

func (m *SinkSpec) GetSinkType() Type

func (*SinkSpec) GoString 

func (this *SinkSpec) GoString() string

func (*SinkSpec) Marshal 

func (m *SinkSpec) Marshal() (dAtA []byte, err error)

func (*SinkSpec) MarshalTo 

func (m *SinkSpec) MarshalTo(dAtA []byte) (int, error)

func (*SinkSpec) MarshalToSizedBuffer 

func (m *SinkSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SinkSpec) ProtoMessage 

func (*SinkSpec) ProtoMessage()

func (*SinkSpec) Reset 

func (m *SinkSpec) Reset()

func (*SinkSpec) Size 

func (m *SinkSpec) Size() (n int)

func (*SinkSpec) String 

func (this *SinkSpec) String() string

func (*SinkSpec) Unmarshal 

func (m *SinkSpec) Unmarshal(dAtA []byte) error

func (*SinkSpec) XXX_DiscardUnknown 

func (m *SinkSpec) XXX_DiscardUnknown()

func (*SinkSpec) XXX_Marshal 

func (m *SinkSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SinkSpec) XXX_Merge 

func (m *SinkSpec) XXX_Merge(src proto.Message)

func (*SinkSpec) XXX_Size 

func (m *SinkSpec) XXX_Size() int

func (*SinkSpec) XXX_Unmarshal 

func (m *SinkSpec) XXX_Unmarshal(b []byte) error

type State 

type State int32
const (
	STATE_UNSPECIFIED    State = 0
	STATE_CREATING       State = 1
	STATE_ACTIVE         State = 2
	STATE_DELETED        State = 3
	STATE_INTERNAL_ERROR State = 4
	STATE_USER_ERROR     State = 5
)

func (State) EnumDescriptor 

func (State) EnumDescriptor() ([]byte, []int)

func (State) String 

func (x State) String() string

type Type 

type Type int32
const (
	TYPE_UNSPECIFIED             Type = 0
	TYPE_AUDIT_LOG               Type = 1
	TYPE_WORKFLOW_HISTORY_EXPORT Type = 2
)

func (Type) EnumDescriptor 

func (Type) EnumDescriptor() ([]byte, []int)

func (Type) String 

func (x Type) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.