taskqueue

package
v1.13.0 Latest Latest
Warning

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

 Go to latest Published: Oct 28, 2022 License: MIT Imports: 12 Imported by: 47

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

Functions

This section is empty.

Types

type PollerInfo 

type PollerInfo struct {
	// Unix Nano
	LastAccessTime *time.Time `protobuf:"bytes,1,opt,name=last_access_time,json=lastAccessTime,proto3,stdtime" json:"last_access_time,omitempty"`
	Identity       string     `protobuf:"bytes,2,opt,name=identity,proto3" json:"identity,omitempty"`
	RatePerSecond  float64    `protobuf:"fixed64,3,opt,name=rate_per_second,json=ratePerSecond,proto3" json:"rate_per_second,omitempty"`
	// If a worker has specified an ID for use with the worker versioning feature while polling,
	// that id must appear here.
	WorkerVersioningId *VersionId `protobuf:"bytes,4,opt,name=worker_versioning_id,json=workerVersioningId,proto3" json:"worker_versioning_id,omitempty"`
}

func (*PollerInfo) Descriptor 

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

func (*PollerInfo) Equal 

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

func (*PollerInfo) GetIdentity 

func (m *PollerInfo) GetIdentity() string

func (*PollerInfo) GetLastAccessTime 

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

func (*PollerInfo) GetRatePerSecond 

func (m *PollerInfo) GetRatePerSecond() float64

func (*PollerInfo) GetWorkerVersioningId added in v1.12.0 

func (m *PollerInfo) GetWorkerVersioningId() *VersionId

func (*PollerInfo) GoString 

func (this *PollerInfo) GoString() string

func (*PollerInfo) Marshal 

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

func (*PollerInfo) MarshalTo 

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

func (*PollerInfo) MarshalToSizedBuffer 

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

func (*PollerInfo) ProtoMessage 

func (*PollerInfo) ProtoMessage()

func (*PollerInfo) Reset 

func (m *PollerInfo) Reset()

func (*PollerInfo) Size 

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

func (*PollerInfo) String 

func (this *PollerInfo) String() string

func (*PollerInfo) Unmarshal 

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

func (*PollerInfo) XXX_DiscardUnknown 

func (m *PollerInfo) XXX_DiscardUnknown()

func (*PollerInfo) XXX_Marshal 

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

func (*PollerInfo) XXX_Merge 

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

func (*PollerInfo) XXX_Size 

func (m *PollerInfo) XXX_Size() int

func (*PollerInfo) XXX_Unmarshal 

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

type StickyExecutionAttributes 

type StickyExecutionAttributes struct {
	WorkerTaskQueue *TaskQueue `protobuf:"bytes,1,opt,name=worker_task_queue,json=workerTaskQueue,proto3" json:"worker_task_queue,omitempty"`
	// (-- api-linter: core::0140::prepositions=disabled
	//     aip.dev/not-precedent: "to" is used to indicate interval. --)
	ScheduleToStartTimeout *time.Duration `` /* 143-byte string literal not displayed */
}

func (*StickyExecutionAttributes) Descriptor 

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

func (*StickyExecutionAttributes) Equal 

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

func (*StickyExecutionAttributes) GetScheduleToStartTimeout added in v0.28.0 

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

func (*StickyExecutionAttributes) GetWorkerTaskQueue 

func (m *StickyExecutionAttributes) GetWorkerTaskQueue() *TaskQueue

func (*StickyExecutionAttributes) GoString 

func (this *StickyExecutionAttributes) GoString() string

func (*StickyExecutionAttributes) Marshal 

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

func (*StickyExecutionAttributes) MarshalTo 

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

func (*StickyExecutionAttributes) MarshalToSizedBuffer 

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

func (*StickyExecutionAttributes) ProtoMessage 

func (*StickyExecutionAttributes) ProtoMessage()

func (*StickyExecutionAttributes) Reset 

func (m *StickyExecutionAttributes) Reset()

func (*StickyExecutionAttributes) Size 

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

func (*StickyExecutionAttributes) String 

func (this *StickyExecutionAttributes) String() string

func (*StickyExecutionAttributes) Unmarshal 

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

func (*StickyExecutionAttributes) XXX_DiscardUnknown 

func (m *StickyExecutionAttributes) XXX_DiscardUnknown()

func (*StickyExecutionAttributes) XXX_Marshal 

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

func (*StickyExecutionAttributes) XXX_Merge 

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

func (*StickyExecutionAttributes) XXX_Size 

func (m *StickyExecutionAttributes) XXX_Size() int

func (*StickyExecutionAttributes) XXX_Unmarshal 

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

type TaskIdBlock 

type TaskIdBlock struct {
	StartId int64 `protobuf:"varint,1,opt,name=start_id,json=startId,proto3" json:"start_id,omitempty"`
	EndId   int64 `protobuf:"varint,2,opt,name=end_id,json=endId,proto3" json:"end_id,omitempty"`
}

func (*TaskIdBlock) Descriptor 

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

func (*TaskIdBlock) Equal 

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

func (*TaskIdBlock) GetEndId 

func (m *TaskIdBlock) GetEndId() int64

func (*TaskIdBlock) GetStartId 

func (m *TaskIdBlock) GetStartId() int64

func (*TaskIdBlock) GoString 

func (this *TaskIdBlock) GoString() string

func (*TaskIdBlock) Marshal 

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

func (*TaskIdBlock) MarshalTo 

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

func (*TaskIdBlock) MarshalToSizedBuffer 

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

func (*TaskIdBlock) ProtoMessage 

func (*TaskIdBlock) ProtoMessage()

func (*TaskIdBlock) Reset 

func (m *TaskIdBlock) Reset()

func (*TaskIdBlock) Size 

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

func (*TaskIdBlock) String 

func (this *TaskIdBlock) String() string

func (*TaskIdBlock) Unmarshal 

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

func (*TaskIdBlock) XXX_DiscardUnknown 

func (m *TaskIdBlock) XXX_DiscardUnknown()

func (*TaskIdBlock) XXX_Marshal 

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

func (*TaskIdBlock) XXX_Merge 

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

func (*TaskIdBlock) XXX_Size 

func (m *TaskIdBlock) XXX_Size() int

func (*TaskIdBlock) XXX_Unmarshal 

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

type TaskQueue 

type TaskQueue struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Default: TASK_QUEUE_KIND_NORMAL.
	Kind v1.TaskQueueKind `protobuf:"varint,2,opt,name=kind,proto3,enum=temporal.api.enums.v1.TaskQueueKind" json:"kind,omitempty"`
}

See https://docs.temporal.io/docs/concepts/task-queues/

func (*TaskQueue) Descriptor 

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

func (*TaskQueue) Equal 

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

func (*TaskQueue) GetKind 

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

func (*TaskQueue) GetName 

func (m *TaskQueue) GetName() string

func (*TaskQueue) GoString 

func (this *TaskQueue) GoString() string

func (*TaskQueue) Marshal 

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

func (*TaskQueue) MarshalTo 

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

func (*TaskQueue) MarshalToSizedBuffer 

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

func (*TaskQueue) ProtoMessage 

func (*TaskQueue) ProtoMessage()

func (*TaskQueue) Reset 

func (m *TaskQueue) Reset()

func (*TaskQueue) Size 

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

func (*TaskQueue) String 

func (this *TaskQueue) String() string

func (*TaskQueue) Unmarshal 

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

func (*TaskQueue) XXX_DiscardUnknown 

func (m *TaskQueue) XXX_DiscardUnknown()

func (*TaskQueue) XXX_Marshal 

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

func (*TaskQueue) XXX_Merge 

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

func (*TaskQueue) XXX_Size 

func (m *TaskQueue) XXX_Size() int

func (*TaskQueue) XXX_Unmarshal 

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

type TaskQueueMetadata 

type TaskQueueMetadata struct {
	// Allows throttling dispatch of tasks from this queue
	MaxTasksPerSecond *types.DoubleValue `protobuf:"bytes,1,opt,name=max_tasks_per_second,json=maxTasksPerSecond,proto3" json:"max_tasks_per_second,omitempty"`
}

Only applies to activity task queues

func (*TaskQueueMetadata) Descriptor 

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

func (*TaskQueueMetadata) Equal 

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

func (*TaskQueueMetadata) GetMaxTasksPerSecond 

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

func (*TaskQueueMetadata) GoString 

func (this *TaskQueueMetadata) GoString() string

func (*TaskQueueMetadata) Marshal 

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

func (*TaskQueueMetadata) MarshalTo 

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

func (*TaskQueueMetadata) MarshalToSizedBuffer 

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

func (*TaskQueueMetadata) ProtoMessage 

func (*TaskQueueMetadata) ProtoMessage()

func (*TaskQueueMetadata) Reset 

func (m *TaskQueueMetadata) Reset()

func (*TaskQueueMetadata) Size 

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

func (*TaskQueueMetadata) String 

func (this *TaskQueueMetadata) String() string

func (*TaskQueueMetadata) Unmarshal 

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

func (*TaskQueueMetadata) XXX_DiscardUnknown 

func (m *TaskQueueMetadata) XXX_DiscardUnknown()

func (*TaskQueueMetadata) XXX_Marshal 

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

func (*TaskQueueMetadata) XXX_Merge 

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

