iscp2v1

package
v0.2.2-0...-e1f0025 Latest Latest
Warning

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

 Go to latest Published: Aug 9, 2023 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	QoS_name = map[int32]string{
		0: "UNRELIABLE",
		1: "RELIABLE",
		2: "PARTIAL",
	}
	QoS_value = map[string]int32{
		"UNRELIABLE": 0,
		"RELIABLE":   1,
		"PARTIAL":    2,
	}
)

Enum value maps for QoS.

View Source 
var (
	ResultCode_name = map[int32]string{
		0: "SUCCEEDED",

		1:   "INCOMPATIBLE_VERSION",
		2:   "MAXIMUM_DATA_ID_ALIAS",
		3:   "MAXIMUM_UPSTREAM_ALIAS",
		64:  "UNSPECIFIED_ERROR",
		65:  "NO_NODE_ID",
		66:  "AUTH_FAILED",
		67:  "CONNECT_TIMEOUT",
		68:  "MALFORMED_MESSAGE",
		69:  "PROTOCOL_ERROR",
		70:  "ACK_TIMEOUT",
		71:  "INVALID_PAYLOAD",
		72:  "INVALID_DATA_ID",
		73:  "INVALID_DATA_ID_ALIAS",
		74:  "INVALID_DATA_FILTER",
		75:  "STREAM_NOT_FOUND",
		76:  "RESUME_REQUEST_CONFLICT",
		77:  "PROCESS_FAILED",
		78:  "DESIRED_QOS_NOT_SUPPORTED",
		79:  "PING_TIMEOUT",
		80:  "TOO_LARGE_MESSAGE_SIZE",
		81:  "TOO_MANY_DATA_ID_ALIASES",
		82:  "TOO_MANY_STREAMS",
		83:  "TOO_LONG_ACK_INTERVAL",
		84:  "TOO_MANY_DOWNSTREAM_FILTERS",
		85:  "TOO_MANY_DATA_FILTERS",
		86:  "TOO_LONG_EXPIRY_INTERVAL",
		87:  "TOO_LONG_PING_TIMEOUT",
		88:  "TOO_SHORT_PING_INTERVAL",
		89:  "TOO_SHORT_PING_TIMEOUT",
		90:  "RATE_LIMIT_REACHED",
		128: "NODE_ID_MISMATCH",
		129: "SESSION_NOT_FOUND",
		130: "SESSION_ALREADY_CLOSED",
		131: "SESSION_CANNOT_CLOSED",
	}
	ResultCode_value = map[string]int32{
		"SUCCEEDED":                   0,
		"NORMAL_CLOSURE":              0,
		"INCOMPATIBLE_VERSION":        1,
		"MAXIMUM_DATA_ID_ALIAS":       2,
		"MAXIMUM_UPSTREAM_ALIAS":      3,
		"UNSPECIFIED_ERROR":           64,
		"NO_NODE_ID":                  65,
		"AUTH_FAILED":                 66,
		"CONNECT_TIMEOUT":             67,
		"MALFORMED_MESSAGE":           68,
		"PROTOCOL_ERROR":              69,
		"ACK_TIMEOUT":                 70,
		"INVALID_PAYLOAD":             71,
		"INVALID_DATA_ID":             72,
		"INVALID_DATA_ID_ALIAS":       73,
		"INVALID_DATA_FILTER":         74,
		"STREAM_NOT_FOUND":            75,
		"RESUME_REQUEST_CONFLICT":     76,
		"PROCESS_FAILED":              77,
		"DESIRED_QOS_NOT_SUPPORTED":   78,
		"PING_TIMEOUT":                79,
		"TOO_LARGE_MESSAGE_SIZE":      80,
		"TOO_MANY_DATA_ID_ALIASES":    81,
		"TOO_MANY_STREAMS":            82,
		"TOO_LONG_ACK_INTERVAL":       83,
		"TOO_MANY_DOWNSTREAM_FILTERS": 84,
		"TOO_MANY_DATA_FILTERS":       85,
		"TOO_LONG_EXPIRY_INTERVAL":    86,
		"TOO_LONG_PING_TIMEOUT":       87,
		"TOO_SHORT_PING_INTERVAL":     88,
		"TOO_SHORT_PING_TIMEOUT":      89,
		"RATE_LIMIT_REACHED":          90,
		"NODE_ID_MISMATCH":            128,
		"SESSION_NOT_FOUND":           129,
		"SESSION_ALREADY_CLOSED":      130,
		"SESSION_CANNOT_CLOSED":       131,
	}
)

Enum value maps for ResultCode.

View Source 
var File_iscp2_v1_common_proto protoreflect.FileDescriptor
View Source 
var File_iscp2_v1_connection_proto protoreflect.FileDescriptor
View Source 
var File_iscp2_v1_downstream_proto protoreflect.FileDescriptor
View Source 
var File_iscp2_v1_e2e_call_proto protoreflect.FileDescriptor
View Source 
var File_iscp2_v1_message_proto protoreflect.FileDescriptor
View Source 
var File_iscp2_v1_metadata_proto protoreflect.FileDescriptor
View Source 
var File_iscp2_v1_ping_pong_proto protoreflect.FileDescriptor
View Source 
var File_iscp2_v1_result_code_proto protoreflect.FileDescriptor
View Source 
var File_iscp2_v1_upstream_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BaseTime 

type BaseTime struct {
	SessionId   string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Name        string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Priority    uint32 `protobuf:"varint,3,opt,name=priority,proto3" json:"priority,omitempty"`
	ElapsedTime uint64 `protobuf:"varint,4,opt,name=elapsed_time,json=elapsedTime,proto3" json:"elapsed_time,omitempty"`
	BaseTime    int64  `protobuf:"zigzag64,5,opt,name=base_time,json=baseTime,proto3" json:"base_time,omitempty"`
	// contains filtered or unexported fields
}

func (*BaseTime) Descriptor deprecated 

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

Deprecated: Use BaseTime.ProtoReflect.Descriptor instead.

func (*BaseTime) GetBaseTime 

func (x *BaseTime) GetBaseTime() int64

func (*BaseTime) GetElapsedTime 

func (x *BaseTime) GetElapsedTime() uint64

func (*BaseTime) GetName 

func (x *BaseTime) GetName() string

func (*BaseTime) GetPriority 

func (x *BaseTime) GetPriority() uint32

func (*BaseTime) GetSessionId 

func (x *BaseTime) GetSessionId() string

func (*BaseTime) ProtoMessage 

func (*BaseTime) ProtoMessage()

func (*BaseTime) ProtoReflect 

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

func (*BaseTime) Reset 

func (x *BaseTime) Reset()

func (*BaseTime) String 

func (x *BaseTime) String() string

type ConnectRequest 

type ConnectRequest struct {
	RequestId       uint32                                    `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	ProtocolVersion string                                    `protobuf:"bytes,2,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	NodeId          string                                    `protobuf:"bytes,3,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	PingInterval    uint32                                    `protobuf:"varint,4,opt,name=ping_interval,json=pingInterval,proto3" json:"ping_interval,omitempty"`
	PingTimeout     uint32                                    `protobuf:"varint,5,opt,name=ping_timeout,json=pingTimeout,proto3" json:"ping_timeout,omitempty"`
	ExtensionFields *extensions.ConnectRequestExtensionFields `protobuf:"bytes,6,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectRequest) Descriptor deprecated 

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

Deprecated: Use ConnectRequest.ProtoReflect.Descriptor instead.

func (*ConnectRequest) GetExtensionFields 

func (x *ConnectRequest) GetExtensionFields() *extensions.ConnectRequestExtensionFields

func (*ConnectRequest) GetNodeId 

func (x *ConnectRequest) GetNodeId() string

func (*ConnectRequest) GetPingInterval 

func (x *ConnectRequest) GetPingInterval() uint32

func (*ConnectRequest) GetPingTimeout 

func (x *ConnectRequest) GetPingTimeout() uint32

func (*ConnectRequest) GetProtocolVersion 

func (x *ConnectRequest) GetProtocolVersion() string

func (*ConnectRequest) GetRequestId 

func (x *ConnectRequest) GetRequestId() uint32

func (*ConnectRequest) ProtoMessage 

func (*ConnectRequest) ProtoMessage()

func (*ConnectRequest) ProtoReflect 

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

func (*ConnectRequest) Reset 

func (x *ConnectRequest) Reset()

func (*ConnectRequest) String 

func (x *ConnectRequest) String() string

type ConnectResponse 

type ConnectResponse struct {
	RequestId       uint32                                     `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	ProtocolVersion string                                     `protobuf:"bytes,2,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	ResultCode      ResultCode                                 `protobuf:"varint,3,opt,name=result_code,json=resultCode,proto3,enum=iscp2.v1.ResultCode" json:"result_code,omitempty"`
	ResultString    string                                     `protobuf:"bytes,4,opt,name=result_string,json=resultString,proto3" json:"result_string,omitempty"`
	ExtensionFields *extensions.ConnectResponseExtensionFields `protobuf:"bytes,5,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectResponse) Descriptor deprecated 

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

Deprecated: Use ConnectResponse.ProtoReflect.Descriptor instead.

func (*ConnectResponse) GetExtensionFields 

func (x *ConnectResponse) GetExtensionFields() *extensions.ConnectResponseExtensionFields

func (*ConnectResponse) GetProtocolVersion 

func (x *ConnectResponse) GetProtocolVersion() string

func (*ConnectResponse) GetRequestId 

func (x *ConnectResponse) GetRequestId() uint32

func (*ConnectResponse) GetResultCode 

func (x *ConnectResponse) GetResultCode() ResultCode

func (*ConnectResponse) GetResultString 

func (x *ConnectResponse) GetResultString() string

func (*ConnectResponse) ProtoMessage 

func (*ConnectResponse) ProtoMessage()

func (*ConnectResponse) ProtoReflect 

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

func (*ConnectResponse) Reset 

func (x *ConnectResponse) Reset()

func (*ConnectResponse) String 

func (x *ConnectResponse) String() string

type DataFilter 

type DataFilter struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*DataFilter) Descriptor deprecated 

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

Deprecated: Use DataFilter.ProtoReflect.Descriptor instead.

func (*DataFilter) GetName 

func (x *DataFilter) GetName() string

func (*DataFilter) GetType 

func (x *DataFilter) GetType() string

func (*DataFilter) ProtoMessage 

func (*DataFilter) ProtoMessage()

func (*DataFilter) ProtoReflect 

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

func (*DataFilter) Reset 

func (x *DataFilter) Reset()

func (*DataFilter) String 

func (x *DataFilter) String() string

type DataID 

type DataID struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*DataID) Descriptor deprecated 

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

Deprecated: Use DataID.ProtoReflect.Descriptor instead.

func (*DataID) GetName 

func (x *DataID) GetName() string

func (*DataID) GetType 

func (x *DataID) GetType() string

func (*DataID) ProtoMessage 

func (*DataID) ProtoMessage()

func (*DataID) ProtoReflect 

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

func (*DataID) Reset 

func (x *DataID) Reset()

func (*DataID) String 

func (x *DataID) String() string

type DataPoint 

type DataPoint struct {
	ElapsedTime int64  `protobuf:"zigzag64,1,opt,name=elapsed_time,json=elapsedTime,proto3" json:"elapsed_time,omitempty"`
	Payload     []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*DataPoint) Descriptor deprecated 

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

Deprecated: Use DataPoint.ProtoReflect.Descriptor instead.

func (*DataPoint) GetElapsedTime 

func (x *DataPoint) GetElapsedTime() int64

func (*DataPoint) GetPayload 

func (x *DataPoint) GetPayload() []byte

func (*DataPoint) ProtoMessage 

func (*DataPoint) ProtoMessage()

func (*DataPoint) ProtoReflect 

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

func (*DataPoint) Reset 

func (x *DataPoint) Reset()

func (*DataPoint) String 

func (x *DataPoint) String() string

type DataPointGroup 

type DataPointGroup struct {

	// Types that are assignable to DataIdOrAlias:
	//
	//	*DataPointGroup_DataId
	//	*DataPointGroup_DataIdAlias
	DataIdOrAlias isDataPointGroup_DataIdOrAlias `protobuf_oneof:"data_id_or_alias"`
	DataPoints    []*DataPoint                   `protobuf:"bytes,3,rep,name=data_points,json=dataPoints,proto3" json:"data_points,omitempty"`
	// contains filtered or unexported fields
}

