taskqueue

package

Go to main page

Versions in this module

v2

v2.2.3

Jul 18, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v2.2.2

Jul 18, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v2.2.1

Jul 12, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v2.2.0

Jul 6, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v2.1.4

Jul 1, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v2.1.3

Jul 1, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v2.1.2

Jun 29, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v2.1.1

Jun 28, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v2.1.0

Jun 24, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

Changes in this version

+ var ErrIntOverflowMessage = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthMessage = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group")

+ type PollerInfo struct

+ Identity string

+ LastAccessTime *time.Time

+ RatePerSecond float64

+ func (*PollerInfo) Descriptor() ([]byte, []int)

+ func (*PollerInfo) ProtoMessage()

+ func (m *PollerInfo) GetIdentity() string

+ func (m *PollerInfo) GetLastAccessTime() *time.Time

+ func (m *PollerInfo) GetRatePerSecond() float64

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

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

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

+ func (m *PollerInfo) Reset()

+ func (m *PollerInfo) Size() (n int)

+ func (m *PollerInfo) Unmarshal(dAtA []byte) error

+ func (m *PollerInfo) XXX_DiscardUnknown()

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

+ func (m *PollerInfo) XXX_Merge(src proto.Message)

+ func (m *PollerInfo) XXX_Size() int

+ func (m *PollerInfo) XXX_Unmarshal(b []byte) error

+ func (this *PollerInfo) Equal(that interface{}) bool

+ func (this *PollerInfo) GoString() string

+ func (this *PollerInfo) String() string

+ type StickyExecutionAttributes struct

+ ScheduleToStartTimeout *time.Duration

+ WorkerTaskQueue *TaskQueue

+ func (*StickyExecutionAttributes) Descriptor() ([]byte, []int)

+ func (*StickyExecutionAttributes) ProtoMessage()

+ func (m *StickyExecutionAttributes) GetScheduleToStartTimeout() *time.Duration

+ func (m *StickyExecutionAttributes) GetWorkerTaskQueue() *TaskQueue

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

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

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

+ func (m *StickyExecutionAttributes) Reset()

+ func (m *StickyExecutionAttributes) Size() (n int)

+ func (m *StickyExecutionAttributes) Unmarshal(dAtA []byte) error

+ func (m *StickyExecutionAttributes) XXX_DiscardUnknown()

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

+ func (m *StickyExecutionAttributes) XXX_Merge(src proto.Message)

+ func (m *StickyExecutionAttributes) XXX_Size() int

+ func (m *StickyExecutionAttributes) XXX_Unmarshal(b []byte) error

+ func (this *StickyExecutionAttributes) Equal(that interface{}) bool

+ func (this *StickyExecutionAttributes) GoString() string

+ func (this *StickyExecutionAttributes) String() string

+ type TaskIdBlock struct

+ EndId int64

+ StartId int64

+ func (*TaskIdBlock) Descriptor() ([]byte, []int)

+ func (*TaskIdBlock) ProtoMessage()

+ func (m *TaskIdBlock) GetEndId() int64

+ func (m *TaskIdBlock) GetStartId() int64

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

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

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

+ func (m *TaskIdBlock) Reset()

+ func (m *TaskIdBlock) Size() (n int)

+ func (m *TaskIdBlock) Unmarshal(dAtA []byte) error

+ func (m *TaskIdBlock) XXX_DiscardUnknown()

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

+ func (m *TaskIdBlock) XXX_Merge(src proto.Message)

+ func (m *TaskIdBlock) XXX_Size() int

+ func (m *TaskIdBlock) XXX_Unmarshal(b []byte) error

+ func (this *TaskIdBlock) Equal(that interface{}) bool

+ func (this *TaskIdBlock) GoString() string

+ func (this *TaskIdBlock) String() string

+ type TaskQueue struct

+ Kind v1.TaskQueueKind

+ Name string

+ func (*TaskQueue) Descriptor() ([]byte, []int)

+ func (*TaskQueue) ProtoMessage()

+ func (m *TaskQueue) GetKind() v1.TaskQueueKind

+ func (m *TaskQueue) GetName() string

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

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

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

+ func (m *TaskQueue) Reset()

+ func (m *TaskQueue) Size() (n int)

+ func (m *TaskQueue) Unmarshal(dAtA []byte) error