func (*TaskQueueMetadata) XXX_Size 

func (m *TaskQueueMetadata) XXX_Size() int

func (*TaskQueueMetadata) XXX_Unmarshal 

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

type TaskQueuePartitionMetadata 

type TaskQueuePartitionMetadata struct {
	Key           string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	OwnerHostName string `protobuf:"bytes,2,opt,name=owner_host_name,json=ownerHostName,proto3" json:"owner_host_name,omitempty"`
}

func (*TaskQueuePartitionMetadata) Descriptor 

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

func (*TaskQueuePartitionMetadata) Equal 

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

func (*TaskQueuePartitionMetadata) GetKey 

func (m *TaskQueuePartitionMetadata) GetKey() string

func (*TaskQueuePartitionMetadata) GetOwnerHostName 

func (m *TaskQueuePartitionMetadata) GetOwnerHostName() string

func (*TaskQueuePartitionMetadata) GoString 

func (this *TaskQueuePartitionMetadata) GoString() string

func (*TaskQueuePartitionMetadata) Marshal 

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

func (*TaskQueuePartitionMetadata) MarshalTo 

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

func (*TaskQueuePartitionMetadata) MarshalToSizedBuffer 

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

func (*TaskQueuePartitionMetadata) ProtoMessage 

func (*TaskQueuePartitionMetadata) ProtoMessage()

func (*TaskQueuePartitionMetadata) Reset 

func (m *TaskQueuePartitionMetadata) Reset()

func (*TaskQueuePartitionMetadata) Size 

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

func (*TaskQueuePartitionMetadata) String 

func (this *TaskQueuePartitionMetadata) String() string

func (*TaskQueuePartitionMetadata) Unmarshal 

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

func (*TaskQueuePartitionMetadata) XXX_DiscardUnknown 

func (m *TaskQueuePartitionMetadata) XXX_DiscardUnknown()

func (*TaskQueuePartitionMetadata) XXX_Marshal 

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

func (*TaskQueuePartitionMetadata) XXX_Merge 

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

func (*TaskQueuePartitionMetadata) XXX_Size 

func (m *TaskQueuePartitionMetadata) XXX_Size() int

func (*TaskQueuePartitionMetadata) XXX_Unmarshal 

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

type TaskQueueStatus 

type TaskQueueStatus struct {
	BacklogCountHint int64        `protobuf:"varint,1,opt,name=backlog_count_hint,json=backlogCountHint,proto3" json:"backlog_count_hint,omitempty"`
	ReadLevel        int64        `protobuf:"varint,2,opt,name=read_level,json=readLevel,proto3" json:"read_level,omitempty"`
	AckLevel         int64        `protobuf:"varint,3,opt,name=ack_level,json=ackLevel,proto3" json:"ack_level,omitempty"`
	RatePerSecond    float64      `protobuf:"fixed64,4,opt,name=rate_per_second,json=ratePerSecond,proto3" json:"rate_per_second,omitempty"`
	TaskIdBlock      *TaskIdBlock `protobuf:"bytes,5,opt,name=task_id_block,json=taskIdBlock,proto3" json:"task_id_block,omitempty"`
}

func (*TaskQueueStatus) Descriptor 

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

func (*TaskQueueStatus) Equal 

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

func (*TaskQueueStatus) GetAckLevel 

func (m *TaskQueueStatus) GetAckLevel() int64

func (*TaskQueueStatus) GetBacklogCountHint 

func (m *TaskQueueStatus) GetBacklogCountHint() int64

func (*TaskQueueStatus) GetRatePerSecond 

func (m *TaskQueueStatus) GetRatePerSecond() float64

func (*TaskQueueStatus) GetReadLevel 

func (m *TaskQueueStatus) GetReadLevel() int64

func (*TaskQueueStatus) GetTaskIdBlock 

func (m *TaskQueueStatus) GetTaskIdBlock() *TaskIdBlock

func (*TaskQueueStatus) GoString 

func (this *TaskQueueStatus) GoString() string

func (*TaskQueueStatus) Marshal 

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

func (*TaskQueueStatus) MarshalTo 

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

func (*TaskQueueStatus) MarshalToSizedBuffer 

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

func (*TaskQueueStatus) ProtoMessage 

func (*TaskQueueStatus) ProtoMessage()

func (*TaskQueueStatus) Reset 

func (m *TaskQueueStatus) Reset()

func (*TaskQueueStatus) Size 

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

func (*TaskQueueStatus) String 

func (this *TaskQueueStatus) String() string

func (*TaskQueueStatus) Unmarshal 

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

func (*TaskQueueStatus) XXX_DiscardUnknown 

func (m *TaskQueueStatus) XXX_DiscardUnknown()