func (*DataPointGroup) Descriptor deprecated 

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

Deprecated: Use DataPointGroup.ProtoReflect.Descriptor instead.

func (*DataPointGroup) GetDataId 

func (x *DataPointGroup) GetDataId() *DataID

func (*DataPointGroup) GetDataIdAlias 

func (x *DataPointGroup) GetDataIdAlias() uint32

func (*DataPointGroup) GetDataIdOrAlias 

func (m *DataPointGroup) GetDataIdOrAlias() isDataPointGroup_DataIdOrAlias

func (*DataPointGroup) GetDataPoints 

func (x *DataPointGroup) GetDataPoints() []*DataPoint

func (*DataPointGroup) ProtoMessage 

func (*DataPointGroup) ProtoMessage()

func (*DataPointGroup) ProtoReflect 

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

func (*DataPointGroup) Reset 

func (x *DataPointGroup) Reset()

func (*DataPointGroup) String 

func (x *DataPointGroup) String() string

type DataPointGroup_DataId 

type DataPointGroup_DataId struct {
	DataId *DataID `protobuf:"bytes,1,opt,name=data_id,json=dataId,proto3,oneof"`
}

type DataPointGroup_DataIdAlias 

type DataPointGroup_DataIdAlias struct {
	DataIdAlias uint32 `protobuf:"varint,2,opt,name=data_id_alias,json=dataIdAlias,proto3,oneof"`
}

type Disconnect 

type Disconnect struct {
	ResultCode      ResultCode                            `protobuf:"varint,1,opt,name=result_code,json=resultCode,proto3,enum=iscp2.v1.ResultCode" json:"result_code,omitempty"`
	ResultString    string                                `protobuf:"bytes,2,opt,name=result_string,json=resultString,proto3" json:"result_string,omitempty"`
	ExtensionFields *extensions.DisconnectExtensionFields `protobuf:"bytes,3,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*Disconnect) Descriptor deprecated 

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

Deprecated: Use Disconnect.ProtoReflect.Descriptor instead.

func (*Disconnect) GetExtensionFields 

func (x *Disconnect) GetExtensionFields() *extensions.DisconnectExtensionFields

func (*Disconnect) GetResultCode 

func (x *Disconnect) GetResultCode() ResultCode

func (*Disconnect) GetResultString 

func (x *Disconnect) GetResultString() string

func (*Disconnect) ProtoMessage 

func (*Disconnect) ProtoMessage()

func (*Disconnect) ProtoReflect 

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

func (*Disconnect) Reset 

func (x *Disconnect) Reset()

func (*Disconnect) String 

func (x *Disconnect) String() string

type DownstreamAbnormalClose 

type DownstreamAbnormalClose struct {
	StreamId []byte `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DownstreamAbnormalClose) Descriptor deprecated 

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

Deprecated: Use DownstreamAbnormalClose.ProtoReflect.Descriptor instead.

func (*DownstreamAbnormalClose) GetStreamId 

func (x *DownstreamAbnormalClose) GetStreamId() []byte

func (*DownstreamAbnormalClose) ProtoMessage 

func (*DownstreamAbnormalClose) ProtoMessage()

func (*DownstreamAbnormalClose) ProtoReflect 

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

func (*DownstreamAbnormalClose) Reset 

func (x *DownstreamAbnormalClose) Reset()

func (*DownstreamAbnormalClose) String 

func (x *DownstreamAbnormalClose) String() string

type DownstreamCall 

type DownstreamCall struct {
	CallId          string                                    `protobuf:"bytes,1,opt,name=call_id,json=callId,proto3" json:"call_id,omitempty"`
	RequestCallId   string                                    `protobuf:"bytes,2,opt,name=request_call_id,json=requestCallId,proto3" json:"request_call_id,omitempty"`
	SourceNodeId    string                                    `protobuf:"bytes,3,opt,name=source_node_id,json=sourceNodeId,proto3" json:"source_node_id,omitempty"`
	Name            string                                    `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Type            string                                    `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"`
	Payload         []byte                                    `protobuf:"bytes,6,opt,name=payload,proto3" json:"payload,omitempty"`
	ExtensionFields *extensions.DownstreamCallExtensionFields `protobuf:"bytes,7,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*DownstreamCall) Descriptor deprecated 

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

Deprecated: Use DownstreamCall.ProtoReflect.Descriptor instead.

func (*DownstreamCall) GetCallId 

func (x *DownstreamCall) GetCallId() string

func (*DownstreamCall) GetExtensionFields 

func (x *DownstreamCall) GetExtensionFields() *extensions.DownstreamCallExtensionFields

func (*DownstreamCall) GetName 

func (x *DownstreamCall) GetName() string

func (*DownstreamCall) GetPayload 

func (x *DownstreamCall) GetPayload() []byte

func (*DownstreamCall) GetRequestCallId 

func (x *DownstreamCall) GetRequestCallId() string

func (*DownstreamCall) GetSourceNodeId 

func (x *DownstreamCall) GetSourceNodeId() string

func (*DownstreamCall) GetType 

func (x *DownstreamCall) GetType() string

func (*DownstreamCall) ProtoMessage 

func (*DownstreamCall) ProtoMessage()

func (*DownstreamCall) ProtoReflect 

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

func (*DownstreamCall) Reset 

func (x *DownstreamCall) Reset()

func (*DownstreamCall) String 

func (x *DownstreamCall) String() string

type DownstreamChunk 

type DownstreamChunk struct {
	StreamIdAlias uint32 `protobuf:"varint,1,opt,name=stream_id_alias,json=streamIdAlias,proto3" json:"stream_id_alias,omitempty"`
	// Types that are assignable to UpstreamOrAlias:
	//
	//	*DownstreamChunk_UpstreamInfo
	//	*DownstreamChunk_UpstreamAlias
	UpstreamOrAlias isDownstreamChunk_UpstreamOrAlias          `protobuf_oneof:"upstream_or_alias"`
	StreamChunk     *StreamChunk                               `protobuf:"bytes,4,opt,name=stream_chunk,json=streamChunk,proto3" json:"stream_chunk,omitempty"`
	ExtensionFields *extensions.DownstreamChunkExtensionFields `protobuf:"bytes,5,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*DownstreamChunk) Descriptor deprecated 

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

Deprecated: Use DownstreamChunk.ProtoReflect.Descriptor instead.

func (*DownstreamChunk) GetExtensionFields 

func (x *DownstreamChunk) GetExtensionFields() *extensions.DownstreamChunkExtensionFields

func (*DownstreamChunk) GetStreamChunk 

func (x *DownstreamChunk) GetStreamChunk() *StreamChunk

func (*DownstreamChunk) GetStreamIdAlias 

func (x *DownstreamChunk) GetStreamIdAlias() uint32

func (*DownstreamChunk) GetUpstreamAlias 

func (x *DownstreamChunk) GetUpstreamAlias() uint32

func (*DownstreamChunk) GetUpstreamInfo 

func (x *DownstreamChunk) GetUpstreamInfo() *UpstreamInfo

func (*DownstreamChunk) GetUpstreamOrAlias 

func (m *DownstreamChunk) GetUpstreamOrAlias() isDownstreamChunk_UpstreamOrAlias

func (*DownstreamChunk) ProtoMessage 

func (*DownstreamChunk) ProtoMessage()

func (*DownstreamChunk) ProtoReflect 

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

func (*DownstreamChunk) Reset 

func (x *DownstreamChunk) Reset()

func (*DownstreamChunk) String 

func (x *DownstreamChunk) String() string

type DownstreamChunkAck 

type DownstreamChunkAck struct {
	StreamIdAlias   uint32                                        `protobuf:"varint,1,opt,name=stream_id_alias,json=streamIdAlias,proto3" json:"stream_id_alias,omitempty"`
	AckId           uint32                                        `protobuf:"varint,2,opt,name=ack_id,json=ackId,proto3" json:"ack_id,omitempty"`
	Results         []*DownstreamChunkResult                      `protobuf:"bytes,3,rep,name=results,proto3" json:"results,omitempty"`
	UpstreamAliases map[uint32]*UpstreamInfo                      `` /* 195-byte string literal not displayed */
	DataIdAliases   map[uint32]*DataID                            `` /* 191-byte string literal not displayed */
	ExtensionFields *extensions.DownstreamChunkAckExtensionFields `protobuf:"bytes,6,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*DownstreamChunkAck) Descriptor deprecated 

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

Deprecated: Use DownstreamChunkAck.ProtoReflect.Descriptor instead.

func (*DownstreamChunkAck) GetAckId 

func (x *DownstreamChunkAck) GetAckId() uint32

func (*DownstreamChunkAck) GetDataIdAliases 

func (x *DownstreamChunkAck) GetDataIdAliases() map[uint32]*DataID

func (*DownstreamChunkAck) GetExtensionFields 

func (x *DownstreamChunkAck) GetExtensionFields() *extensions.DownstreamChunkAckExtensionFields

func (*DownstreamChunkAck) GetResults 

func (x *DownstreamChunkAck) GetResults() []*DownstreamChunkResult

func (*DownstreamChunkAck) GetStreamIdAlias 

func (x *DownstreamChunkAck) GetStreamIdAlias() uint32

func (*DownstreamChunkAck) GetUpstreamAliases 

func (x *DownstreamChunkAck) GetUpstreamAliases() map[uint32]*UpstreamInfo

func (*DownstreamChunkAck) ProtoMessage 

func (*DownstreamChunkAck) ProtoMessage()

func (*DownstreamChunkAck) ProtoReflect 

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

func (*DownstreamChunkAck) Reset 

func (x *DownstreamChunkAck) Reset()

func (*DownstreamChunkAck) String 

func (x *DownstreamChunkAck) String() string

type DownstreamChunkAckComplete 

type DownstreamChunkAckComplete struct {
	StreamIdAlias   uint32                                                `protobuf:"varint,1,opt,name=stream_id_alias,json=streamIdAlias,proto3" json:"stream_id_alias,omitempty"`
	AckId           uint32                                                `protobuf:"varint,2,opt,name=ack_id,json=ackId,proto3" json:"ack_id,omitempty"`
	ResultCode      ResultCode                                            `protobuf:"varint,3,opt,name=result_code,json=resultCode,proto3,enum=iscp2.v1.ResultCode" json:"result_code,omitempty"`
	ResultString    string                                                `protobuf:"bytes,4,opt,name=result_string,json=resultString,proto3" json:"result_string,omitempty"`
	ExtensionFields *extensions.DownstreamChunkAckCompleteExtensionFields `protobuf:"bytes,5,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*DownstreamChunkAckComplete) Descriptor deprecated 

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

Deprecated: Use DownstreamChunkAckComplete.ProtoReflect.Descriptor instead.

func (*DownstreamChunkAckComplete) GetAckId 

func (x *DownstreamChunkAckComplete) GetAckId() uint32

func (*DownstreamChunkAckComplete) GetExtensionFields 

func (x *DownstreamChunkAckComplete) GetExtensionFields() *extensions.DownstreamChunkAckCompleteExtensionFields

func (*DownstreamChunkAckComplete) GetResultCode 

func (x *DownstreamChunkAckComplete) GetResultCode() ResultCode

func (*DownstreamChunkAckComplete) GetResultString 

func (x *DownstreamChunkAckComplete) GetResultString() string

func (*DownstreamChunkAckComplete) GetStreamIdAlias 

func (x *DownstreamChunkAckComplete) GetStreamIdAlias() uint32

func (*DownstreamChunkAckComplete) ProtoMessage 

func (*DownstreamChunkAckComplete) ProtoMessage()

func (*DownstreamChunkAckComplete) ProtoReflect 

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

func (*DownstreamChunkAckComplete) Reset 

func (x *DownstreamChunkAckComplete) Reset()

func (*DownstreamChunkAckComplete) String 

func (x *DownstreamChunkAckComplete) String() string

type DownstreamChunkResult 

type DownstreamChunkResult struct {
	StreamIdOfUpstream       []byte                                           `protobuf:"bytes,1,opt,name=stream_id_of_upstream,json=streamIdOfUpstream,proto3" json:"stream_id_of_upstream,omitempty"`
	SequenceNumberInUpstream uint32                                           `` /* 138-byte string literal not displayed */
	ResultCode               ResultCode                                       `protobuf:"varint,3,opt,name=result_code,json=resultCode,proto3,enum=iscp2.v1.ResultCode" json:"result_code,omitempty"`
	ResultString             string                                           `protobuf:"bytes,4,opt,name=result_string,json=resultString,proto3" json:"result_string,omitempty"`
	ExtensionFields          *extensions.DownstreamChunkResultExtensionFields `protobuf:"bytes,5,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*DownstreamChunkResult) Descriptor deprecated 

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

Deprecated: Use DownstreamChunkResult.ProtoReflect.Descriptor instead.

func (*DownstreamChunkResult) GetExtensionFields 

func (x *DownstreamChunkResult) GetExtensionFields() *extensions.DownstreamChunkResultExtensionFields

func (*DownstreamChunkResult) GetResultCode 

func (x *DownstreamChunkResult) GetResultCode() ResultCode

func (*DownstreamChunkResult) GetResultString 

func (x *DownstreamChunkResult) GetResultString() string

func (*DownstreamChunkResult) GetSequenceNumberInUpstream 

func (x *DownstreamChunkResult) GetSequenceNumberInUpstream() uint32

func (*DownstreamChunkResult) GetStreamIdOfUpstream 

func (x *DownstreamChunkResult) GetStreamIdOfUpstream() []byte

func (*DownstreamChunkResult) ProtoMessage 

func (*DownstreamChunkResult) ProtoMessage()

func (*DownstreamChunkResult) ProtoReflect 

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

func (*DownstreamChunkResult) Reset 

func (x *DownstreamChunkResult) Reset()

func (*DownstreamChunkResult) String 

func (x *DownstreamChunkResult) String() string

type DownstreamChunk_UpstreamAlias 

type DownstreamChunk_UpstreamAlias struct {
	UpstreamAlias uint32 `protobuf:"varint,3,opt,name=upstream_alias,json=upstreamAlias,proto3,oneof"`
}

type DownstreamChunk_UpstreamInfo 

type DownstreamChunk_UpstreamInfo struct {
	UpstreamInfo *UpstreamInfo `protobuf:"bytes,2,opt,name=upstream_info,json=upstreamInfo,proto3,oneof"`
}

type DownstreamCloseRequest 

type DownstreamCloseRequest struct {
	RequestId       uint32                                            `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	StreamId        []byte                                            `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	ExtensionFields *extensions.DownstreamCloseRequestExtensionFields `protobuf:"bytes,3,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*DownstreamCloseRequest) Descriptor deprecated 

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

Deprecated: Use DownstreamCloseRequest.ProtoReflect.Descriptor instead.

func (*DownstreamCloseRequest) GetExtensionFields 

func (x *DownstreamCloseRequest) GetExtensionFields() *extensions.DownstreamCloseRequestExtensionFields

func (*DownstreamCloseRequest) GetRequestId 

func (x *DownstreamCloseRequest) GetRequestId() uint32

func (*DownstreamCloseRequest) GetStreamId 

func (x *DownstreamCloseRequest) GetStreamId() []byte

func (*DownstreamCloseRequest) ProtoMessage 

func (*DownstreamCloseRequest) ProtoMessage()

func (*DownstreamCloseRequest) ProtoReflect 

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

func (*DownstreamCloseRequest) Reset 

func (x *DownstreamCloseRequest) Reset()

func (*DownstreamCloseRequest) String 

func (x *DownstreamCloseRequest) String() string

type DownstreamCloseResponse 

type DownstreamCloseResponse struct {
	RequestId       uint32                                             `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	ResultCode      ResultCode                                         `protobuf:"varint,2,opt,name=result_code,json=resultCode,proto3,enum=iscp2.v1.ResultCode" json:"result_code,omitempty"`
	ResultString    string                                             `protobuf:"bytes,3,opt,name=result_string,json=resultString,proto3" json:"result_string,omitempty"`
	ExtensionFields *extensions.DownstreamCloseResponseExtensionFields `protobuf:"bytes,4,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*DownstreamCloseResponse) Descriptor deprecated 

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

Deprecated: Use DownstreamCloseResponse.ProtoReflect.Descriptor instead.

func (*DownstreamCloseResponse) GetExtensionFields 

func (x *DownstreamCloseResponse) GetExtensionFields() *extensions.DownstreamCloseResponseExtensionFields

func (*DownstreamCloseResponse) GetRequestId 

func (x *DownstreamCloseResponse) GetRequestId() uint32

func (*DownstreamCloseResponse) GetResultCode 

func (x *DownstreamCloseResponse) GetResultCode() ResultCode

func (*DownstreamCloseResponse) GetResultString 

func (x *DownstreamCloseResponse) GetResultString() string

func (*DownstreamCloseResponse) ProtoMessage 

func (*DownstreamCloseResponse) ProtoMessage()

func (*DownstreamCloseResponse) ProtoReflect 

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

func (*DownstreamCloseResponse) Reset 

func (x *DownstreamCloseResponse) Reset()

func (*DownstreamCloseResponse) String 

func (x *DownstreamCloseResponse) String() string

type DownstreamFilter 

type DownstreamFilter struct {
	SourceNodeId string        `protobuf:"bytes,1,opt,name=source_node_id,json=sourceNodeId,proto3" json:"source_node_id,omitempty"`
	DataFilters  []*DataFilter `protobuf:"bytes,2,rep,name=data_filters,json=dataFilters,proto3" json:"data_filters,omitempty"`
	// contains filtered or unexported fields
}

func (*DownstreamFilter) Descriptor deprecated 

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

Deprecated: Use DownstreamFilter.ProtoReflect.Descriptor instead.

func (*DownstreamFilter) GetDataFilters 

func (x *DownstreamFilter) GetDataFilters() []*DataFilter

func (*DownstreamFilter) GetSourceNodeId 

func (x *DownstreamFilter) GetSourceNodeId() string

func (*DownstreamFilter) ProtoMessage 

func (*DownstreamFilter) ProtoMessage()

func (*DownstreamFilter) ProtoReflect 

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

func (*DownstreamFilter) Reset 

func (x *DownstreamFilter) Reset()

func (*DownstreamFilter) String 

func (x *DownstreamFilter) String() string

type DownstreamMetadata 

type DownstreamMetadata struct {
	RequestId     uint32 `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	StreamIdAlias uint32 `protobuf:"varint,13,opt,name=stream_id_alias,json=streamIdAlias,proto3" json:"stream_id_alias,omitempty"`
	// Types that are assignable to Metadata:
	//
	//	*DownstreamMetadata_BaseTime
	//	*DownstreamMetadata_UpstreamOpen
	//	*DownstreamMetadata_UpstreamAbnormalClose
	//	*DownstreamMetadata_UpstreamResume
	//	*DownstreamMetadata_UpstreamNormalClose
	//	*DownstreamMetadata_DownstreamOpen
	//	*DownstreamMetadata_DownstreamAbnormalClose
	//	*DownstreamMetadata_DownstreamResume
	//	*DownstreamMetadata_DownstreamNormalClose
	Metadata        isDownstreamMetadata_Metadata                 `protobuf_oneof:"metadata"`
	SourceNodeId    string                                        `protobuf:"bytes,11,opt,name=source_node_id,json=sourceNodeId,proto3" json:"source_node_id,omitempty"`
	ExtensionFields *extensions.DownstreamMetadataExtensionFields `protobuf:"bytes,12,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*DownstreamMetadata) Descriptor deprecated 

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

Deprecated: Use DownstreamMetadata.ProtoReflect.Descriptor instead.

func (*DownstreamMetadata) GetBaseTime 

func (x *DownstreamMetadata) GetBaseTime() *BaseTime

func (*DownstreamMetadata) GetDownstreamAbnormalClose 

func (x *DownstreamMetadata) GetDownstreamAbnormalClose() *DownstreamAbnormalClose

func (*DownstreamMetadata) GetDownstreamNormalClose 

func (x *DownstreamMetadata) GetDownstreamNormalClose() *DownstreamNormalClose

func (*DownstreamMetadata) GetDownstreamOpen 

func (x *DownstreamMetadata) GetDownstreamOpen() *DownstreamOpen

func (*DownstreamMetadata) GetDownstreamResume 

func (x *DownstreamMetadata) GetDownstreamResume() *DownstreamResume

func (*DownstreamMetadata) GetExtensionFields 

func (x *DownstreamMetadata) GetExtensionFields() *extensions.DownstreamMetadataExtensionFields

func (*DownstreamMetadata) GetMetadata 

func (m *DownstreamMetadata) GetMetadata() isDownstreamMetadata_Metadata

func (*DownstreamMetadata) GetRequestId 

func (x *DownstreamMetadata) GetRequestId() uint32

func (*DownstreamMetadata) GetSourceNodeId 

func (x *DownstreamMetadata) GetSourceNodeId() string

func (*DownstreamMetadata) GetStreamIdAlias 

func (x *DownstreamMetadata) GetStreamIdAlias() uint32

func (*DownstreamMetadata) GetUpstreamAbnormalClose 

func (x *DownstreamMetadata) GetUpstreamAbnormalClose() *UpstreamAbnormalClose

func (*DownstreamMetadata) GetUpstreamNormalClose 

func (x *DownstreamMetadata) GetUpstreamNormalClose() *UpstreamNormalClose

func (*DownstreamMetadata) GetUpstreamOpen 

func (x *DownstreamMetadata) GetUpstreamOpen() *UpstreamOpen

func (*DownstreamMetadata) GetUpstreamResume 

func (x *DownstreamMetadata) GetUpstreamResume() *UpstreamResume

func (*DownstreamMetadata) ProtoMessage 

func (*DownstreamMetadata) ProtoMessage()

func (*DownstreamMetadata) ProtoReflect 

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

func (*DownstreamMetadata) Reset 

func (x *DownstreamMetadata) Reset()

func (*DownstreamMetadata) String 

func (x *DownstreamMetadata) String() string

type DownstreamMetadataAck 

type DownstreamMetadataAck struct {
	RequestId       uint32                                           `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	ResultCode      ResultCode                                       `protobuf:"varint,2,opt,name=result_code,json=resultCode,proto3,enum=iscp2.v1.ResultCode" json:"result_code,omitempty"`
	ResultString    string                                           `protobuf:"bytes,3,opt,name=result_string,json=resultString,proto3" json:"result_string,omitempty"`
	ExtensionFields *extensions.DownstreamMetadataAckExtensionFields `protobuf:"bytes,4,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*DownstreamMetadataAck) Descriptor deprecated 

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

Deprecated: Use DownstreamMetadataAck.ProtoReflect.Descriptor instead.

func (*DownstreamMetadataAck) GetExtensionFields 

func (x *DownstreamMetadataAck) GetExtensionFields() *extensions.DownstreamMetadataAckExtensionFields

func (*DownstreamMetadataAck) GetRequestId 

func (x *DownstreamMetadataAck) GetRequestId() uint32

func (*DownstreamMetadataAck) GetResultCode 

func (x *DownstreamMetadataAck) GetResultCode() ResultCode

func (*DownstreamMetadataAck) GetResultString 

func (x *DownstreamMetadataAck) GetResultString() string

func (*DownstreamMetadataAck) ProtoMessage 

func (*DownstreamMetadataAck) ProtoMessage()

func (*DownstreamMetadataAck) ProtoReflect 

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

func (*DownstreamMetadataAck) Reset 

func (x *DownstreamMetadataAck) Reset()

func (*DownstreamMetadataAck) String 

func (x *DownstreamMetadataAck) String() string

type DownstreamMetadata_BaseTime 

type DownstreamMetadata_BaseTime struct {
	BaseTime *BaseTime `protobuf:"bytes,2,opt,name=base_time,json=baseTime,proto3,oneof"`
}

type DownstreamMetadata_DownstreamAbnormalClose 

type DownstreamMetadata_DownstreamAbnormalClose struct {
	DownstreamAbnormalClose *DownstreamAbnormalClose `protobuf:"bytes,8,opt,name=downstream_abnormal_close,json=downstreamAbnormalClose,proto3,oneof"`
}

type DownstreamMetadata_DownstreamNormalClose 

type DownstreamMetadata_DownstreamNormalClose struct {
	DownstreamNormalClose *DownstreamNormalClose `protobuf:"bytes,10,opt,name=downstream_normal_close,json=downstreamNormalClose,proto3,oneof"`
}

type DownstreamMetadata_DownstreamOpen 

type DownstreamMetadata_DownstreamOpen struct {
	DownstreamOpen *DownstreamOpen `protobuf:"bytes,7,opt,name=downstream_open,json=downstreamOpen,proto3,oneof"`
}

type DownstreamMetadata_DownstreamResume 

type DownstreamMetadata_DownstreamResume struct {
	DownstreamResume *DownstreamResume `protobuf:"bytes,9,opt,name=downstream_resume,json=downstreamResume,proto3,oneof"`
}

type DownstreamMetadata_UpstreamAbnormalClose 

type DownstreamMetadata_UpstreamAbnormalClose struct {
	UpstreamAbnormalClose *UpstreamAbnormalClose `protobuf:"bytes,4,opt,name=upstream_abnormal_close,json=upstreamAbnormalClose,proto3,oneof"`
}

type DownstreamMetadata_UpstreamNormalClose 

type DownstreamMetadata_UpstreamNormalClose struct {
	UpstreamNormalClose *UpstreamNormalClose `protobuf:"bytes,6,opt,name=upstream_normal_close,json=upstreamNormalClose,proto3,oneof"`
}

type DownstreamMetadata_UpstreamOpen 

type DownstreamMetadata_UpstreamOpen struct {
	UpstreamOpen *UpstreamOpen `protobuf:"bytes,3,opt,name=upstream_open,json=upstreamOpen,proto3,oneof"`
}

type DownstreamMetadata_UpstreamResume 

type DownstreamMetadata_UpstreamResume struct {
	UpstreamResume *UpstreamResume `protobuf:"bytes,5,opt,name=upstream_resume,json=upstreamResume,proto3,oneof"`
}

type DownstreamNormalClose 

type DownstreamNormalClose struct {
	StreamId []byte `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DownstreamNormalClose) Descriptor deprecated 

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

Deprecated: Use DownstreamNormalClose.ProtoReflect.Descriptor instead.

func (*DownstreamNormalClose) GetStreamId 

func (x *DownstreamNormalClose) GetStreamId() []byte

func (*DownstreamNormalClose) ProtoMessage 

func (*DownstreamNormalClose) ProtoMessage()

func (*DownstreamNormalClose) ProtoReflect 

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

func (*DownstreamNormalClose) Reset 

func (x *DownstreamNormalClose) Reset()

func (*DownstreamNormalClose) String 

func (x *DownstreamNormalClose) String() string

type DownstreamOpen 

type DownstreamOpen struct {
	StreamId          []byte              `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	DownstreamFilters []*DownstreamFilter `protobuf:"bytes,2,rep,name=downstream_filters,json=downstreamFilters,proto3" json:"downstream_filters,omitempty"`
	Qos               QoS                 `protobuf:"varint,3,opt,name=qos,proto3,enum=iscp2.v1.QoS" json:"qos,omitempty"`
	// contains filtered or unexported fields
}

func (*DownstreamOpen) Descriptor deprecated 

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

Deprecated: Use DownstreamOpen.ProtoReflect.Descriptor instead.

func (*DownstreamOpen) GetDownstreamFilters 

func (x *DownstreamOpen) GetDownstreamFilters() []*DownstreamFilter

func (*DownstreamOpen) GetQos 

func (x *DownstreamOpen) GetQos() QoS

func (*DownstreamOpen) GetStreamId 

func (x *DownstreamOpen) GetStreamId() []byte

func (*DownstreamOpen) ProtoMessage 

func (*DownstreamOpen) ProtoMessage()

func (*DownstreamOpen) ProtoReflect 

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

func (*DownstreamOpen) Reset 

func (x *DownstreamOpen) Reset()

func (*DownstreamOpen) String 

func (x *DownstreamOpen) String() string

type DownstreamOpenRequest 

type DownstreamOpenRequest struct {
	RequestId            uint32                                           `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	DesiredStreamIdAlias uint32                                           `` /* 126-byte string literal not displayed */
	DownstreamFilters    []*DownstreamFilter                              `protobuf:"bytes,3,rep,name=downstream_filters,json=downstreamFilters,proto3" json:"downstream_filters,omitempty"`
	ExpiryInterval       uint32                                           `protobuf:"varint,4,opt,name=expiry_interval,json=expiryInterval,proto3" json:"expiry_interval,omitempty"`
	DataIdAliases        map[uint32]*DataID                               `` /* 191-byte string literal not displayed */
	Qos                  QoS                                              `protobuf:"varint,6,opt,name=qos,proto3,enum=iscp2.v1.QoS" json:"qos,omitempty"`
	ExtensionFields      *extensions.DownstreamOpenRequestExtensionFields `protobuf:"bytes,7,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	OmitEmptyChunk       bool                                             `protobuf:"varint,8,opt,name=omit_empty_chunk,json=omitEmptyChunk,proto3" json:"omit_empty_chunk,omitempty"`
	// contains filtered or unexported fields
}

func (*DownstreamOpenRequest) Descriptor deprecated 

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

Deprecated: Use DownstreamOpenRequest.ProtoReflect.Descriptor instead.

func (*DownstreamOpenRequest) GetDataIdAliases 

func (x *DownstreamOpenRequest) GetDataIdAliases() map[uint32]*DataID

func (*DownstreamOpenRequest) GetDesiredStreamIdAlias 

func (x *DownstreamOpenRequest) GetDesiredStreamIdAlias() uint32

func (*DownstreamOpenRequest) GetDownstreamFilters 

func (x *DownstreamOpenRequest) GetDownstreamFilters() []*DownstreamFilter

func (*DownstreamOpenRequest) GetExpiryInterval 

func (x *DownstreamOpenRequest) GetExpiryInterval() uint32

func (*DownstreamOpenRequest) GetExtensionFields 

func (x *DownstreamOpenRequest) GetExtensionFields() *extensions.DownstreamOpenRequestExtensionFields

func (*DownstreamOpenRequest) GetOmitEmptyChunk 

func (x *DownstreamOpenRequest) GetOmitEmptyChunk() bool

func (*DownstreamOpenRequest) GetQos 

func (x *DownstreamOpenRequest) GetQos() QoS

func (*DownstreamOpenRequest) GetRequestId 

func (x *DownstreamOpenRequest) GetRequestId() uint32

func (*DownstreamOpenRequest) ProtoMessage 

func (*DownstreamOpenRequest) ProtoMessage()

func (*DownstreamOpenRequest) ProtoReflect 

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

func (*DownstreamOpenRequest) Reset 

func (x *DownstreamOpenRequest) Reset()

func (*DownstreamOpenRequest) String 

func (x *DownstreamOpenRequest) String() string

type DownstreamOpenResponse 

type DownstreamOpenResponse struct {
	RequestId        uint32                                            `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	AssignedStreamId []byte                                            `protobuf:"bytes,2,opt,name=assigned_stream_id,json=assignedStreamId,proto3" json:"assigned_stream_id,omitempty"`
	ServerTime       int64                                             `protobuf:"zigzag64,3,opt,name=server_time,json=serverTime,proto3" json:"server_time,omitempty"`
	ResultCode       ResultCode                                        `protobuf:"varint,4,opt,name=result_code,json=resultCode,proto3,enum=iscp2.v1.ResultCode" json:"result_code,omitempty"`
	ResultString     string                                            `protobuf:"bytes,5,opt,name=result_string,json=resultString,proto3" json:"result_string,omitempty"`
	ExtensionFields  *extensions.DownstreamOpenResponseExtensionFields `protobuf:"bytes,6,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*DownstreamOpenResponse) Descriptor deprecated 

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

Deprecated: Use DownstreamOpenResponse.ProtoReflect.Descriptor instead.

func (*DownstreamOpenResponse) GetAssignedStreamId 

func (x *DownstreamOpenResponse) GetAssignedStreamId() []byte

func (*DownstreamOpenResponse) GetExtensionFields 

func (x *DownstreamOpenResponse) GetExtensionFields() *extensions.DownstreamOpenResponseExtensionFields

func (*DownstreamOpenResponse) GetRequestId 

func (x *DownstreamOpenResponse) GetRequestId() uint32

func (*DownstreamOpenResponse) GetResultCode 

func (x *DownstreamOpenResponse) GetResultCode() ResultCode

func (*DownstreamOpenResponse) GetResultString 

func (x *DownstreamOpenResponse) GetResultString() string

func (*DownstreamOpenResponse) GetServerTime 

func (x *DownstreamOpenResponse) GetServerTime() int64

func (*DownstreamOpenResponse) ProtoMessage 

func (*DownstreamOpenResponse) ProtoMessage()

func (*DownstreamOpenResponse) ProtoReflect 

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

func (*DownstreamOpenResponse) Reset 

func (x *DownstreamOpenResponse) Reset()

func (*DownstreamOpenResponse) String 

func (x *DownstreamOpenResponse) String() string

type DownstreamResume 

type DownstreamResume struct {
	StreamId          []byte              `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	DownstreamFilters []*DownstreamFilter `protobuf:"bytes,2,rep,name=downstream_filters,json=downstreamFilters,proto3" json:"downstream_filters,omitempty"`
	Qos               QoS                 `protobuf:"varint,3,opt,name=qos,proto3,enum=iscp2.v1.QoS" json:"qos,omitempty"`
	// contains filtered or unexported fields
}

func (*DownstreamResume) Descriptor deprecated 

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

Deprecated: Use DownstreamResume.ProtoReflect.Descriptor instead.

func (*DownstreamResume) GetDownstreamFilters 

func (x *DownstreamResume) GetDownstreamFilters() []*DownstreamFilter

func (*DownstreamResume) GetQos 

func (x *DownstreamResume) GetQos() QoS

func (*DownstreamResume) GetStreamId 

func (x *DownstreamResume) GetStreamId() []byte

func (*DownstreamResume) ProtoMessage 

func (*DownstreamResume) ProtoMessage()

func (*DownstreamResume) ProtoReflect 

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

func (*DownstreamResume) Reset 

func (x *DownstreamResume) Reset()

func (*DownstreamResume) String 

func (x *DownstreamResume) String() string

type DownstreamResumeRequest 

type DownstreamResumeRequest struct {
	RequestId            uint32                                             `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	StreamId             []byte                                             `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	DesiredStreamIdAlias uint32                                             `` /* 126-byte string literal not displayed */
	ExtensionFields      *extensions.DownstreamResumeRequestExtensionFields `protobuf:"bytes,4,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*DownstreamResumeRequest) Descriptor deprecated 

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

Deprecated: Use DownstreamResumeRequest.ProtoReflect.Descriptor instead.

func (*DownstreamResumeRequest) GetDesiredStreamIdAlias 

func (x *DownstreamResumeRequest) GetDesiredStreamIdAlias() uint32

func (*DownstreamResumeRequest) GetExtensionFields 

func (x *DownstreamResumeRequest) GetExtensionFields() *extensions.DownstreamResumeRequestExtensionFields

func (*DownstreamResumeRequest) GetRequestId 

func (x *DownstreamResumeRequest) GetRequestId() uint32

func (*DownstreamResumeRequest) GetStreamId 

func (x *DownstreamResumeRequest) GetStreamId() []byte

func (*DownstreamResumeRequest) ProtoMessage 

func (*DownstreamResumeRequest) ProtoMessage()

func (*DownstreamResumeRequest) ProtoReflect 

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

func (*DownstreamResumeRequest) Reset 

func (x *DownstreamResumeRequest) Reset()

func (*DownstreamResumeRequest) String 

func (x *DownstreamResumeRequest) String() string

type DownstreamResumeResponse 

type DownstreamResumeResponse struct {
	RequestId       uint32                                              `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	ResultCode      ResultCode                                          `protobuf:"varint,2,opt,name=result_code,json=resultCode,proto3,enum=iscp2.v1.ResultCode" json:"result_code,omitempty"`
	ResultString    string                                              `protobuf:"bytes,3,opt,name=result_string,json=resultString,proto3" json:"result_string,omitempty"`
	ExtensionFields *extensions.DownstreamResumeResponseExtensionFields `protobuf:"bytes,4,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*DownstreamResumeResponse) Descriptor deprecated 

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

Deprecated: Use DownstreamResumeResponse.ProtoReflect.Descriptor instead.

func (*DownstreamResumeResponse) GetExtensionFields 

func (x *DownstreamResumeResponse) GetExtensionFields() *extensions.DownstreamResumeResponseExtensionFields

func (*DownstreamResumeResponse) GetRequestId 

func (x *DownstreamResumeResponse) GetRequestId() uint32

func (*DownstreamResumeResponse) GetResultCode 

func (x *DownstreamResumeResponse) GetResultCode() ResultCode

func (*DownstreamResumeResponse) GetResultString 

func (x *DownstreamResumeResponse) GetResultString() string

func (*DownstreamResumeResponse) ProtoMessage 

func (*DownstreamResumeResponse) ProtoMessage()

func (*DownstreamResumeResponse) ProtoReflect 

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

func (*DownstreamResumeResponse) Reset 

func (x *DownstreamResumeResponse) Reset()

func (*DownstreamResumeResponse) String 

func (x *DownstreamResumeResponse) String() string

type Message 

type Message struct {

	// Types that are assignable to Message:
	//
	//	*Message_ConnectRequest
	//	*Message_ConnectResponse
	//	*Message_Disconnect
	//	*Message_UpstreamOpenRequest
	//	*Message_UpstreamOpenResponse
	//	*Message_UpstreamResumeRequest
	//	*Message_UpstreamResumeResponse
	//	*Message_UpstreamCloseRequest
	//	*Message_UpstreamCloseResponse
	//	*Message_UpstreamChunk
	//	*Message_UpstreamChunkAck
	//	*Message_UpstreamMetadata
	//	*Message_UpstreamMetadataAck
	//	*Message_DownstreamOpenRequest
	//	*Message_DownstreamOpenResponse
	//	*Message_DownstreamResumeRequest
	//	*Message_DownstreamResumeResponse
	//	*Message_DownstreamCloseRequest
	//	*Message_DownstreamCloseResponse
	//	*Message_DownstreamChunk
	//	*Message_DownstreamChunkAck
	//	*Message_DownstreamChunkAckComplete
	//	*Message_DownstreamMetadata
	//	*Message_DownstreamMetadataAck
	//	*Message_Ping
	//	*Message_Pong
	//	*Message_UpstreamCall
	//	*Message_UpstreamCallAck
	//	*Message_DownstreamCall
	Message isMessage_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor deprecated 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetConnectRequest 

func (x *Message) GetConnectRequest() *ConnectRequest

func (*Message) GetConnectResponse 

func (x *Message) GetConnectResponse() *ConnectResponse

func (*Message) GetDisconnect 

func (x *Message) GetDisconnect() *Disconnect

func (*Message) GetDownstreamCall 

func (x *Message) GetDownstreamCall() *DownstreamCall

func (*Message) GetDownstreamChunk 

func (x *Message) GetDownstreamChunk() *DownstreamChunk

func (*Message) GetDownstreamChunkAck 

func (x *Message) GetDownstreamChunkAck() *DownstreamChunkAck

func (*Message) GetDownstreamChunkAckComplete 

func (x *Message) GetDownstreamChunkAckComplete() *DownstreamChunkAckComplete

func (*Message) GetDownstreamCloseRequest 

func (x *Message) GetDownstreamCloseRequest() *DownstreamCloseRequest

func (*Message) GetDownstreamCloseResponse 

func (x *Message) GetDownstreamCloseResponse() *DownstreamCloseResponse

func (*Message) GetDownstreamMetadata 

func (x *Message) GetDownstreamMetadata() *DownstreamMetadata

func (*Message) GetDownstreamMetadataAck 

func (x *Message) GetDownstreamMetadataAck() *DownstreamMetadataAck

func (*Message) GetDownstreamOpenRequest 

func (x *Message) GetDownstreamOpenRequest() *DownstreamOpenRequest

func (*Message) GetDownstreamOpenResponse 

func (x *Message) GetDownstreamOpenResponse() *DownstreamOpenResponse

func (*Message) GetDownstreamResumeRequest 

func (x *Message) GetDownstreamResumeRequest() *DownstreamResumeRequest

func (*Message) GetDownstreamResumeResponse 

func (x *Message) GetDownstreamResumeResponse() *DownstreamResumeResponse

func (*Message) GetMessage 

func (m *Message) GetMessage() isMessage_Message

func (*Message) GetPing 

func (x *Message) GetPing() *Ping

func (*Message) GetPong 

func (x *Message) GetPong() *Pong

func (*Message) GetUpstreamCall 

func (x *Message) GetUpstreamCall() *UpstreamCall

func (*Message) GetUpstreamCallAck 

func (x *Message) GetUpstreamCallAck() *UpstreamCallAck

func (*Message) GetUpstreamChunk 

func (x *Message) GetUpstreamChunk() *UpstreamChunk

func (*Message) GetUpstreamChunkAck 

func (x *Message) GetUpstreamChunkAck() *UpstreamChunkAck

func (*Message) GetUpstreamCloseRequest 

func (x *Message) GetUpstreamCloseRequest() *UpstreamCloseRequest

func (*Message) GetUpstreamCloseResponse 

func (x *Message) GetUpstreamCloseResponse() *UpstreamCloseResponse

func (*Message) GetUpstreamMetadata 

func (x *Message) GetUpstreamMetadata() *UpstreamMetadata

func (*Message) GetUpstreamMetadataAck 

func (x *Message) GetUpstreamMetadataAck() *UpstreamMetadataAck

func (*Message) GetUpstreamOpenRequest 

func (x *Message) GetUpstreamOpenRequest() *UpstreamOpenRequest

func (*Message) GetUpstreamOpenResponse 

func (x *Message) GetUpstreamOpenResponse() *UpstreamOpenResponse

func (*Message) GetUpstreamResumeRequest 

func (x *Message) GetUpstreamResumeRequest() *UpstreamResumeRequest

func (*Message) GetUpstreamResumeResponse 

func (x *Message) GetUpstreamResumeResponse() *UpstreamResumeResponse

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 Message_ConnectRequest 

type Message_ConnectRequest struct {
	// Connect
	ConnectRequest *ConnectRequest `protobuf:"bytes,1,opt,name=connect_request,json=connectRequest,proto3,oneof"`
}

type Message_ConnectResponse 

type Message_ConnectResponse struct {
	ConnectResponse *ConnectResponse `protobuf:"bytes,2,opt,name=connect_response,json=connectResponse,proto3,oneof"`
}

type Message_Disconnect 

type Message_Disconnect struct {
	Disconnect *Disconnect `protobuf:"bytes,3,opt,name=disconnect,proto3,oneof"`
}

type Message_DownstreamCall 

type Message_DownstreamCall struct {
	DownstreamCall *DownstreamCall `protobuf:"bytes,258,opt,name=downstream_call,json=downstreamCall,proto3,oneof"`
}

type Message_DownstreamChunk 

type Message_DownstreamChunk struct {
	DownstreamChunk *DownstreamChunk `protobuf:"bytes,134,opt,name=downstream_chunk,json=downstreamChunk,proto3,oneof"`
}

type Message_DownstreamChunkAck 

type Message_DownstreamChunkAck struct {
	DownstreamChunkAck *DownstreamChunkAck `protobuf:"bytes,135,opt,name=downstream_chunk_ack,json=downstreamChunkAck,proto3,oneof"`
}

type Message_DownstreamChunkAckComplete 

type Message_DownstreamChunkAckComplete struct {
	DownstreamChunkAckComplete *DownstreamChunkAckComplete `protobuf:"bytes,136,opt,name=downstream_chunk_ack_complete,json=downstreamChunkAckComplete,proto3,oneof"`
}

type Message_DownstreamCloseRequest 

type Message_DownstreamCloseRequest struct {
	DownstreamCloseRequest *DownstreamCloseRequest `protobuf:"bytes,132,opt,name=downstream_close_request,json=downstreamCloseRequest,proto3,oneof"`
}

type Message_DownstreamCloseResponse 

type Message_DownstreamCloseResponse struct {
	DownstreamCloseResponse *DownstreamCloseResponse `protobuf:"bytes,133,opt,name=downstream_close_response,json=downstreamCloseResponse,proto3,oneof"`
}

type Message_DownstreamMetadata 

type Message_DownstreamMetadata struct {
	DownstreamMetadata *DownstreamMetadata `protobuf:"bytes,137,opt,name=downstream_metadata,json=downstreamMetadata,proto3,oneof"`
}

type Message_DownstreamMetadataAck 

type Message_DownstreamMetadataAck struct {
	DownstreamMetadataAck *DownstreamMetadataAck `protobuf:"bytes,138,opt,name=downstream_metadata_ack,json=downstreamMetadataAck,proto3,oneof"`
}

type Message_DownstreamOpenRequest 

type Message_DownstreamOpenRequest struct {
	// Downstream
	DownstreamOpenRequest *DownstreamOpenRequest `protobuf:"bytes,128,opt,name=downstream_open_request,json=downstreamOpenRequest,proto3,oneof"`
}

type Message_DownstreamOpenResponse 

type Message_DownstreamOpenResponse struct {
	DownstreamOpenResponse *DownstreamOpenResponse `protobuf:"bytes,129,opt,name=downstream_open_response,json=downstreamOpenResponse,proto3,oneof"`
}

type Message_DownstreamResumeRequest 

type Message_DownstreamResumeRequest struct {
	DownstreamResumeRequest *DownstreamResumeRequest `protobuf:"bytes,130,opt,name=downstream_resume_request,json=downstreamResumeRequest,proto3,oneof"`
}

type Message_DownstreamResumeResponse 

type Message_DownstreamResumeResponse struct {
	DownstreamResumeResponse *DownstreamResumeResponse `protobuf:"bytes,131,opt,name=downstream_resume_response,json=downstreamResumeResponse,proto3,oneof"`
}

type Message_Ping 

type Message_Ping struct {
	// Ping/Pong
	Ping *Ping `protobuf:"bytes,192,opt,name=ping,proto3,oneof"`
}

type Message_Pong 

type Message_Pong struct {
	Pong *Pong `protobuf:"bytes,193,opt,name=pong,proto3,oneof"`
}

type Message_UpstreamCall 

type Message_UpstreamCall struct {
	// E2E Call
	UpstreamCall *UpstreamCall `protobuf:"bytes,256,opt,name=upstream_call,json=upstreamCall,proto3,oneof"`
}

type Message_UpstreamCallAck 

type Message_UpstreamCallAck struct {
	UpstreamCallAck *UpstreamCallAck `protobuf:"bytes,257,opt,name=upstream_call_ack,json=upstreamCallAck,proto3,oneof"`
}

type Message_UpstreamChunk 

type Message_UpstreamChunk struct {
	UpstreamChunk *UpstreamChunk `protobuf:"bytes,70,opt,name=upstream_chunk,json=upstreamChunk,proto3,oneof"`
}

type Message_UpstreamChunkAck 

type Message_UpstreamChunkAck struct {
	UpstreamChunkAck *UpstreamChunkAck `protobuf:"bytes,71,opt,name=upstream_chunk_ack,json=upstreamChunkAck,proto3,oneof"`
}

type Message_UpstreamCloseRequest 

type Message_UpstreamCloseRequest struct {
	UpstreamCloseRequest *UpstreamCloseRequest `protobuf:"bytes,68,opt,name=upstream_close_request,json=upstreamCloseRequest,proto3,oneof"`
}

type Message_UpstreamCloseResponse 

type Message_UpstreamCloseResponse struct {
	UpstreamCloseResponse *UpstreamCloseResponse `protobuf:"bytes,69,opt,name=upstream_close_response,json=upstreamCloseResponse,proto3,oneof"`
}

type Message_UpstreamMetadata 

type Message_UpstreamMetadata struct {
	UpstreamMetadata *UpstreamMetadata `protobuf:"bytes,72,opt,name=upstream_metadata,json=upstreamMetadata,proto3,oneof"`
}

type Message_UpstreamMetadataAck 

type Message_UpstreamMetadataAck struct {
	UpstreamMetadataAck *UpstreamMetadataAck `protobuf:"bytes,73,opt,name=upstream_metadata_ack,json=upstreamMetadataAck,proto3,oneof"`
}

type Message_UpstreamOpenRequest 

type Message_UpstreamOpenRequest struct {
	// Upstream
	UpstreamOpenRequest *UpstreamOpenRequest `protobuf:"bytes,64,opt,name=upstream_open_request,json=upstreamOpenRequest,proto3,oneof"`
}

type Message_UpstreamOpenResponse 

type Message_UpstreamOpenResponse struct {
	UpstreamOpenResponse *UpstreamOpenResponse `protobuf:"bytes,65,opt,name=upstream_open_response,json=upstreamOpenResponse,proto3,oneof"`
}

type Message_UpstreamResumeRequest 

type Message_UpstreamResumeRequest struct {
	UpstreamResumeRequest *UpstreamResumeRequest `protobuf:"bytes,66,opt,name=upstream_resume_request,json=upstreamResumeRequest,proto3,oneof"`
}

type Message_UpstreamResumeResponse 

type Message_UpstreamResumeResponse struct {
	UpstreamResumeResponse *UpstreamResumeResponse `protobuf:"bytes,67,opt,name=upstream_resume_response,json=upstreamResumeResponse,proto3,oneof"`
}

type Ping 

type Ping struct {
	RequestId       uint32                          `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	ExtensionFields *extensions.PingExtensionFields `protobuf:"bytes,2,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*Ping) Descriptor deprecated 

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

Deprecated: Use Ping.ProtoReflect.Descriptor instead.

func (*Ping) GetExtensionFields 

func (x *Ping) GetExtensionFields() *extensions.PingExtensionFields

func (*Ping) GetRequestId 

func (x *Ping) GetRequestId() uint32

func (*Ping) ProtoMessage 

func (*Ping) ProtoMessage()

func (*Ping) ProtoReflect 

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

func (*Ping) Reset 

func (x *Ping) Reset()

func (*Ping) String 

func (x *Ping) String() string

type Pong 

type Pong struct {
	RequestId       uint32                          `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	ExtensionFields *extensions.PongExtensionFields `protobuf:"bytes,2,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*Pong) Descriptor deprecated 

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

Deprecated: Use Pong.ProtoReflect.Descriptor instead.

func (*Pong) GetExtensionFields 

func (x *Pong) GetExtensionFields() *extensions.PongExtensionFields

func (*Pong) GetRequestId 

func (x *Pong) GetRequestId() uint32

func (*Pong) ProtoMessage 

func (*Pong) ProtoMessage()

func (*Pong) ProtoReflect 

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

func (*Pong) Reset 

func (x *Pong) Reset()

func (*Pong) String 

func (x *Pong) String() string

type QoS 

type QoS int32
const (
	QoS_UNRELIABLE QoS = 0
	QoS_RELIABLE   QoS = 1
	QoS_PARTIAL    QoS = 2
)

func (QoS) Descriptor 

func (QoS) Descriptor() protoreflect.EnumDescriptor

func (QoS) Enum 

func (x QoS) Enum() *QoS

func (QoS) EnumDescriptor deprecated 

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

Deprecated: Use QoS.Descriptor instead.

func (QoS) Number 

func (x QoS) Number() protoreflect.EnumNumber

func (QoS) String 

func (x QoS) String() string

func (QoS) Type 

func (QoS) Type() protoreflect.EnumType

type ResultCode 

type ResultCode int32
const (
	ResultCode_SUCCEEDED                   ResultCode = 0
	ResultCode_NORMAL_CLOSURE              ResultCode = 0
	ResultCode_INCOMPATIBLE_VERSION        ResultCode = 1
	ResultCode_MAXIMUM_DATA_ID_ALIAS       ResultCode = 2
	ResultCode_MAXIMUM_UPSTREAM_ALIAS      ResultCode = 3
	ResultCode_UNSPECIFIED_ERROR           ResultCode = 64
	ResultCode_NO_NODE_ID                  ResultCode = 65
	ResultCode_AUTH_FAILED                 ResultCode = 66
	ResultCode_CONNECT_TIMEOUT             ResultCode = 67
	ResultCode_MALFORMED_MESSAGE           ResultCode = 68
	ResultCode_PROTOCOL_ERROR              ResultCode = 69
	ResultCode_ACK_TIMEOUT                 ResultCode = 70
	ResultCode_INVALID_PAYLOAD             ResultCode = 71
	ResultCode_INVALID_DATA_ID             ResultCode = 72
	ResultCode_INVALID_DATA_ID_ALIAS       ResultCode = 73
	ResultCode_INVALID_DATA_FILTER         ResultCode = 74
	ResultCode_STREAM_NOT_FOUND            ResultCode = 75
	ResultCode_RESUME_REQUEST_CONFLICT     ResultCode = 76
	ResultCode_PROCESS_FAILED              ResultCode = 77
	ResultCode_DESIRED_QOS_NOT_SUPPORTED   ResultCode = 78
	ResultCode_PING_TIMEOUT                ResultCode = 79
	ResultCode_TOO_LARGE_MESSAGE_SIZE      ResultCode = 80
	ResultCode_TOO_MANY_DATA_ID_ALIASES    ResultCode = 81
	ResultCode_TOO_MANY_STREAMS            ResultCode = 82
	ResultCode_TOO_LONG_ACK_INTERVAL       ResultCode = 83
	ResultCode_TOO_MANY_DOWNSTREAM_FILTERS ResultCode = 84
	ResultCode_TOO_MANY_DATA_FILTERS       ResultCode = 85
	ResultCode_TOO_LONG_EXPIRY_INTERVAL    ResultCode = 86
	ResultCode_TOO_LONG_PING_TIMEOUT       ResultCode = 87
	ResultCode_TOO_SHORT_PING_INTERVAL     ResultCode = 88
	ResultCode_TOO_SHORT_PING_TIMEOUT      ResultCode = 89
	ResultCode_RATE_LIMIT_REACHED          ResultCode = 90
	ResultCode_NODE_ID_MISMATCH            ResultCode = 128
	ResultCode_SESSION_NOT_FOUND           ResultCode = 129
	ResultCode_SESSION_ALREADY_CLOSED      ResultCode = 130
	ResultCode_SESSION_CANNOT_CLOSED       ResultCode = 131
)

func (ResultCode) Descriptor 

func (ResultCode) Descriptor() protoreflect.EnumDescriptor

func (ResultCode) Enum 

func (x ResultCode) Enum() *ResultCode

func (ResultCode) EnumDescriptor deprecated 

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

Deprecated: Use ResultCode.Descriptor instead.

func (ResultCode) Number 

func (x ResultCode) Number() protoreflect.EnumNumber

func (ResultCode) String 

func (x ResultCode) String() string

func (ResultCode) Type 

func (ResultCode) Type() protoreflect.EnumType

type StreamChunk 

type StreamChunk struct {
	SequenceNumber  uint32            `protobuf:"varint,1,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number,omitempty"`
	DataPointGroups []*DataPointGroup `protobuf:"bytes,2,rep,name=data_point_groups,json=dataPointGroups,proto3" json:"data_point_groups,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamChunk) Descriptor deprecated 

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

Deprecated: Use StreamChunk.ProtoReflect.Descriptor instead.

func (*StreamChunk) GetDataPointGroups 

func (x *StreamChunk) GetDataPointGroups() []*DataPointGroup

func (*StreamChunk) GetSequenceNumber 

func (x *StreamChunk) GetSequenceNumber() uint32

func (*StreamChunk) ProtoMessage 

func (*StreamChunk) ProtoMessage()

func (*StreamChunk) ProtoReflect 

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

func (*StreamChunk) Reset 

func (x *StreamChunk) Reset()

func (*StreamChunk) String 

func (x *StreamChunk) String() string

type UpstreamAbnormalClose 

type UpstreamAbnormalClose struct {
	StreamId  []byte `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	SessionId string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UpstreamAbnormalClose) Descriptor deprecated 

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

Deprecated: Use UpstreamAbnormalClose.ProtoReflect.Descriptor instead.

func (*UpstreamAbnormalClose) GetSessionId 

func (x *UpstreamAbnormalClose) GetSessionId() string

func (*UpstreamAbnormalClose) GetStreamId 

func (x *UpstreamAbnormalClose) GetStreamId() []byte

func (*UpstreamAbnormalClose) ProtoMessage 

func (*UpstreamAbnormalClose) ProtoMessage()

func (*UpstreamAbnormalClose) ProtoReflect 

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

func (*UpstreamAbnormalClose) Reset 

func (x *UpstreamAbnormalClose) Reset()

func (*UpstreamAbnormalClose) String 

func (x *UpstreamAbnormalClose) String() string

type UpstreamCall 

type UpstreamCall struct {
	CallId            string                                  `protobuf:"bytes,1,opt,name=call_id,json=callId,proto3" json:"call_id,omitempty"`
	RequestCallId     string                                  `protobuf:"bytes,2,opt,name=request_call_id,json=requestCallId,proto3" json:"request_call_id,omitempty"`
	DestinationNodeId string                                  `protobuf:"bytes,3,opt,name=destination_node_id,json=destinationNodeId,proto3" json:"destination_node_id,omitempty"`
	Name              string                                  `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Type              string                                  `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"`
	Payload           []byte                                  `protobuf:"bytes,6,opt,name=payload,proto3" json:"payload,omitempty"`
	ExtensionFields   *extensions.UpstreamCallExtensionFields `protobuf:"bytes,7,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*UpstreamCall) Descriptor deprecated 

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

Deprecated: Use UpstreamCall.ProtoReflect.Descriptor instead.

func (*UpstreamCall) GetCallId 

func (x *UpstreamCall) GetCallId() string

func (*UpstreamCall) GetDestinationNodeId 

func (x *UpstreamCall) GetDestinationNodeId() string

func (*UpstreamCall) GetExtensionFields 

func (x *UpstreamCall) GetExtensionFields() *extensions.UpstreamCallExtensionFields

func (*UpstreamCall) GetName 

func (x *UpstreamCall) GetName() string

func (*UpstreamCall) GetPayload 

func (x *UpstreamCall) GetPayload() []byte

func (*UpstreamCall) GetRequestCallId 

func (x *UpstreamCall) GetRequestCallId() string

func (*UpstreamCall) GetType 

func (x *UpstreamCall) GetType() string

func (*UpstreamCall) ProtoMessage 

func (*UpstreamCall) ProtoMessage()

func (*UpstreamCall) ProtoReflect 

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

func (*UpstreamCall) Reset 

func (x *UpstreamCall) Reset()

func (*UpstreamCall) String 

func (x *UpstreamCall) String() string

type UpstreamCallAck 

type UpstreamCallAck struct {
	CallId          string                                     `protobuf:"bytes,1,opt,name=call_id,json=callId,proto3" json:"call_id,omitempty"`
	ResultCode      ResultCode                                 `protobuf:"varint,2,opt,name=result_code,json=resultCode,proto3,enum=iscp2.v1.ResultCode" json:"result_code,omitempty"`
	ResultString    string                                     `protobuf:"bytes,3,opt,name=result_string,json=resultString,proto3" json:"result_string,omitempty"`
	ExtensionFields *extensions.UpstreamCallAckExtensionFields `protobuf:"bytes,4,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*UpstreamCallAck) Descriptor deprecated 

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

Deprecated: Use UpstreamCallAck.ProtoReflect.Descriptor instead.

func (*UpstreamCallAck) GetCallId 

func (x *UpstreamCallAck) GetCallId() string

func (*UpstreamCallAck) GetExtensionFields 

func (x *UpstreamCallAck) GetExtensionFields() *extensions.UpstreamCallAckExtensionFields

func (*UpstreamCallAck) GetResultCode 

func (x *UpstreamCallAck) GetResultCode() ResultCode

func (*UpstreamCallAck) GetResultString 

func (x *UpstreamCallAck) GetResultString() string

func (*UpstreamCallAck) ProtoMessage 

func (*UpstreamCallAck) ProtoMessage()

func (*UpstreamCallAck) ProtoReflect 

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

func (*UpstreamCallAck) Reset 

func (x *UpstreamCallAck) Reset()

func (*UpstreamCallAck) String 

func (x *UpstreamCallAck) String() string

type UpstreamChunk 

type UpstreamChunk struct {
	StreamIdAlias   uint32                                   `protobuf:"varint,1,opt,name=stream_id_alias,json=streamIdAlias,proto3" json:"stream_id_alias,omitempty"`
	StreamChunk     *StreamChunk                             `protobuf:"bytes,2,opt,name=stream_chunk,json=streamChunk,proto3" json:"stream_chunk,omitempty"`
	DataIds         []*DataID                                `protobuf:"bytes,3,rep,name=data_ids,json=dataIds,proto3" json:"data_ids,omitempty"`
	ExtensionFields *extensions.UpstreamChunkExtensionFields `protobuf:"bytes,4,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*UpstreamChunk) Descriptor deprecated 

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

Deprecated: Use UpstreamChunk.ProtoReflect.Descriptor instead.

func (*UpstreamChunk) GetDataIds 

func (x *UpstreamChunk) GetDataIds() []*DataID

func (*UpstreamChunk) GetExtensionFields 

func (x *UpstreamChunk) GetExtensionFields() *extensions.UpstreamChunkExtensionFields

func (*UpstreamChunk) GetStreamChunk 

func (x *UpstreamChunk) GetStreamChunk() *StreamChunk

func (*UpstreamChunk) GetStreamIdAlias 

func (x *UpstreamChunk) GetStreamIdAlias() uint32

func (*UpstreamChunk) ProtoMessage 

func (*UpstreamChunk) ProtoMessage()

func (*UpstreamChunk) ProtoReflect 

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

func (*UpstreamChunk) Reset 

func (x *UpstreamChunk) Reset()

func (*UpstreamChunk) String 

func (x *UpstreamChunk) String() string

type UpstreamChunkAck 

type UpstreamChunkAck struct {
	StreamIdAlias   uint32                                      `protobuf:"varint,1,opt,name=stream_id_alias,json=streamIdAlias,proto3" json:"stream_id_alias,omitempty"`
	Results         []*UpstreamChunkResult                      `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"`
	DataIdAliases   map[uint32]*DataID                          `` /* 191-byte string literal not displayed */
	ExtensionFields *extensions.UpstreamChunkAckExtensionFields `protobuf:"bytes,4,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*UpstreamChunkAck) Descriptor deprecated 

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

Deprecated: Use UpstreamChunkAck.ProtoReflect.Descriptor instead.

func (*UpstreamChunkAck) GetDataIdAliases 

func (x *UpstreamChunkAck) GetDataIdAliases() map[uint32]*DataID

func (*UpstreamChunkAck) GetExtensionFields 

func (x *UpstreamChunkAck) GetExtensionFields() *extensions.UpstreamChunkAckExtensionFields

func (*UpstreamChunkAck) GetResults 

func (x *UpstreamChunkAck) GetResults() []*UpstreamChunkResult

func (*UpstreamChunkAck) GetStreamIdAlias 

func (x *UpstreamChunkAck) GetStreamIdAlias() uint32

func (*UpstreamChunkAck) ProtoMessage 

func (*UpstreamChunkAck) ProtoMessage()

func (*UpstreamChunkAck) ProtoReflect 

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

func (*UpstreamChunkAck) Reset 

func (x *UpstreamChunkAck) Reset()

func (*UpstreamChunkAck) String 

func (x *UpstreamChunkAck) String() string

type UpstreamChunkResult 

type UpstreamChunkResult struct {
	SequenceNumber  uint32                                         `protobuf:"varint,1,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number,omitempty"`
	ResultCode      ResultCode                                     `protobuf:"varint,2,opt,name=result_code,json=resultCode,proto3,enum=iscp2.v1.ResultCode" json:"result_code,omitempty"`
	ResultString    string                                         `protobuf:"bytes,3,opt,name=result_string,json=resultString,proto3" json:"result_string,omitempty"`
	ExtensionFields *extensions.UpstreamChunkResultExtensionFields `protobuf:"bytes,4,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*UpstreamChunkResult) Descriptor deprecated 

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

Deprecated: Use UpstreamChunkResult.ProtoReflect.Descriptor instead.

func (*UpstreamChunkResult) GetExtensionFields 

func (x *UpstreamChunkResult) GetExtensionFields() *extensions.UpstreamChunkResultExtensionFields

func (*UpstreamChunkResult) GetResultCode 

func (x *UpstreamChunkResult) GetResultCode() ResultCode

func (*UpstreamChunkResult) GetResultString 

func (x *UpstreamChunkResult) GetResultString() string

func (*UpstreamChunkResult) GetSequenceNumber 

func (x *UpstreamChunkResult) GetSequenceNumber() uint32

func (*UpstreamChunkResult) ProtoMessage 

func (*UpstreamChunkResult) ProtoMessage()

func (*UpstreamChunkResult) ProtoReflect 

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

func (*UpstreamChunkResult) Reset 

func (x *UpstreamChunkResult) Reset()

func (*UpstreamChunkResult) String 

func (x *UpstreamChunkResult) String() string

type UpstreamCloseRequest 

type UpstreamCloseRequest struct {
	RequestId           uint32                                          `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	StreamId            []byte                                          `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	TotalDataPoints     uint64                                          `protobuf:"varint,3,opt,name=total_data_points,json=totalDataPoints,proto3" json:"total_data_points,omitempty"`
	FinalSequenceNumber uint32                                          `protobuf:"varint,4,opt,name=final_sequence_number,json=finalSequenceNumber,proto3" json:"final_sequence_number,omitempty"`
	ExtensionFields     *extensions.UpstreamCloseRequestExtensionFields `protobuf:"bytes,5,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*UpstreamCloseRequest) Descriptor deprecated 

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

Deprecated: Use UpstreamCloseRequest.ProtoReflect.Descriptor instead.

func (*UpstreamCloseRequest) GetExtensionFields 

func (x *UpstreamCloseRequest) GetExtensionFields() *extensions.UpstreamCloseRequestExtensionFields

func (*UpstreamCloseRequest) GetFinalSequenceNumber 

func (x *UpstreamCloseRequest) GetFinalSequenceNumber() uint32

func (*UpstreamCloseRequest) GetRequestId 

func (x *UpstreamCloseRequest) GetRequestId() uint32

func (*UpstreamCloseRequest) GetStreamId 

func (x *UpstreamCloseRequest) GetStreamId() []byte

func (*UpstreamCloseRequest) GetTotalDataPoints 

func (x *UpstreamCloseRequest) GetTotalDataPoints() uint64

func (*UpstreamCloseRequest) ProtoMessage 

func (*UpstreamCloseRequest) ProtoMessage()

func (*UpstreamCloseRequest) ProtoReflect 

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

func (*UpstreamCloseRequest) Reset 

func (x *UpstreamCloseRequest) Reset()

func (*UpstreamCloseRequest) String 

func (x *UpstreamCloseRequest) String() string

type UpstreamCloseResponse 

type UpstreamCloseResponse struct {
	RequestId       uint32                                           `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	ResultCode      ResultCode                                       `protobuf:"varint,2,opt,name=result_code,json=resultCode,proto3,enum=iscp2.v1.ResultCode" json:"result_code,omitempty"`
	ResultString    string                                           `protobuf:"bytes,3,opt,name=result_string,json=resultString,proto3" json:"result_string,omitempty"`
	ExtensionFields *extensions.UpstreamCloseResponseExtensionFields `protobuf:"bytes,4,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*UpstreamCloseResponse) Descriptor deprecated 

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

Deprecated: Use UpstreamCloseResponse.ProtoReflect.Descriptor instead.

func (*UpstreamCloseResponse) GetExtensionFields 

func (x *UpstreamCloseResponse) GetExtensionFields() *extensions.UpstreamCloseResponseExtensionFields

func (*UpstreamCloseResponse) GetRequestId 

func (x *UpstreamCloseResponse) GetRequestId() uint32

func (*UpstreamCloseResponse) GetResultCode 

func (x *UpstreamCloseResponse) GetResultCode() ResultCode

func (*UpstreamCloseResponse) GetResultString 

func (x *UpstreamCloseResponse) GetResultString() string

func (*UpstreamCloseResponse) ProtoMessage 

func (*UpstreamCloseResponse) ProtoMessage()

func (*UpstreamCloseResponse) ProtoReflect 

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

func (*UpstreamCloseResponse) Reset 

func (x *UpstreamCloseResponse) Reset()

func (*UpstreamCloseResponse) String 

func (x *UpstreamCloseResponse) String() string

type UpstreamInfo 

type UpstreamInfo struct {
	SessionId    string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	StreamId     []byte `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	SourceNodeId string `protobuf:"bytes,3,opt,name=source_node_id,json=sourceNodeId,proto3" json:"source_node_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UpstreamInfo) Descriptor deprecated 

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

Deprecated: Use UpstreamInfo.ProtoReflect.Descriptor instead.

func (*UpstreamInfo) GetSessionId 

func (x *UpstreamInfo) GetSessionId() string

func (*UpstreamInfo) GetSourceNodeId 

func (x *UpstreamInfo) GetSourceNodeId() string

func (*UpstreamInfo) GetStreamId 

func (x *UpstreamInfo) GetStreamId() []byte

func (*UpstreamInfo) ProtoMessage 

func (*UpstreamInfo) ProtoMessage()

func (*UpstreamInfo) ProtoReflect 

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

func (*UpstreamInfo) Reset 

func (x *UpstreamInfo) Reset()

func (*UpstreamInfo) String 

func (x *UpstreamInfo) String() string

type UpstreamMetadata 

type UpstreamMetadata struct {
	RequestId uint32 `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Types that are assignable to Metadata:
	//
	//	*UpstreamMetadata_BaseTime
	Metadata        isUpstreamMetadata_Metadata                 `protobuf_oneof:"metadata"`
	ExtensionFields *extensions.UpstreamMetadataExtensionFields `protobuf:"bytes,4,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*UpstreamMetadata) Descriptor deprecated 

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

Deprecated: Use UpstreamMetadata.ProtoReflect.Descriptor instead.

func (*UpstreamMetadata) GetBaseTime 

func (x *UpstreamMetadata) GetBaseTime() *BaseTime

func (*UpstreamMetadata) GetExtensionFields 

func (x *UpstreamMetadata) GetExtensionFields() *extensions.UpstreamMetadataExtensionFields

func (*UpstreamMetadata) GetMetadata 

func (m *UpstreamMetadata) GetMetadata() isUpstreamMetadata_Metadata

func (*UpstreamMetadata) GetRequestId 

func (x *UpstreamMetadata) GetRequestId() uint32

func (*UpstreamMetadata) ProtoMessage 

func (*UpstreamMetadata) ProtoMessage()

func (*UpstreamMetadata) ProtoReflect 

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

func (*UpstreamMetadata) Reset 

func (x *UpstreamMetadata) Reset()

func (*UpstreamMetadata) String 

func (x *UpstreamMetadata) String() string

type UpstreamMetadataAck 

type UpstreamMetadataAck struct {
	RequestId       uint32                                         `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	ResultCode      ResultCode                                     `protobuf:"varint,2,opt,name=result_code,json=resultCode,proto3,enum=iscp2.v1.ResultCode" json:"result_code,omitempty"`
	ResultString    string                                         `protobuf:"bytes,3,opt,name=result_string,json=resultString,proto3" json:"result_string,omitempty"`
	ExtensionFields *extensions.UpstreamMetadataAckExtensionFields `protobuf:"bytes,4,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*UpstreamMetadataAck) Descriptor deprecated 

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

Deprecated: Use UpstreamMetadataAck.ProtoReflect.Descriptor instead.

func (*UpstreamMetadataAck) GetExtensionFields 

func (x *UpstreamMetadataAck) GetExtensionFields() *extensions.UpstreamMetadataAckExtensionFields

func (*UpstreamMetadataAck) GetRequestId 

func (x *UpstreamMetadataAck) GetRequestId() uint32

func (*UpstreamMetadataAck) GetResultCode 

func (x *UpstreamMetadataAck) GetResultCode() ResultCode

func (*UpstreamMetadataAck) GetResultString 

func (x *UpstreamMetadataAck) GetResultString() string

func (*UpstreamMetadataAck) ProtoMessage 

func (*UpstreamMetadataAck) ProtoMessage()

func (*UpstreamMetadataAck) ProtoReflect 

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

func (*UpstreamMetadataAck) Reset 

func (x *UpstreamMetadataAck) Reset()

func (*UpstreamMetadataAck) String 

func (x *UpstreamMetadataAck) String() string

type UpstreamMetadata_BaseTime 

type UpstreamMetadata_BaseTime struct {
	BaseTime *BaseTime `protobuf:"bytes,2,opt,name=base_time,json=baseTime,proto3,oneof"`
}

type UpstreamNormalClose 

type UpstreamNormalClose struct {
	StreamId            []byte `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	SessionId           string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	TotalDataPoints     uint64 `protobuf:"varint,3,opt,name=total_data_points,json=totalDataPoints,proto3" json:"total_data_points,omitempty"`
	FinalSequenceNumber uint32 `protobuf:"varint,4,opt,name=final_sequence_number,json=finalSequenceNumber,proto3" json:"final_sequence_number,omitempty"`
	// contains filtered or unexported fields
}

func (*UpstreamNormalClose) Descriptor deprecated 

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

Deprecated: Use UpstreamNormalClose.ProtoReflect.Descriptor instead.

func (*UpstreamNormalClose) GetFinalSequenceNumber 

func (x *UpstreamNormalClose) GetFinalSequenceNumber() uint32

func (*UpstreamNormalClose) GetSessionId 

func (x *UpstreamNormalClose) GetSessionId() string

func (*UpstreamNormalClose) GetStreamId 

func (x *UpstreamNormalClose) GetStreamId() []byte

func (*UpstreamNormalClose) GetTotalDataPoints 

func (x *UpstreamNormalClose) GetTotalDataPoints() uint64

func (*UpstreamNormalClose) ProtoMessage 

func (*UpstreamNormalClose) ProtoMessage()

func (*UpstreamNormalClose) ProtoReflect 

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

func (*UpstreamNormalClose) Reset 

func (x *UpstreamNormalClose) Reset()

func (*UpstreamNormalClose) String 

func (x *UpstreamNormalClose) String() string

type UpstreamOpen 

type UpstreamOpen struct {
	StreamId  []byte `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	SessionId string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Qos       QoS    `protobuf:"varint,3,opt,name=qos,proto3,enum=iscp2.v1.QoS" json:"qos,omitempty"`
	// contains filtered or unexported fields
}

func (*UpstreamOpen) Descriptor deprecated 

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

Deprecated: Use UpstreamOpen.ProtoReflect.Descriptor instead.

func (*UpstreamOpen) GetQos 

func (x *UpstreamOpen) GetQos() QoS

func (*UpstreamOpen) GetSessionId 

func (x *UpstreamOpen) GetSessionId() string

func (*UpstreamOpen) GetStreamId 

func (x *UpstreamOpen) GetStreamId() []byte

func (*UpstreamOpen) ProtoMessage 

func (*UpstreamOpen) ProtoMessage()

func (*UpstreamOpen) ProtoReflect 

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

func (*UpstreamOpen) Reset 

func (x *UpstreamOpen) Reset()

func (*UpstreamOpen) String 

func (x *UpstreamOpen) String() string

type UpstreamOpenRequest 

type UpstreamOpenRequest struct {
	RequestId       uint32                                         `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	SessionId       string                                         `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	AckInterval     uint32                                         `protobuf:"varint,3,opt,name=ack_interval,json=ackInterval,proto3" json:"ack_interval,omitempty"`
	ExpiryInterval  uint32                                         `protobuf:"varint,5,opt,name=expiry_interval,json=expiryInterval,proto3" json:"expiry_interval,omitempty"`
	DataIds         []*DataID                                      `protobuf:"bytes,6,rep,name=data_ids,json=dataIds,proto3" json:"data_ids,omitempty"`
	Qos             QoS                                            `protobuf:"varint,7,opt,name=qos,proto3,enum=iscp2.v1.QoS" json:"qos,omitempty"`
	ExtensionFields *extensions.UpstreamOpenRequestExtensionFields `protobuf:"bytes,8,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*UpstreamOpenRequest) Descriptor deprecated 

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

Deprecated: Use UpstreamOpenRequest.ProtoReflect.Descriptor instead.

func (*UpstreamOpenRequest) GetAckInterval 

func (x *UpstreamOpenRequest) GetAckInterval() uint32

func (*UpstreamOpenRequest) GetDataIds 

func (x *UpstreamOpenRequest) GetDataIds() []*DataID

func (*UpstreamOpenRequest) GetExpiryInterval 

func (x *UpstreamOpenRequest) GetExpiryInterval() uint32

func (*UpstreamOpenRequest) GetExtensionFields 

func (x *UpstreamOpenRequest) GetExtensionFields() *extensions.UpstreamOpenRequestExtensionFields

func (*UpstreamOpenRequest) GetQos 

func (x *UpstreamOpenRequest) GetQos() QoS

func (*UpstreamOpenRequest) GetRequestId 

func (x *UpstreamOpenRequest) GetRequestId() uint32

func (*UpstreamOpenRequest) GetSessionId 

func (x *UpstreamOpenRequest) GetSessionId() string

func (*UpstreamOpenRequest) ProtoMessage 

func (*UpstreamOpenRequest) ProtoMessage()

func (*UpstreamOpenRequest) ProtoReflect 

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

func (*UpstreamOpenRequest) Reset 

func (x *UpstreamOpenRequest) Reset()

func (*UpstreamOpenRequest) String 

func (x *UpstreamOpenRequest) String() string

type UpstreamOpenResponse 

type UpstreamOpenResponse struct {
	RequestId             uint32                                          `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	AssignedStreamId      []byte                                          `protobuf:"bytes,2,opt,name=assigned_stream_id,json=assignedStreamId,proto3" json:"assigned_stream_id,omitempty"`
	AssignedStreamIdAlias uint32                                          `` /* 129-byte string literal not displayed */
	DataIdAliases         map[uint32]*DataID                              `` /* 191-byte string literal not displayed */
	ServerTime            int64                                           `protobuf:"zigzag64,5,opt,name=server_time,json=serverTime,proto3" json:"server_time,omitempty"`
	ResultCode            ResultCode                                      `protobuf:"varint,6,opt,name=result_code,json=resultCode,proto3,enum=iscp2.v1.ResultCode" json:"result_code,omitempty"`
	ResultString          string                                          `protobuf:"bytes,7,opt,name=result_string,json=resultString,proto3" json:"result_string,omitempty"`
	ExtensionFields       *extensions.UpstreamOpenResponseExtensionFields `protobuf:"bytes,8,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*UpstreamOpenResponse) Descriptor deprecated 

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

Deprecated: Use UpstreamOpenResponse.ProtoReflect.Descriptor instead.

func (*UpstreamOpenResponse) GetAssignedStreamId 

func (x *UpstreamOpenResponse) GetAssignedStreamId() []byte

func (*UpstreamOpenResponse) GetAssignedStreamIdAlias 

func (x *UpstreamOpenResponse) GetAssignedStreamIdAlias() uint32

func (*UpstreamOpenResponse) GetDataIdAliases 

func (x *UpstreamOpenResponse) GetDataIdAliases() map[uint32]*DataID

func (*UpstreamOpenResponse) GetExtensionFields 

func (x *UpstreamOpenResponse) GetExtensionFields() *extensions.UpstreamOpenResponseExtensionFields

func (*UpstreamOpenResponse) GetRequestId 

func (x *UpstreamOpenResponse) GetRequestId() uint32

func (*UpstreamOpenResponse) GetResultCode 

func (x *UpstreamOpenResponse) GetResultCode() ResultCode

func (*UpstreamOpenResponse) GetResultString 

func (x *UpstreamOpenResponse) GetResultString() string

func (*UpstreamOpenResponse) GetServerTime 

func (x *UpstreamOpenResponse) GetServerTime() int64

func (*UpstreamOpenResponse) ProtoMessage 

func (*UpstreamOpenResponse) ProtoMessage()

func (*UpstreamOpenResponse) ProtoReflect 

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

func (*UpstreamOpenResponse) Reset 

func (x *UpstreamOpenResponse) Reset()

func (*UpstreamOpenResponse) String 

func (x *UpstreamOpenResponse) String() string

type UpstreamResume 

type UpstreamResume struct {
	StreamId  []byte `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	SessionId string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Qos       QoS    `protobuf:"varint,3,opt,name=qos,proto3,enum=iscp2.v1.QoS" json:"qos,omitempty"`
	// contains filtered or unexported fields
}

func (*UpstreamResume) Descriptor deprecated 

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

Deprecated: Use UpstreamResume.ProtoReflect.Descriptor instead.

func (*UpstreamResume) GetQos 

func (x *UpstreamResume) GetQos() QoS

func (*UpstreamResume) GetSessionId 

func (x *UpstreamResume) GetSessionId() string

func (*UpstreamResume) GetStreamId 

func (x *UpstreamResume) GetStreamId() []byte

func (*UpstreamResume) ProtoMessage 

func (*UpstreamResume) ProtoMessage()

func (*UpstreamResume) ProtoReflect 

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

func (*UpstreamResume) Reset 

func (x *UpstreamResume) Reset()

func (*UpstreamResume) String 

func (x *UpstreamResume) String() string

type UpstreamResumeRequest 

type UpstreamResumeRequest struct {
	RequestId       uint32                                           `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	StreamId        []byte                                           `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	ExtensionFields *extensions.UpstreamResumeRequestExtensionFields `protobuf:"bytes,3,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*UpstreamResumeRequest) Descriptor deprecated 

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

Deprecated: Use UpstreamResumeRequest.ProtoReflect.Descriptor instead.

func (*UpstreamResumeRequest) GetExtensionFields 

func (x *UpstreamResumeRequest) GetExtensionFields() *extensions.UpstreamResumeRequestExtensionFields

func (*UpstreamResumeRequest) GetRequestId 

func (x *UpstreamResumeRequest) GetRequestId() uint32

func (*UpstreamResumeRequest) GetStreamId 

func (x *UpstreamResumeRequest) GetStreamId() []byte

func (*UpstreamResumeRequest) ProtoMessage 

func (*UpstreamResumeRequest) ProtoMessage()

func (*UpstreamResumeRequest) ProtoReflect 

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

func (*UpstreamResumeRequest) Reset 

func (x *UpstreamResumeRequest) Reset()

func (*UpstreamResumeRequest) String 

func (x *UpstreamResumeRequest) String() string

type UpstreamResumeResponse 

type UpstreamResumeResponse struct {
	RequestId             uint32                                            `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	AssignedStreamIdAlias uint32                                            `` /* 129-byte string literal not displayed */
	ResultCode            ResultCode                                        `protobuf:"varint,3,opt,name=result_code,json=resultCode,proto3,enum=iscp2.v1.ResultCode" json:"result_code,omitempty"`
	ResultString          string                                            `protobuf:"bytes,4,opt,name=result_string,json=resultString,proto3" json:"result_string,omitempty"`
	ExtensionFields       *extensions.UpstreamResumeResponseExtensionFields `protobuf:"bytes,5,opt,name=extension_fields,json=extensionFields,proto3" json:"extension_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*UpstreamResumeResponse) Descriptor deprecated 

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

Deprecated: Use UpstreamResumeResponse.ProtoReflect.Descriptor instead.

func (*UpstreamResumeResponse) GetAssignedStreamIdAlias 

func (x *UpstreamResumeResponse) GetAssignedStreamIdAlias() uint32

func (*UpstreamResumeResponse) GetExtensionFields 

func (x *UpstreamResumeResponse) GetExtensionFields() *extensions.UpstreamResumeResponseExtensionFields

func (*UpstreamResumeResponse) GetRequestId 

func (x *UpstreamResumeResponse) GetRequestId() uint32

func (*UpstreamResumeResponse) GetResultCode 

func (x *UpstreamResumeResponse) GetResultCode() ResultCode

func (*UpstreamResumeResponse) GetResultString 

func (x *UpstreamResumeResponse) GetResultString() string

func (*UpstreamResumeResponse) ProtoMessage 

func (*UpstreamResumeResponse) ProtoMessage()

func (*UpstreamResumeResponse) ProtoReflect 

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

func (*UpstreamResumeResponse) Reset 

func (x *UpstreamResumeResponse) Reset()

func (*UpstreamResumeResponse) String 

func (x *UpstreamResumeResponse) String() string

Source Files

View all Source files

Directories

Path Synopsis

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.