+ func (m *TaskQueue) XXX_DiscardUnknown()

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

+ func (m *TaskQueue) XXX_Merge(src proto.Message)

+ func (m *TaskQueue) XXX_Size() int

+ func (m *TaskQueue) XXX_Unmarshal(b []byte) error

+ func (this *TaskQueue) Equal(that interface{}) bool

+ func (this *TaskQueue) GoString() string

+ func (this *TaskQueue) String() string

+ type TaskQueueMetadata struct

+ MaxTasksPerSecond *types.DoubleValue

+ func (*TaskQueueMetadata) Descriptor() ([]byte, []int)

+ func (*TaskQueueMetadata) ProtoMessage()

+ func (m *TaskQueueMetadata) GetMaxTasksPerSecond() *types.DoubleValue

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

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

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

+ func (m *TaskQueueMetadata) Reset()

+ func (m *TaskQueueMetadata) Size() (n int)

+ func (m *TaskQueueMetadata) Unmarshal(dAtA []byte) error

+ func (m *TaskQueueMetadata) XXX_DiscardUnknown()

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

+ func (m *TaskQueueMetadata) XXX_Merge(src proto.Message)

+ func (m *TaskQueueMetadata) XXX_Size() int

+ func (m *TaskQueueMetadata) XXX_Unmarshal(b []byte) error

+ func (this *TaskQueueMetadata) Equal(that interface{}) bool

+ func (this *TaskQueueMetadata) GoString() string

+ func (this *TaskQueueMetadata) String() string

+ type TaskQueuePartitionMetadata struct

+ Key string

+ OwnerHostName string

+ func (*TaskQueuePartitionMetadata) Descriptor() ([]byte, []int)

+ func (*TaskQueuePartitionMetadata) ProtoMessage()

+ func (m *TaskQueuePartitionMetadata) GetKey() string

+ func (m *TaskQueuePartitionMetadata) GetOwnerHostName() string

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

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

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

+ func (m *TaskQueuePartitionMetadata) Reset()

+ func (m *TaskQueuePartitionMetadata) Size() (n int)

+ func (m *TaskQueuePartitionMetadata) Unmarshal(dAtA []byte) error

+ func (m *TaskQueuePartitionMetadata) XXX_DiscardUnknown()

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

+ func (m *TaskQueuePartitionMetadata) XXX_Merge(src proto.Message)

+ func (m *TaskQueuePartitionMetadata) XXX_Size() int

+ func (m *TaskQueuePartitionMetadata) XXX_Unmarshal(b []byte) error

+ func (this *TaskQueuePartitionMetadata) Equal(that interface{}) bool

+ func (this *TaskQueuePartitionMetadata) GoString() string

+ func (this *TaskQueuePartitionMetadata) String() string

+ type TaskQueueStatus struct

+ AckLevel int64

+ BacklogCountHint int64

+ RatePerSecond float64

+ ReadLevel int64

+ TaskIdBlock *TaskIdBlock

+ func (*TaskQueueStatus) Descriptor() ([]byte, []int)

+ func (*TaskQueueStatus) ProtoMessage()

+ func (m *TaskQueueStatus) GetAckLevel() int64

+ func (m *TaskQueueStatus) GetBacklogCountHint() int64

+ func (m *TaskQueueStatus) GetRatePerSecond() float64

+ func (m *TaskQueueStatus) GetReadLevel() int64

+ func (m *TaskQueueStatus) GetTaskIdBlock() *TaskIdBlock

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

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

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

+ func (m *TaskQueueStatus) Reset()

+ func (m *TaskQueueStatus) Size() (n int)

+ func (m *TaskQueueStatus) Unmarshal(dAtA []byte) error

+ func (m *TaskQueueStatus) XXX_DiscardUnknown()

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

+ func (m *TaskQueueStatus) XXX_Merge(src proto.Message)

+ func (m *TaskQueueStatus) XXX_Size() int

+ func (m *TaskQueueStatus) XXX_Unmarshal(b []byte) error

+ func (this *TaskQueueStatus) Equal(that interface{}) bool

+ func (this *TaskQueueStatus) GoString() string

+ func (this *TaskQueueStatus) String() string

Other modules containing this package

github.com/temporalio/ui-server

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL