th2_grpc_common

package
v0.2.1 Latest Latest
Warning

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

 Go to latest Published: Dec 18, 2024 License: Apache-2.0 Imports: 7 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Direction_name = map[int32]string{
		0: "FIRST",
		1: "SECOND",
	}
	Direction_value = map[string]int32{
		"FIRST":  0,
		"SECOND": 1,
	}
)

Enum value maps for Direction.

View Source 
var (
	NullValue_name = map[int32]string{
		0: "NULL_VALUE",
	}
	NullValue_value = map[string]int32{
		"NULL_VALUE": 0,
	}
)

Enum value maps for NullValue.

View Source 
var (
	FailUnexpected_name = map[int32]string{
		0: "NO",
		1: "FIELDS",
		2: "FIELDS_AND_MESSAGES",
	}
	FailUnexpected_value = map[string]int32{
		"NO":                  0,
		"FIELDS":              1,
		"FIELDS_AND_MESSAGES": 2,
	}
)

Enum value maps for FailUnexpected.

View Source 
var (
	FilterOperation_name = map[int32]string{
		0:  "EQUAL",
		1:  "NOT_EQUAL",
		2:  "EMPTY",
		3:  "NOT_EMPTY",
		4:  "IN",
		5:  "NOT_IN",
		6:  "LIKE",
		7:  "NOT_LIKE",
		8:  "MORE",
		9:  "NOT_MORE",
		10: "LESS",
		11: "NOT_LESS",
		12: "WILDCARD",
		13: "NOT_WILDCARD",
		14: "EQ_TIME_PRECISION",
		15: "EQ_DECIMAL_PRECISION",
	}
	FilterOperation_value = map[string]int32{
		"EQUAL":                0,
		"NOT_EQUAL":            1,
		"EMPTY":                2,
		"NOT_EMPTY":            3,
		"IN":                   4,
		"NOT_IN":               5,
		"LIKE":                 6,
		"NOT_LIKE":             7,
		"MORE":                 8,
		"NOT_MORE":             9,
		"LESS":                 10,
		"NOT_LESS":             11,
		"WILDCARD":             12,
		"NOT_WILDCARD":         13,
		"EQ_TIME_PRECISION":    14,
		"EQ_DECIMAL_PRECISION": 15,
	}
)

Enum value maps for FilterOperation.

View Source 
var (
	EventStatus_name = map[int32]string{
		0: "SUCCESS",
		1: "FAILED",
	}
	EventStatus_value = map[string]int32{
		"SUCCESS": 0,
		"FAILED":  1,
	}
)

Enum value maps for EventStatus.

View Source 
var (
	RequestStatus_Status_name = map[int32]string{
		0: "SUCCESS",
		1: "ERROR",
	}
	RequestStatus_Status_value = map[string]int32{
		"SUCCESS": 0,
		"ERROR":   1,
	}
)

Enum value maps for RequestStatus_Status.

View Source 
var File_th2_grpc_common_common_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AnyMessage 

type AnyMessage struct {

	// Types that are assignable to Kind:
	//
	//	*AnyMessage_Message
	//	*AnyMessage_RawMessage
	Kind isAnyMessage_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

func (*AnyMessage) Descriptor deprecated 

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

Deprecated: Use AnyMessage.ProtoReflect.Descriptor instead.

func (*AnyMessage) GetKind 

func (m *AnyMessage) GetKind() isAnyMessage_Kind

func (*AnyMessage) GetMessage 

func (x *AnyMessage) GetMessage() *Message

func (*AnyMessage) GetRawMessage 

func (x *AnyMessage) GetRawMessage() *RawMessage

func (*AnyMessage) ProtoMessage 

func (*AnyMessage) ProtoMessage()

func (*AnyMessage) ProtoReflect 

func (x *AnyMessage) ProtoReflect() protoreflect.Message

func (*AnyMessage) Reset 

func (x *AnyMessage) Reset()

func (*AnyMessage) String 

func (x *AnyMessage) String() string

type AnyMessage_Message 

type AnyMessage_Message struct {
	Message *Message `protobuf:"bytes,1,opt,name=message,proto3,oneof"`
}

type AnyMessage_RawMessage 

type AnyMessage_RawMessage struct {
	RawMessage *RawMessage `protobuf:"bytes,2,opt,name=raw_message,json=rawMessage,proto3,oneof"`
}

type Checkpoint 

type Checkpoint struct {
	Id                                          string                                                   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	BookNameToSessionAliasToDirectionCheckpoint map[string]*Checkpoint_SessionAliasToDirectionCheckpoint `` /* 290-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Checkpoint) Descriptor deprecated 

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

Deprecated: Use Checkpoint.ProtoReflect.Descriptor instead.

func (*Checkpoint) GetBookNameToSessionAliasToDirectionCheckpoint 

func (x *Checkpoint) GetBookNameToSessionAliasToDirectionCheckpoint() map[string]*Checkpoint_SessionAliasToDirectionCheckpoint

func (*Checkpoint) GetId 

func (x *Checkpoint) GetId() string

func (*Checkpoint) ProtoMessage 

func (*Checkpoint) ProtoMessage()

func (*Checkpoint) ProtoReflect 

func (x *Checkpoint) ProtoReflect() protoreflect.Message

func (*Checkpoint) Reset 

func (x *Checkpoint) Reset()

func (*Checkpoint) String 

func (x *Checkpoint) String() string

type Checkpoint_CheckpointData 

type Checkpoint_CheckpointData struct {
	Sequence  int64                  `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`  // Message sequence number in session
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // Message creation timestamp
	// contains filtered or unexported fields
}

func (*Checkpoint_CheckpointData) Descriptor deprecated 

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

Deprecated: Use Checkpoint_CheckpointData.ProtoReflect.Descriptor instead.

func (*Checkpoint_CheckpointData) GetSequence 

func (x *Checkpoint_CheckpointData) GetSequence() int64

func (*Checkpoint_CheckpointData) GetTimestamp 

func (x *Checkpoint_CheckpointData) GetTimestamp() *timestamppb.Timestamp

func (*Checkpoint_CheckpointData) ProtoMessage 

func (*Checkpoint_CheckpointData) ProtoMessage()

func (*Checkpoint_CheckpointData) ProtoReflect 

func (x *Checkpoint_CheckpointData) ProtoReflect() protoreflect.Message

func (*Checkpoint_CheckpointData) Reset 

func (x *Checkpoint_CheckpointData) Reset()

func (*Checkpoint_CheckpointData) String 

func (x *Checkpoint_CheckpointData) String() string

type Checkpoint_DirectionCheckpoint 

type Checkpoint_DirectionCheckpoint struct {
	DirectionToCheckpointData map[int32]*Checkpoint_CheckpointData `` /* 229-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Checkpoint_DirectionCheckpoint) Descriptor deprecated 

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

Deprecated: Use Checkpoint_DirectionCheckpoint.ProtoReflect.Descriptor instead.

func (*Checkpoint_DirectionCheckpoint) GetDirectionToCheckpointData 

func (x *Checkpoint_DirectionCheckpoint) GetDirectionToCheckpointData() map[int32]*Checkpoint_CheckpointData

func (*Checkpoint_DirectionCheckpoint) ProtoMessage 

func (*Checkpoint_DirectionCheckpoint) ProtoMessage()

func (*Checkpoint_DirectionCheckpoint) ProtoReflect 

func (x *Checkpoint_DirectionCheckpoint) ProtoReflect() protoreflect.Message

func (*Checkpoint_DirectionCheckpoint) Reset 

func (x *Checkpoint_DirectionCheckpoint) Reset()

func (*Checkpoint_DirectionCheckpoint) String 

func (x *Checkpoint_DirectionCheckpoint) String() string

type Checkpoint_SessionAliasToDirectionCheckpoint 

type Checkpoint_SessionAliasToDirectionCheckpoint struct {
	SessionAliasToDirectionCheckpoint map[string]*Checkpoint_DirectionCheckpoint `` /* 254-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Checkpoint_SessionAliasToDirectionCheckpoint) Descriptor deprecated 

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

Deprecated: Use Checkpoint_SessionAliasToDirectionCheckpoint.ProtoReflect.Descriptor instead.

func (*Checkpoint_SessionAliasToDirectionCheckpoint) GetSessionAliasToDirectionCheckpoint 

func (x *Checkpoint_SessionAliasToDirectionCheckpoint) GetSessionAliasToDirectionCheckpoint() map[string]*Checkpoint_DirectionCheckpoint

func (*Checkpoint_SessionAliasToDirectionCheckpoint) ProtoMessage 

func (*Checkpoint_SessionAliasToDirectionCheckpoint) ProtoMessage()

func (*Checkpoint_SessionAliasToDirectionCheckpoint) ProtoReflect 

func (x *Checkpoint_SessionAliasToDirectionCheckpoint) ProtoReflect() protoreflect.Message

func (*Checkpoint_SessionAliasToDirectionCheckpoint) Reset 

func (x *Checkpoint_SessionAliasToDirectionCheckpoint) Reset()

func (*Checkpoint_SessionAliasToDirectionCheckpoint) String 

func (x *Checkpoint_SessionAliasToDirectionCheckpoint) String() string

type ComparisonSettings 

type ComparisonSettings struct {
	FailUnexpected FailUnexpected `protobuf:"varint,2,opt,name=fail_unexpected,json=failUnexpected,proto3,enum=FailUnexpected" json:"fail_unexpected,omitempty"`
	// contains filtered or unexported fields
}

func (*ComparisonSettings) Descriptor deprecated 

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

Deprecated: Use ComparisonSettings.ProtoReflect.Descriptor instead.

func (*ComparisonSettings) GetFailUnexpected 

func (x *ComparisonSettings) GetFailUnexpected() FailUnexpected

func (*ComparisonSettings) ProtoMessage 

func (*ComparisonSettings) ProtoMessage()

func (*ComparisonSettings) ProtoReflect 

func (x *ComparisonSettings) ProtoReflect() protoreflect.Message

func (*ComparisonSettings) Reset 

func (x *ComparisonSettings) Reset()

func (*ComparisonSettings) String 

func (x *ComparisonSettings) String() string

type ConnectionID 

type ConnectionID struct {
	SessionAlias string `protobuf:"bytes,1,opt,name=session_alias,json=sessionAlias,proto3" json:"session_alias,omitempty"` // Session identifier depends on protocol, target / sender
	SessionGroup string `protobuf:"bytes,2,opt,name=session_group,json=sessionGroup,proto3" json:"session_group,omitempty"` // Session group
	// contains filtered or unexported fields
}

func (*ConnectionID) Descriptor deprecated 

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

Deprecated: Use ConnectionID.ProtoReflect.Descriptor instead.

func (*ConnectionID) GetSessionAlias 

func (x *ConnectionID) GetSessionAlias() string

func (*ConnectionID) GetSessionGroup 

func (x *ConnectionID) GetSessionGroup() string

func (*ConnectionID) ProtoMessage 

func (*ConnectionID) ProtoMessage()

func (*ConnectionID) ProtoReflect 

func (x *ConnectionID) ProtoReflect() protoreflect.Message

func (*ConnectionID) Reset 

func (x *ConnectionID) Reset()

func (*ConnectionID) String 

func (x *ConnectionID) String() string

type Direction 

type Direction int32
const (
	Direction_FIRST  Direction = 0 // Incoming message for connectivity
	Direction_SECOND Direction = 1 // Outgoing message for connectivity
)

func (Direction) Descriptor 

func (Direction) Descriptor() protoreflect.EnumDescriptor

func (Direction) Enum 

func (x Direction) Enum() *Direction

func (Direction) EnumDescriptor deprecated 

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

Deprecated: Use Direction.Descriptor instead.

func (Direction) Number 

func (x Direction) Number() protoreflect.EnumNumber

func (Direction) String 

func (x Direction) String() string

func (Direction) Type 

func (Direction) Type() protoreflect.EnumType

type Event 

type Event struct {
	Id                 *EventID               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ParentId           *EventID               `protobuf:"bytes,2,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"` // Event id of parent event. It is null for root event
	EndTimestamp       *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=end_timestamp,json=endTimestamp,proto3" json:"end_timestamp,omitempty"`
	Status             EventStatus            `protobuf:"varint,5,opt,name=status,proto3,enum=EventStatus" json:"status,omitempty"` // Aggregated status of current and children events which sync written.
	Name               string                 `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"`
	Type               string                 `protobuf:"bytes,7,opt,name=type,proto3" json:"type,omitempty"`
	Body               []byte                 `protobuf:"bytes,8,opt,name=body,proto3" json:"body,omitempty"`
	AttachedMessageIds []*MessageID           `protobuf:"bytes,9,rep,name=attached_message_ids,json=attachedMessageIds,proto3" json:"attached_message_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetAttachedMessageIds 

func (x *Event) GetAttachedMessageIds() []*MessageID

func (*Event) GetBody 

func (x *Event) GetBody() []byte

func (*Event) GetEndTimestamp 

func (x *Event) GetEndTimestamp() *timestamppb.Timestamp

func (*Event) GetId 

func (x *Event) GetId() *EventID

func (*Event) GetName 

func (x *Event) GetName() string

func (*Event) GetParentId 

func (x *Event) GetParentId() *EventID

func (*Event) GetStatus 

func (x *Event) GetStatus() EventStatus

func (*Event) GetType 

func (x *Event) GetType() string

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

func (x *Event) ProtoReflect() protoreflect.Message

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type EventBatch 

type EventBatch struct {
	Metadata      *EventBatchMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	ParentEventId *EventID            `protobuf:"bytes,1,opt,name=parent_event_id,json=parentEventId,proto3" json:"parent_event_id,omitempty"`
	Events        []*Event            `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"` // Events optional related to between themselves. No events outside this batch should refer to the events in this batch.
	// contains filtered or unexported fields
}

func (*EventBatch) Descriptor deprecated 

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

Deprecated: Use EventBatch.ProtoReflect.Descriptor instead.

func (*EventBatch) GetEvents 

func (x *EventBatch) GetEvents() []*Event

func (*EventBatch) GetMetadata 

func (x *EventBatch) GetMetadata() *EventBatchMetadata

func (*EventBatch) GetParentEventId 

func (x *EventBatch) GetParentEventId() *EventID

func (*EventBatch) ProtoMessage 

func (*EventBatch) ProtoMessage()

func (*EventBatch) ProtoReflect 

func (x *EventBatch) ProtoReflect() protoreflect.Message

func (*EventBatch) Reset 

func (x *EventBatch) Reset()

func (*EventBatch) String 

func (x *EventBatch) String() string

type EventBatchMetadata 

type EventBatchMetadata struct {
	ExternalQueue string `protobuf:"bytes,1,opt,name=external_queue,json=externalQueue,proto3" json:"external_queue,omitempty"` // External user queue can be used for routing by internal box logic.
	// contains filtered or unexported fields
}

func (*EventBatchMetadata) Descriptor deprecated 

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

Deprecated: Use EventBatchMetadata.ProtoReflect.Descriptor instead.

func (*EventBatchMetadata) GetExternalQueue 

func (x *EventBatchMetadata) GetExternalQueue() string

func (*EventBatchMetadata) ProtoMessage 

func (*EventBatchMetadata) ProtoMessage()

func (*EventBatchMetadata) ProtoReflect 

func (x *EventBatchMetadata) ProtoReflect() protoreflect.Message

func (*EventBatchMetadata) Reset 

func (x *EventBatchMetadata) Reset()

func (*EventBatchMetadata) String 

func (x *EventBatchMetadata) String() string

type EventID 

type EventID struct {
	Id             string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Unique event id in TH2 deploy
	BookName       string                 `protobuf:"bytes,2,opt,name=book_name,json=bookName,proto3" json:"book_name,omitempty"`
	Scope          string                 `protobuf:"bytes,3,opt,name=scope,proto3" json:"scope,omitempty"`
	StartTimestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=start_timestamp,json=startTimestamp,proto3" json:"start_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*EventID) Descriptor deprecated 

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

Deprecated: Use EventID.ProtoReflect.Descriptor instead.

func (*EventID) GetBookName 

func (x *EventID) GetBookName() string

func (*EventID) GetId 

func (x *EventID) GetId() string

func (*EventID) GetScope 

func (x *EventID) GetScope() string

func (*EventID) GetStartTimestamp 

func (x *EventID) GetStartTimestamp() *timestamppb.Timestamp

func (*EventID) ProtoMessage 

func (*EventID) ProtoMessage()

func (*EventID) ProtoReflect 

func (x *EventID) ProtoReflect() protoreflect.Message

func (*EventID) Reset 

func (x *EventID) Reset()

func (*EventID) String 

func (x *EventID) String() string

type EventStatus 

type EventStatus int32

--// Event //--// 

const (
	EventStatus_SUCCESS EventStatus = 0
	EventStatus_FAILED  EventStatus = 1
)

func (EventStatus) Descriptor 

func (EventStatus) Descriptor() protoreflect.EnumDescriptor

func (EventStatus) Enum 

func (x EventStatus) Enum() *EventStatus

func (EventStatus) EnumDescriptor deprecated 

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

Deprecated: Use EventStatus.Descriptor instead.

func (EventStatus) Number 

func (x EventStatus) Number() protoreflect.EnumNumber

func (EventStatus) String 

func (x EventStatus) String() string

func (EventStatus) Type 

func (EventStatus) Type() protoreflect.EnumType

type FailUnexpected 

type FailUnexpected int32

--// Settings //--// 

const (
	FailUnexpected_NO                  FailUnexpected = 0 // comparison won't fail in case of unexpected fields or messages
	FailUnexpected_FIELDS              FailUnexpected = 1 // comparison will fail in case of unexpected fields only
	FailUnexpected_FIELDS_AND_MESSAGES FailUnexpected = 2 // comparison will fail in case of unexpected fields or messages
)

func (FailUnexpected) Descriptor 

func (FailUnexpected) Descriptor() protoreflect.EnumDescriptor

func (FailUnexpected) Enum 

func (x FailUnexpected) Enum() *FailUnexpected

func (FailUnexpected) EnumDescriptor deprecated 

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

Deprecated: Use FailUnexpected.Descriptor instead.

func (FailUnexpected) Number 

func (x FailUnexpected) Number() protoreflect.EnumNumber

func (FailUnexpected) String 

func (x FailUnexpected) String() string

func (FailUnexpected) Type 

func (FailUnexpected) Type() protoreflect.EnumType

type FilterOperation 

type FilterOperation int32
const (
	FilterOperation_EQUAL                FilterOperation = 0
	FilterOperation_NOT_EQUAL            FilterOperation = 1
	FilterOperation_EMPTY                FilterOperation = 2
	FilterOperation_NOT_EMPTY            FilterOperation = 3
	FilterOperation_IN                   FilterOperation = 4
	FilterOperation_NOT_IN               FilterOperation = 5
	FilterOperation_LIKE                 FilterOperation = 6
	FilterOperation_NOT_LIKE             FilterOperation = 7
	FilterOperation_MORE                 FilterOperation = 8
	FilterOperation_NOT_MORE             FilterOperation = 9
	FilterOperation_LESS                 FilterOperation = 10
	FilterOperation_NOT_LESS             FilterOperation = 11
	FilterOperation_WILDCARD             FilterOperation = 12
	FilterOperation_NOT_WILDCARD         FilterOperation = 13
	FilterOperation_EQ_TIME_PRECISION    FilterOperation = 14
	FilterOperation_EQ_DECIMAL_PRECISION FilterOperation = 15
)

func (FilterOperation) Descriptor 

func (FilterOperation) Descriptor() protoreflect.EnumDescriptor

func (FilterOperation) Enum 

func (x FilterOperation) Enum() *FilterOperation

func (FilterOperation) EnumDescriptor deprecated 

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

Deprecated: Use FilterOperation.Descriptor instead.

func (FilterOperation) Number 

func (x FilterOperation) Number() protoreflect.EnumNumber

func (FilterOperation) String 

func (x FilterOperation) String() string

func (FilterOperation) Type 

func (FilterOperation) Type() protoreflect.EnumType

type ListValue 

type ListValue struct {
	Values []*Value `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*ListValue) Descriptor deprecated 

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

Deprecated: Use ListValue.ProtoReflect.Descriptor instead.

func (*ListValue) GetValues 

func (x *ListValue) GetValues() []*Value

func (*ListValue) ProtoMessage 

func (*ListValue) ProtoMessage()

func (*ListValue) ProtoReflect 

func (x *ListValue) ProtoReflect() protoreflect.Message

func (*ListValue) Reset 

func (x *ListValue) Reset()

func (*ListValue) String 

func (x *ListValue) String() string

type ListValueFilter 

type ListValueFilter struct {
	Values []*ValueFilter `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*ListValueFilter) Descriptor deprecated 

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

Deprecated: Use ListValueFilter.ProtoReflect.Descriptor instead.

func (*ListValueFilter) GetValues 

func (x *ListValueFilter) GetValues() []*ValueFilter

func (*ListValueFilter) ProtoMessage 

func (*ListValueFilter) ProtoMessage()

func (*ListValueFilter) ProtoReflect 

func (x *ListValueFilter) ProtoReflect() protoreflect.Message

func (*ListValueFilter) Reset 

func (x *ListValueFilter) Reset()

func (*ListValueFilter) String 

func (x *ListValueFilter) String() string

type Message 

type Message struct {
	ParentEventId *EventID          `protobuf:"bytes,3,opt,name=parent_event_id,json=parentEventId,proto3" json:"parent_event_id,omitempty"` // It maybe used to store event related to message life cycle
	Metadata      *MessageMetadata  `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Fields        map[string]*Value `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Message) Descriptor deprecated 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetFields 

func (x *Message) GetFields() map[string]*Value

func (*Message) GetMetadata 

func (x *Message) GetMetadata() *MessageMetadata

func (*Message) GetParentEventId 

func (x *Message) GetParentEventId() *EventID

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

func (x *Message) ProtoReflect() protoreflect.Message

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) String 

func (x *Message) String() string

type MessageBatch 

type MessageBatch struct {
	Messages []*Message `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageBatch) Descriptor deprecated 

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

Deprecated: Use MessageBatch.ProtoReflect.Descriptor instead.

func (*MessageBatch) GetMessages 

func (x *MessageBatch) GetMessages() []*Message

func (*MessageBatch) ProtoMessage 

func (*MessageBatch) ProtoMessage()

func (*MessageBatch) ProtoReflect 

func (x *MessageBatch) ProtoReflect() protoreflect.Message

func (*MessageBatch) Reset 

func (x *MessageBatch) Reset()

func (*MessageBatch) String 

func (x *MessageBatch) String() string

type MessageFilter 

type MessageFilter struct {
	Fields             map[string]*ValueFilter `` /* 153-byte string literal not displayed */
	ComparisonSettings *ComparisonSettings     `protobuf:"bytes,4,opt,name=comparison_settings,json=comparisonSettings,proto3" json:"comparison_settings,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageFilter) Descriptor deprecated 

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

Deprecated: Use MessageFilter.ProtoReflect.Descriptor instead.

func (*MessageFilter) GetComparisonSettings 

func (x *MessageFilter) GetComparisonSettings() *ComparisonSettings

func (*MessageFilter) GetFields 

func (x *MessageFilter) GetFields() map[string]*ValueFilter

func (*MessageFilter) ProtoMessage 

func (*MessageFilter) ProtoMessage()

func (*MessageFilter) ProtoReflect 

func (x *MessageFilter) ProtoReflect() protoreflect.Message

func (*MessageFilter) Reset 

func (x *MessageFilter) Reset()

func (*MessageFilter) String 

func (x *MessageFilter) String() string

type MessageGroup 

type MessageGroup struct {
	Messages []*AnyMessage `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageGroup) Descriptor deprecated 

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

Deprecated: Use MessageGroup.ProtoReflect.Descriptor instead.

func (*MessageGroup) GetMessages 

func (x *MessageGroup) GetMessages() []*AnyMessage

func (*MessageGroup) ProtoMessage 

func (*MessageGroup) ProtoMessage()

func (*MessageGroup) ProtoReflect 

func (x *MessageGroup) ProtoReflect() protoreflect.Message

func (*MessageGroup) Reset 

func (x *MessageGroup) Reset()

func (*MessageGroup) String 

func (x *MessageGroup) String() string

type MessageGroupBatch 

type MessageGroupBatch struct {
	Metadata *MessageGroupBatchMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Groups   []*MessageGroup            `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageGroupBatch) Descriptor deprecated 

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

Deprecated: Use MessageGroupBatch.ProtoReflect.Descriptor instead.

func (*MessageGroupBatch) GetGroups 

func (x *MessageGroupBatch) GetGroups() []*MessageGroup

func (*MessageGroupBatch) GetMetadata 

func (x *MessageGroupBatch) GetMetadata() *MessageGroupBatchMetadata

func (*MessageGroupBatch) ProtoMessage 

func (*MessageGroupBatch) ProtoMessage()

func (*MessageGroupBatch) ProtoReflect 

func (x *MessageGroupBatch) ProtoReflect() protoreflect.Message

func (*MessageGroupBatch) Reset 

func (x *MessageGroupBatch) Reset()

func (*MessageGroupBatch) String 

func (x *MessageGroupBatch) String() string

type MessageGroupBatchMetadata 

type MessageGroupBatchMetadata struct {
	ExternalQueue string `protobuf:"bytes,1,opt,name=external_queue,json=externalQueue,proto3" json:"external_queue,omitempty"` // External user queue can be used for routing by internal box logic.
	// contains filtered or unexported fields
}

func (*MessageGroupBatchMetadata) Descriptor deprecated 

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

Deprecated: Use MessageGroupBatchMetadata.ProtoReflect.Descriptor instead.

func (*MessageGroupBatchMetadata) GetExternalQueue 

func (x *MessageGroupBatchMetadata) GetExternalQueue() string

func (*MessageGroupBatchMetadata) ProtoMessage 

func (*MessageGroupBatchMetadata) ProtoMessage()

func (*MessageGroupBatchMetadata) ProtoReflect 

func (x *MessageGroupBatchMetadata) ProtoReflect() protoreflect.Message

func (*MessageGroupBatchMetadata) Reset 

func (x *MessageGroupBatchMetadata) Reset()

func (*MessageGroupBatchMetadata) String 

func (x *MessageGroupBatchMetadata) String() string

type MessageID 

type MessageID struct {
	ConnectionId *ConnectionID          `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	Direction    Direction              `protobuf:"varint,2,opt,name=direction,proto3,enum=Direction" json:"direction,omitempty"` // Transport direction.
	Sequence     int64                  `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"`                  // Unique sequence number in session
	Subsequence  []uint32               `protobuf:"varint,4,rep,packed,name=subsequence,proto3" json:"subsequence,omitempty"`     // List of nested sequences in addition to the main one
	BookName     string                 `protobuf:"bytes,5,opt,name=book_name,json=bookName,proto3" json:"book_name,omitempty"`
	Timestamp    *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // Message creation timestamp
	// contains filtered or unexported fields
}

func (*MessageID) Descriptor deprecated 

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

Deprecated: Use MessageID.ProtoReflect.Descriptor instead.

func (*MessageID) GetBookName 

func (x *MessageID) GetBookName() string

func (*MessageID) GetConnectionId 

func (x *MessageID) GetConnectionId() *ConnectionID

func (*MessageID) GetDirection 

func (x *MessageID) GetDirection() Direction

func (*MessageID) GetSequence 

func (x *MessageID) GetSequence() int64

func (*MessageID) GetSubsequence 

func (x *MessageID) GetSubsequence() []uint32

func (*MessageID) GetTimestamp 

func (x *MessageID) GetTimestamp() *timestamppb.Timestamp

func (*MessageID) ProtoMessage 

func (*MessageID) ProtoMessage()

func (*MessageID) ProtoReflect 

func (x *MessageID) ProtoReflect() protoreflect.Message

func (*MessageID) Reset 

func (x *MessageID) Reset()

func (*MessageID) String 

func (x *MessageID) String() string

type MessageMetadata 

type MessageMetadata struct {
	Id          *MessageID        `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`                                      // Message id should be unique in session
	MessageType string            `protobuf:"bytes,3,opt,name=message_type,json=messageType,proto3" json:"message_type,omitempty"` // Message type by dictionary
	Properties  map[string]string ``                                                                                               // Additional properties for the message
	/* 161-byte string literal not displayed */
	Protocol string `protobuf:"bytes,5,opt,name=protocol,proto3" json:"protocol,omitempty"` // Protocol to be used when encoding the message
	// contains filtered or unexported fields
}

func (*MessageMetadata) Descriptor deprecated 

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

Deprecated: Use MessageMetadata.ProtoReflect.Descriptor instead.

func (*MessageMetadata) GetId 

func (x *MessageMetadata) GetId() *MessageID

func (*MessageMetadata) GetMessageType 

func (x *MessageMetadata) GetMessageType() string

func (*MessageMetadata) GetProperties 

func (x *MessageMetadata) GetProperties() map[string]string

func (*MessageMetadata) GetProtocol 

func (x *MessageMetadata) GetProtocol() string

func (*MessageMetadata) ProtoMessage 

func (*MessageMetadata) ProtoMessage()

func (*MessageMetadata) ProtoReflect 

func (x *MessageMetadata) ProtoReflect() protoreflect.Message

func (*MessageMetadata) Reset 

func (x *MessageMetadata) Reset()

func (*MessageMetadata) String 

func (x *MessageMetadata) String() string

type MetadataFilter 

type MetadataFilter struct {
	PropertyFilters map[string]*MetadataFilter_SimpleFilter `` /* 194-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MetadataFilter) Descriptor deprecated 

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

Deprecated: Use MetadataFilter.ProtoReflect.Descriptor instead.

func (*MetadataFilter) GetPropertyFilters 

func (x *MetadataFilter) GetPropertyFilters() map[string]*MetadataFilter_SimpleFilter

func (*MetadataFilter) ProtoMessage 

func (*MetadataFilter) ProtoMessage()

func (*MetadataFilter) ProtoReflect 

func (x *MetadataFilter) ProtoReflect() protoreflect.Message

func (*MetadataFilter) Reset 

func (x *MetadataFilter) Reset()

func (*MetadataFilter) String 

func (x *MetadataFilter) String() string

type MetadataFilter_SimpleFilter 

type MetadataFilter_SimpleFilter struct {
	Operation FilterOperation `protobuf:"varint,1,opt,name=operation,proto3,enum=FilterOperation" json:"operation,omitempty"`
	Key       bool            `protobuf:"varint,2,opt,name=key,proto3" json:"key,omitempty"`
	// Types that are assignable to FilterValue:
	//
	//	*MetadataFilter_SimpleFilter_Value
	//	*MetadataFilter_SimpleFilter_SimpleList
	FilterValue isMetadataFilter_SimpleFilter_FilterValue `protobuf_oneof:"filter_value"`
	// contains filtered or unexported fields
}

func (*MetadataFilter_SimpleFilter) Descriptor deprecated 

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

Deprecated: Use MetadataFilter_SimpleFilter.ProtoReflect.Descriptor instead.

func (*MetadataFilter_SimpleFilter) GetFilterValue 

func (m *MetadataFilter_SimpleFilter) GetFilterValue() isMetadataFilter_SimpleFilter_FilterValue

func (*MetadataFilter_SimpleFilter) GetKey 

func (x *MetadataFilter_SimpleFilter) GetKey() bool

func (*MetadataFilter_SimpleFilter) GetOperation 

func (x *MetadataFilter_SimpleFilter) GetOperation() FilterOperation

func (*MetadataFilter_SimpleFilter) GetSimpleList 

func (x *MetadataFilter_SimpleFilter) GetSimpleList() *SimpleList

func (*MetadataFilter_SimpleFilter) GetValue 

func (x *MetadataFilter_SimpleFilter) GetValue() string

func (*MetadataFilter_SimpleFilter) ProtoMessage 

func (*MetadataFilter_SimpleFilter) ProtoMessage()

func (*MetadataFilter_SimpleFilter) ProtoReflect 

func (x *MetadataFilter_SimpleFilter) ProtoReflect() protoreflect.Message

func (*MetadataFilter_SimpleFilter) Reset 

func (x *MetadataFilter_SimpleFilter) Reset()

func (*MetadataFilter_SimpleFilter) String 

func (x *MetadataFilter_SimpleFilter) String() string

type MetadataFilter_SimpleFilter_SimpleList 

type MetadataFilter_SimpleFilter_SimpleList struct {
	SimpleList *SimpleList `protobuf:"bytes,4,opt,name=simple_list,json=simpleList,proto3,oneof"`
}

type MetadataFilter_SimpleFilter_Value 

type MetadataFilter_SimpleFilter_Value struct {
	Value string `protobuf:"bytes,3,opt,name=value,proto3,oneof"`
}

type NullValue 

type NullValue int32
const (
	NullValue_NULL_VALUE NullValue = 0
)

func (NullValue) Descriptor 

func (NullValue) Descriptor() protoreflect.EnumDescriptor

func (NullValue) Enum 

func (x NullValue) Enum() *NullValue

func (NullValue) EnumDescriptor deprecated 

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

Deprecated: Use NullValue.Descriptor instead.

func (NullValue) Number 

func (x NullValue) Number() protoreflect.EnumNumber

func (NullValue) String 

func (x NullValue) String() string

func (NullValue) Type 

func (NullValue) Type() protoreflect.EnumType

type RawMessage 

type RawMessage struct {
	ParentEventId *EventID            `protobuf:"bytes,3,opt,name=parent_event_id,json=parentEventId,proto3" json:"parent_event_id,omitempty"` // It maybe used to store event related to message life cycle
	Metadata      *RawMessageMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Body          []byte              `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*RawMessage) Descriptor deprecated 

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

Deprecated: Use RawMessage.ProtoReflect.Descriptor instead.

func (*RawMessage) GetBody 

func (x *RawMessage) GetBody() []byte

func (*RawMessage) GetMetadata 

func (x *RawMessage) GetMetadata() *RawMessageMetadata

func (*RawMessage) GetParentEventId 

func (x *RawMessage) GetParentEventId() *EventID

func (*RawMessage) ProtoMessage 

func (*RawMessage) ProtoMessage()

func (*RawMessage) ProtoReflect 

func (x *RawMessage) ProtoReflect() protoreflect.Message

func (*RawMessage) Reset 

func (x *RawMessage) Reset()

func (*RawMessage) String 

func (x *RawMessage) String() string

type RawMessageBatch 

type RawMessageBatch struct {
	Messages []*RawMessage `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

func (*RawMessageBatch) Descriptor deprecated 

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

Deprecated: Use RawMessageBatch.ProtoReflect.Descriptor instead.

func (*RawMessageBatch) GetMessages 

func (x *RawMessageBatch) GetMessages() []*RawMessage

func (*RawMessageBatch) ProtoMessage 

func (*RawMessageBatch) ProtoMessage()

func (*RawMessageBatch) ProtoReflect 

func (x *RawMessageBatch) ProtoReflect() protoreflect.Message

func (*RawMessageBatch) Reset 

func (x *RawMessageBatch) Reset()

func (*RawMessageBatch) String 

func (x *RawMessageBatch) String() string

type RawMessageMetadata 

type RawMessageMetadata struct {
	Id         *MessageID        `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Message id should be unique in session
	Properties map[string]string ``                                                          // Additional properties for the raw message
	/* 161-byte string literal not displayed */
	Protocol string `protobuf:"bytes,4,opt,name=protocol,proto3" json:"protocol,omitempty"` // Protocol to be used when decoding the message
	// contains filtered or unexported fields
}

func (*RawMessageMetadata) Descriptor deprecated 

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

Deprecated: Use RawMessageMetadata.ProtoReflect.Descriptor instead.

func (*RawMessageMetadata) GetId 

func (x *RawMessageMetadata) GetId() *MessageID

func (*RawMessageMetadata) GetProperties 

func (x *RawMessageMetadata) GetProperties() map[string]string

func (*RawMessageMetadata) GetProtocol 

func (x *RawMessageMetadata) GetProtocol() string

func (*RawMessageMetadata) ProtoMessage 

func (*RawMessageMetadata) ProtoMessage()

func (*RawMessageMetadata) ProtoReflect 

func (x *RawMessageMetadata) ProtoReflect() protoreflect.Message

func (*RawMessageMetadata) Reset 

func (x *RawMessageMetadata) Reset()

func (*RawMessageMetadata) String 

func (x *RawMessageMetadata) String() string

type RequestStatus 

type RequestStatus struct {
	Status  RequestStatus_Status `protobuf:"varint,1,opt,name=status,proto3,enum=RequestStatus_Status" json:"status,omitempty"`
	Message string               `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestStatus) Descriptor deprecated 

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

Deprecated: Use RequestStatus.ProtoReflect.Descriptor instead.

func (*RequestStatus) GetMessage 

func (x *RequestStatus) GetMessage() string

func (*RequestStatus) GetStatus 

func (x *RequestStatus) GetStatus() RequestStatus_Status

func (*RequestStatus) ProtoMessage 

func (*RequestStatus) ProtoMessage()

func (*RequestStatus) ProtoReflect 

func (x *RequestStatus) ProtoReflect() protoreflect.Message

func (*RequestStatus) Reset 

func (x *RequestStatus) Reset()

func (*RequestStatus) String 

func (x *RequestStatus) String() string

type RequestStatus_Status 

type RequestStatus_Status int32
const (
	RequestStatus_SUCCESS RequestStatus_Status = 0
	RequestStatus_ERROR   RequestStatus_Status = 1
)

func (RequestStatus_Status) Descriptor 

func (RequestStatus_Status) Descriptor() protoreflect.EnumDescriptor

func (RequestStatus_Status) Enum 

func (x RequestStatus_Status) Enum() *RequestStatus_Status

func (RequestStatus_Status) EnumDescriptor deprecated 

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

Deprecated: Use RequestStatus_Status.Descriptor instead.

func (RequestStatus_Status) Number 

func (x RequestStatus_Status) Number() protoreflect.EnumNumber

func (RequestStatus_Status) String 

func (x RequestStatus_Status) String() string

func (RequestStatus_Status) Type 

func (RequestStatus_Status) Type() protoreflect.EnumType

type RootComparisonSettings 

type RootComparisonSettings struct {

	// These fields will not be considered during comparison. It concerns fields with simple or collection types.
	// Comparison result will have the NA status for them.
	IgnoreFields []string `protobuf:"bytes,1,rep,name=ignore_fields,json=ignoreFields,proto3" json:"ignore_fields,omitempty"`
	// Enables order verification in repeating groups according to defined filters.
	CheckRepeatingGroupOrder bool `` /* 138-byte string literal not displayed */
	// Time precision format for comparing timestamps
	TimePrecision *durationpb.Duration `protobuf:"bytes,3,opt,name=time_precision,json=timePrecision,proto3" json:"time_precision,omitempty"`
	// Decimal precision format for comparing numbers. E.g. 0.0001, 0.125, 125E-3 could be supported
	DecimalPrecision string `protobuf:"bytes,4,opt,name=decimal_precision,json=decimalPrecision,proto3" json:"decimal_precision,omitempty"`
	// contains filtered or unexported fields
}

func (*RootComparisonSettings) Descriptor deprecated 

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

Deprecated: Use RootComparisonSettings.ProtoReflect.Descriptor instead.

func (*RootComparisonSettings) GetCheckRepeatingGroupOrder 

func (x *RootComparisonSettings) GetCheckRepeatingGroupOrder() bool

func (*RootComparisonSettings) GetDecimalPrecision 

func (x *RootComparisonSettings) GetDecimalPrecision() string

func (*RootComparisonSettings) GetIgnoreFields 

func (x *RootComparisonSettings) GetIgnoreFields() []string

func (*RootComparisonSettings) GetTimePrecision 

func (x *RootComparisonSettings) GetTimePrecision() *durationpb.Duration

func (*RootComparisonSettings) ProtoMessage 

func (*RootComparisonSettings) ProtoMessage()

func (*RootComparisonSettings) ProtoReflect 

func (x *RootComparisonSettings) ProtoReflect() protoreflect.Message

func (*RootComparisonSettings) Reset 

func (x *RootComparisonSettings) Reset()

func (*RootComparisonSettings) String 

func (x *RootComparisonSettings) String() string

type RootMessageFilter 

type RootMessageFilter struct {

	// The message type to match
	MessageType string `protobuf:"bytes,1,opt,name=messageType,proto3" json:"messageType,omitempty"`
	// The filter to match message's content
	MessageFilter *MessageFilter `protobuf:"bytes,2,opt,name=message_filter,json=messageFilter,proto3" json:"message_filter,omitempty"`
	// The filter to match message's metadata content
	MetadataFilter *MetadataFilter `protobuf:"bytes,3,opt,name=metadata_filter,json=metadataFilter,proto3" json:"metadata_filter,omitempty"`
	// Settings that will be used for comparing both filters (MessageFilter and MetadataFilter)
	ComparisonSettings *RootComparisonSettings `protobuf:"bytes,4,opt,name=comparison_settings,json=comparisonSettings,proto3" json:"comparison_settings,omitempty"`
	// Description that may contain some information about the RootMessageFilter
	Description *wrapperspb.StringValue `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*RootMessageFilter) Descriptor deprecated 

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

Deprecated: Use RootMessageFilter.ProtoReflect.Descriptor instead.

func (*RootMessageFilter) GetComparisonSettings 

func (x *RootMessageFilter) GetComparisonSettings() *RootComparisonSettings

func (*RootMessageFilter) GetDescription 

func (x *RootMessageFilter) GetDescription() *wrapperspb.StringValue

func (*RootMessageFilter) GetMessageFilter 

func (x *RootMessageFilter) GetMessageFilter() *MessageFilter

func (*RootMessageFilter) GetMessageType 

func (x *RootMessageFilter) GetMessageType() string

func (*RootMessageFilter) GetMetadataFilter 

func (x *RootMessageFilter) GetMetadataFilter() *MetadataFilter

func (*RootMessageFilter) ProtoMessage 

func (*RootMessageFilter) ProtoMessage()

func (*RootMessageFilter) ProtoReflect 

func (x *RootMessageFilter) ProtoReflect() protoreflect.Message

func (*RootMessageFilter) Reset 

func (x *RootMessageFilter) Reset()

func (*RootMessageFilter) String 

func (x *RootMessageFilter) String() string

type SimpleList 

type SimpleList struct {
	SimpleValues []string `protobuf:"bytes,1,rep,name=simple_values,json=simpleValues,proto3" json:"simple_values,omitempty"`
	// contains filtered or unexported fields
}

func (*SimpleList) Descriptor deprecated 

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

Deprecated: Use SimpleList.ProtoReflect.Descriptor instead.

func (*SimpleList) GetSimpleValues 

func (x *SimpleList) GetSimpleValues() []string

func (*SimpleList) ProtoMessage 

func (*SimpleList) ProtoMessage()

func (*SimpleList) ProtoReflect 

func (x *SimpleList) ProtoReflect() protoreflect.Message

func (*SimpleList) Reset 

func (x *SimpleList) Reset()

func (*SimpleList) String 

func (x *SimpleList) String() string

type Value 

type Value struct {

	// Types that are assignable to Kind:
	//
	//	*Value_NullValue
	//	*Value_SimpleValue
	//	*Value_MessageValue
	//	*Value_ListValue
	Kind isValue_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

func (*Value) Descriptor deprecated 

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

Deprecated: Use Value.ProtoReflect.Descriptor instead.

func (*Value) GetKind 

func (m *Value) GetKind() isValue_Kind

func (*Value) GetListValue 

func (x *Value) GetListValue() *ListValue

func (*Value) GetMessageValue 

func (x *Value) GetMessageValue() *Message

func (*Value) GetNullValue 

func (x *Value) GetNullValue() NullValue

func (*Value) GetSimpleValue 

func (x *Value) GetSimpleValue() string

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) ProtoReflect 

func (x *Value) ProtoReflect() protoreflect.Message

func (*Value) Reset 

func (x *Value) Reset()

func (*Value) String 

func (x *Value) String() string

type ValueFilter 

type ValueFilter struct {
	Operation FilterOperation `protobuf:"varint,1,opt,name=operation,proto3,enum=FilterOperation" json:"operation,omitempty"`
	Key       bool            `protobuf:"varint,2,opt,name=key,proto3" json:"key,omitempty"`
	// Types that are assignable to Kind:
	//
	//	*ValueFilter_SimpleFilter
	//	*ValueFilter_MessageFilter
	//	*ValueFilter_ListFilter
	//	*ValueFilter_SimpleList
	//	*ValueFilter_NullValue
	Kind isValueFilter_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

func (*ValueFilter) Descriptor deprecated 

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

Deprecated: Use ValueFilter.ProtoReflect.Descriptor instead.

func (*ValueFilter) GetKey 

func (x *ValueFilter) GetKey() bool

func (*ValueFilter) GetKind 

func (m *ValueFilter) GetKind() isValueFilter_Kind

func (*ValueFilter) GetListFilter 

func (x *ValueFilter) GetListFilter() *ListValueFilter

func (*ValueFilter) GetMessageFilter 

func (x *ValueFilter) GetMessageFilter() *MessageFilter

func (*ValueFilter) GetNullValue 

func (x *ValueFilter) GetNullValue() NullValue

func (*ValueFilter) GetOperation 

func (x *ValueFilter) GetOperation() FilterOperation

func (*ValueFilter) GetSimpleFilter 

func (x *ValueFilter) GetSimpleFilter() string

func (*ValueFilter) GetSimpleList 

func (x *ValueFilter) GetSimpleList() *SimpleList

func (*ValueFilter) ProtoMessage 

func (*ValueFilter) ProtoMessage()

func (*ValueFilter) ProtoReflect 

func (x *ValueFilter) ProtoReflect() protoreflect.Message

func (*ValueFilter) Reset 

func (x *ValueFilter) Reset()

func (*ValueFilter) String 

func (x *ValueFilter) String() string

type ValueFilter_ListFilter 

type ValueFilter_ListFilter struct {
	ListFilter *ListValueFilter `protobuf:"bytes,5,opt,name=list_filter,json=listFilter,proto3,oneof"`
}

type ValueFilter_MessageFilter 

type ValueFilter_MessageFilter struct {
	MessageFilter *MessageFilter `protobuf:"bytes,4,opt,name=message_filter,json=messageFilter,proto3,oneof"`
}

type ValueFilter_NullValue 

type ValueFilter_NullValue struct {
	NullValue NullValue `protobuf:"varint,7,opt,name=null_value,json=nullValue,proto3,enum=NullValue,oneof"`
}

type ValueFilter_SimpleFilter 

type ValueFilter_SimpleFilter struct {
	SimpleFilter string `protobuf:"bytes,3,opt,name=simple_filter,json=simpleFilter,proto3,oneof"`
}

type ValueFilter_SimpleList 

type ValueFilter_SimpleList struct {
	SimpleList *SimpleList `protobuf:"bytes,6,opt,name=simple_list,json=simpleList,proto3,oneof"`
}

type Value_ListValue 

type Value_ListValue struct {
	ListValue *ListValue `protobuf:"bytes,4,opt,name=list_value,json=listValue,proto3,oneof"`
}

type Value_MessageValue 

type Value_MessageValue struct {
	MessageValue *Message `protobuf:"bytes,3,opt,name=message_value,json=messageValue,proto3,oneof"`
}

type Value_NullValue 

type Value_NullValue struct {
	NullValue NullValue `protobuf:"varint,1,opt,name=null_value,json=nullValue,proto3,enum=NullValue,oneof"`
}

type Value_SimpleValue 

type Value_SimpleValue struct {
	SimpleValue string `protobuf:"bytes,2,opt,name=simple_value,json=simpleValue,proto3,oneof"`
}

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.