indexer

package
v1.5.6 Latest Latest
Warning

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

 Go to latest Published: Feb 18, 2021 License: MIT Imports: 10 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")
)

Functions

This section is empty.

Types

type Field 

type Field struct {
	Type v1.FieldType `protobuf:"varint,1,opt,name=type,proto3,enum=temporal.server.api.enums.v1.FieldType" json:"type,omitempty"`
	// Types that are valid to be assigned to Data:
	//	*Field_StringData
	//	*Field_IntData
	//	*Field_BoolData
	//	*Field_BinaryData
	Data isField_Data `protobuf_oneof:"data"`
}

Deprecated. Remove with kafka removal.

func (*Field) Descriptor 

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

func (*Field) Equal 

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

func (*Field) GetBinaryData 

func (m *Field) GetBinaryData() []byte

func (*Field) GetBoolData 

func (m *Field) GetBoolData() bool

func (*Field) GetData 

func (m *Field) GetData() isField_Data

func (*Field) GetIntData 

func (m *Field) GetIntData() int64

func (*Field) GetStringData 

func (m *Field) GetStringData() string

func (*Field) GetType 

func (m *Field) GetType() v1.FieldType

func (*Field) GoString 

func (this *Field) GoString() string

func (*Field) Marshal 

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

func (*Field) MarshalTo 

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

func (*Field) MarshalToSizedBuffer 

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

func (*Field) ProtoMessage 

func (*Field) ProtoMessage()

func (*Field) Reset 

func (m *Field) Reset()

func (*Field) Size 

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

func (*Field) String 

func (this *Field) String() string

func (*Field) Unmarshal 

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

func (*Field) XXX_DiscardUnknown 

func (m *Field) XXX_DiscardUnknown()

func (*Field) XXX_Marshal 

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

func (*Field) XXX_Merge 

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

func (*Field) XXX_OneofWrappers 

func (*Field) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Field) XXX_Size 

func (m *Field) XXX_Size() int

func (*Field) XXX_Unmarshal 

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

type Field_BinaryData 

type Field_BinaryData struct {
	BinaryData []byte `protobuf:"bytes,5,opt,name=binary_data,json=binaryData,proto3,oneof" json:"binary_data,omitempty"`
}

func (*Field_BinaryData) Equal 

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

func (*Field_BinaryData) GoString 

func (this *Field_BinaryData) GoString() string

func (*Field_BinaryData) MarshalTo 

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

func (*Field_BinaryData) MarshalToSizedBuffer 

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

func (*Field_BinaryData) Size 

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

func (*Field_BinaryData) String 

func (this *Field_BinaryData) String() string

type Field_BoolData 

type Field_BoolData struct {
	BoolData bool `protobuf:"varint,4,opt,name=bool_data,json=boolData,proto3,oneof" json:"bool_data,omitempty"`
}

func (*Field_BoolData) Equal 

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

func (*Field_BoolData) GoString 

func (this *Field_BoolData) GoString() string

func (*Field_BoolData) MarshalTo 

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

func (*Field_BoolData) MarshalToSizedBuffer 

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

func (*Field_BoolData) Size 

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

func (*Field_BoolData) String 

func (this *Field_BoolData) String() string

type Field_IntData 

type Field_IntData struct {
	IntData int64 `protobuf:"varint,3,opt,name=int_data,json=intData,proto3,oneof" json:"int_data,omitempty"`
}

func (*Field_IntData) Equal 

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

func (*Field_IntData) GoString 

func (this *Field_IntData) GoString() string

func (*Field_IntData) MarshalTo 

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

func (*Field_IntData) MarshalToSizedBuffer 

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

func (*Field_IntData) Size 

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

func (*Field_IntData) String 

func (this *Field_IntData) String() string

type Field_StringData 

type Field_StringData struct {
	StringData string `protobuf:"bytes,2,opt,name=string_data,json=stringData,proto3,oneof" json:"string_data,omitempty"`
}

func (*Field_StringData) Equal 

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

func (*Field_StringData) GoString 

func (this *Field_StringData) GoString() string

func (*Field_StringData) MarshalTo 

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

func (*Field_StringData) MarshalToSizedBuffer 

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

func (*Field_StringData) Size 

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

func (*Field_StringData) String 

func (this *Field_StringData) String() string

type Message 

type Message struct {
	MessageType v1.MessageType    `` /* 141-byte string literal not displayed */
	NamespaceId string            `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WorkflowId  string            `protobuf:"bytes,3,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId       string            `protobuf:"bytes,4,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Version     int64             `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
	Fields      map[string]*Field `` /* 153-byte string literal not displayed */
}

Deprecated. Remove with kafka removal.

func (*Message) Descriptor 

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

func (*Message) Equal 

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

func (*Message) GetFields 

func (m *Message) GetFields() map[string]*Field

func (*Message) GetMessageType 

func (m *Message) GetMessageType() v1.MessageType

func (*Message) GetNamespaceId 

func (m *Message) GetNamespaceId() string

func (*Message) GetRunId 

func (m *Message) GetRunId() string

func (*Message) GetVersion 

func (m *Message) GetVersion() int64

func (*Message) GetWorkflowId 

func (m *Message) GetWorkflowId() string

func (*Message) GoString 

func (this *Message) GoString() string

func (*Message) Marshal 

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

func (*Message) MarshalTo 

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

func (*Message) MarshalToSizedBuffer 

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

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) Size 

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

func (*Message) String 

func (this *Message) String() string

func (*Message) Unmarshal 

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

func (*Message) XXX_DiscardUnknown 

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal 

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

func (*Message) XXX_Merge 

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

func (*Message) XXX_Size 

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal 

func (m *Message) 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.