sink

package
v0.53.0 Latest Latest
Warning

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

 Go to latest Published: Jan 13, 2026 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",
	3: "Pubsub",
}
View Source 
var DestinationType_value = map[string]int32{
	"Unspecified": 0,
	"Kinesis":     1,
	"S3":          2,
	"Pubsub":      3,
}
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 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) 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 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 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) 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"`
	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) 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) GetPubSubSink added in v0.17.0 

func (m *SinkSpec) GetPubSubSink() *PubSubSpec

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

State is only used by Audit Log 

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

Type is only used by Audit Log 

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.