func (*TaskQueueStatus) XXX_Marshal 

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

func (*TaskQueueStatus) XXX_Merge 

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

func (*TaskQueueStatus) XXX_Size 

func (m *TaskQueueStatus) XXX_Size() int

func (*TaskQueueStatus) XXX_Unmarshal 

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

type VersionId added in v1.9.0 

type VersionId struct {
	// An opaque whole-worker identifier
	WorkerBuildId string `protobuf:"bytes,1,opt,name=worker_build_id,json=workerBuildId,proto3" json:"worker_build_id,omitempty"`
}

Used by the worker versioning APIs, represents a specific version of something Currently, that's just a whole-worker id. In the future, if we support WASM workflow bundle based versioning, for example, then the inside of this message may become a oneof of different version types.

func (*VersionId) Descriptor added in v1.9.0 

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

func (*VersionId) Equal added in v1.9.0 

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

func (*VersionId) GetWorkerBuildId added in v1.9.0 

func (m *VersionId) GetWorkerBuildId() string

func (*VersionId) GoString added in v1.9.0 

func (this *VersionId) GoString() string

func (*VersionId) Marshal added in v1.9.0 

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

func (*VersionId) MarshalTo added in v1.9.0 

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

func (*VersionId) MarshalToSizedBuffer added in v1.9.0 

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

func (*VersionId) ProtoMessage added in v1.9.0 

func (*VersionId) ProtoMessage()

func (*VersionId) Reset added in v1.9.0 

func (m *VersionId) Reset()

func (*VersionId) Size added in v1.9.0 

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

func (*VersionId) String added in v1.9.0 

func (this *VersionId) String() string

func (*VersionId) Unmarshal added in v1.9.0 

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

func (*VersionId) XXX_DiscardUnknown added in v1.9.0 

func (m *VersionId) XXX_DiscardUnknown()

func (*VersionId) XXX_Marshal added in v1.9.0 

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

func (*VersionId) XXX_Merge added in v1.9.0 

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

func (*VersionId) XXX_Size added in v1.9.0 

func (m *VersionId) XXX_Size() int

func (*VersionId) XXX_Unmarshal added in v1.9.0 

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

type VersionIdNode added in v1.9.0 

type VersionIdNode struct {
	Version *VersionId `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// A pointer to the previous version this version is considered to be compatible with
	PreviousCompatible *VersionIdNode `protobuf:"bytes,2,opt,name=previous_compatible,json=previousCompatible,proto3" json:"previous_compatible,omitempty"`
	// A pointer to the last incompatible version (previous major version)
	PreviousIncompatible *VersionIdNode `protobuf:"bytes,3,opt,name=previous_incompatible,json=previousIncompatible,proto3" json:"previous_incompatible,omitempty"`
}

Used by the worker versioning APIs, represents a node in the version graph for a particular task queue

func (*VersionIdNode) Descriptor added in v1.9.0 

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

func (*VersionIdNode) Equal added in v1.9.0 

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

func (*VersionIdNode) GetPreviousCompatible added in v1.9.0 

func (m *VersionIdNode) GetPreviousCompatible() *VersionIdNode

func (*VersionIdNode) GetPreviousIncompatible added in v1.9.0 

func (m *VersionIdNode) GetPreviousIncompatible() *VersionIdNode

func (*VersionIdNode) GetVersion added in v1.9.0 

func (m *VersionIdNode) GetVersion() *VersionId

func (*VersionIdNode) GoString added in v1.9.0 

func (this *VersionIdNode) GoString() string

func (*VersionIdNode) Marshal added in v1.9.0 

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

func (*VersionIdNode) MarshalTo added in v1.9.0 

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

func (*VersionIdNode) MarshalToSizedBuffer added in v1.9.0 

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

func (*VersionIdNode) ProtoMessage added in v1.9.0 

func (*VersionIdNode) ProtoMessage()

func (*VersionIdNode) Reset added in v1.9.0 

func (m *VersionIdNode) Reset()

func (*VersionIdNode) Size added in v1.9.0 

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

func (*VersionIdNode) String added in v1.9.0 

func (this *VersionIdNode) String() string

func (*VersionIdNode) Unmarshal added in v1.9.0 

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

func (*VersionIdNode) XXX_DiscardUnknown added in v1.9.0 

func (m *VersionIdNode) XXX_DiscardUnknown()

func (*VersionIdNode) XXX_Marshal added in v1.9.0 

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

func (*VersionIdNode) XXX_Merge added in v1.9.0 

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

func (*VersionIdNode) XXX_Size added in v1.9.0 

func (m *VersionIdNode) XXX_Size() int

func (*VersionIdNode) XXX_Unmarshal added in v1.9.0 

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

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.