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: 6 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCommon        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCommon          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCommon = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthConnection        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowConnection          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupConnection = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthDownstream        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDownstream          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDownstream = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthE2ECall        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowE2ECall          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupE2ECall = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthMessage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthMetadata        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMetadata          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMetadata = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthPingPong        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPingPong          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPingPong = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthUpstream        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowUpstream          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupUpstream = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var QoS_name = map[int32]string{
	0: "UNRELIABLE",
	1: "RELIABLE",
	2: "PARTIAL",
}
View Source 
var QoS_value = map[string]int32{
	"UNRELIABLE": 0,
	"RELIABLE":   1,
	"PARTIAL":    2,
}
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",
}
View Source 
var 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,
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BaseTime) Descriptor 

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

func (*BaseTime) GetBaseTime 

func (m *BaseTime) GetBaseTime() int64

func (*BaseTime) GetElapsedTime 

func (m *BaseTime) GetElapsedTime() uint64

func (*BaseTime) GetName 

func (m *BaseTime) GetName() string

func (*BaseTime) GetPriority 

func (m *BaseTime) GetPriority() uint32

func (*BaseTime) GetSessionId 

func (m *BaseTime) GetSessionId() string

func (*BaseTime) Marshal 

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

func (*BaseTime) MarshalTo 

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

func (*BaseTime) MarshalToSizedBuffer 

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

func (*BaseTime) ProtoMessage 

func (*BaseTime) ProtoMessage()

func (*BaseTime) Reset 

func (m *BaseTime) Reset()

func (*BaseTime) Size 

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

func (*BaseTime) String 

func (m *BaseTime) String() string

func (*BaseTime) Unmarshal 

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

func (*BaseTime) XXX_DiscardUnknown 

func (m *BaseTime) XXX_DiscardUnknown()

func (*BaseTime) XXX_Marshal 

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

func (*BaseTime) XXX_Merge 

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

func (*BaseTime) XXX_Size 

func (m *BaseTime) XXX_Size() int

func (*BaseTime) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                                  `json:"-"`
	XXX_unrecognized     []byte                                    `json:"-"`
	XXX_sizecache        int32                                     `json:"-"`
}

func (*ConnectRequest) Descriptor 

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

func (*ConnectRequest) GetExtensionFields 

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

func (*ConnectRequest) GetNodeId 

func (m *ConnectRequest) GetNodeId() string

func (*ConnectRequest) GetPingInterval 

func (m *ConnectRequest) GetPingInterval() uint32

func (*ConnectRequest) GetPingTimeout 

func (m *ConnectRequest) GetPingTimeout() uint32

func (*ConnectRequest) GetProtocolVersion 

func (m *ConnectRequest) GetProtocolVersion() string

func (*ConnectRequest) GetRequestId 

func (m *ConnectRequest) GetRequestId() uint32

func (*ConnectRequest) Marshal 

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

func (*ConnectRequest) MarshalTo 

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

func (*ConnectRequest) MarshalToSizedBuffer 

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

func (*ConnectRequest) ProtoMessage 

func (*ConnectRequest) ProtoMessage()

func (*ConnectRequest) Reset 

func (m *ConnectRequest) Reset()

func (*ConnectRequest) Size 

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

func (*ConnectRequest) String 

func (m *ConnectRequest) String() string

func (*ConnectRequest) Unmarshal 

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

func (*ConnectRequest) XXX_DiscardUnknown 

func (m *ConnectRequest) XXX_DiscardUnknown()

func (*ConnectRequest) XXX_Marshal 

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

func (*ConnectRequest) XXX_Merge 

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

func (*ConnectRequest) XXX_Size 

func (m *ConnectRequest) XXX_Size() int

func (*ConnectRequest) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                                   `json:"-"`
	XXX_unrecognized     []byte                                     `json:"-"`
	XXX_sizecache        int32                                      `json:"-"`
}

func (*ConnectResponse) Descriptor 

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

func (*ConnectResponse) GetExtensionFields 

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

func (*ConnectResponse) GetProtocolVersion 

func (m *ConnectResponse) GetProtocolVersion() string

func (*ConnectResponse) GetRequestId 

func (m *ConnectResponse) GetRequestId() uint32

func (*ConnectResponse) GetResultCode 

func (m *ConnectResponse) GetResultCode() ResultCode

func (*ConnectResponse) GetResultString 

func (m *ConnectResponse) GetResultString() string

func (*ConnectResponse) Marshal 

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

func (*ConnectResponse) MarshalTo 

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

func (*ConnectResponse) MarshalToSizedBuffer 

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

func (*ConnectResponse) ProtoMessage 

func (*ConnectResponse) ProtoMessage()

func (*ConnectResponse) Reset 

func (m *ConnectResponse) Reset()

func (*ConnectResponse) Size 

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

func (*ConnectResponse) String 

func (m *ConnectResponse) String() string

func (*ConnectResponse) Unmarshal 

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

func (*ConnectResponse) XXX_DiscardUnknown 

func (m *ConnectResponse) XXX_DiscardUnknown()

func (*ConnectResponse) XXX_Marshal 

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

func (*ConnectResponse) XXX_Merge 

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

func (*ConnectResponse) XXX_Size 

func (m *ConnectResponse) XXX_Size() int

func (*ConnectResponse) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DataFilter) Descriptor 

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

func (*DataFilter) GetName 

func (m *DataFilter) GetName() string

func (*DataFilter) GetType 

func (m *DataFilter) GetType() string

func (*DataFilter) Marshal 

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

func (*DataFilter) MarshalTo 

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

func (*DataFilter) MarshalToSizedBuffer 

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

func (*DataFilter) ProtoMessage 

func (*DataFilter) ProtoMessage()

func (*DataFilter) Reset 

func (m *DataFilter) Reset()

func (*DataFilter) Size 

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

func (*DataFilter) String 

func (m *DataFilter) String() string

func (*DataFilter) Unmarshal 

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

func (*DataFilter) XXX_DiscardUnknown 

func (m *DataFilter) XXX_DiscardUnknown()

func (*DataFilter) XXX_Marshal 

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

func (*DataFilter) XXX_Merge 

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

func (*DataFilter) XXX_Size 

func (m *DataFilter) XXX_Size() int

func (*DataFilter) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DataID) Descriptor 

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

func (*DataID) GetName 

func (m *DataID) GetName() string

func (*DataID) GetType 

func (m *DataID) GetType() string

func (*DataID) Marshal 

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

func (*DataID) MarshalTo 

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

func (*DataID) MarshalToSizedBuffer 

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

func (*DataID) ProtoMessage 

func (*DataID) ProtoMessage()

func (*DataID) Reset 

func (m *DataID) Reset()

func (*DataID) Size 

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

func (*DataID) String 

func (m *DataID) String() string

func (*DataID) Unmarshal 

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

func (*DataID) XXX_DiscardUnknown 

func (m *DataID) XXX_DiscardUnknown()

func (*DataID) XXX_Marshal 

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

func (*DataID) XXX_Merge 

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

func (*DataID) XXX_Size 

func (m *DataID) XXX_Size() int

func (*DataID) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DataPoint) Descriptor 

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

func (*DataPoint) GetElapsedTime 

func (m *DataPoint) GetElapsedTime() int64

func (*DataPoint) GetPayload 

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

func (*DataPoint) Marshal 

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

func (*DataPoint) MarshalTo 

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

func (*DataPoint) MarshalToSizedBuffer 

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

func (*DataPoint) ProtoMessage 

func (*DataPoint) ProtoMessage()

func (*DataPoint) Reset 

func (m *DataPoint) Reset()

func (*DataPoint) Size 

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

func (*DataPoint) String 

func (m *DataPoint) String() string

func (*DataPoint) Unmarshal 

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

func (*DataPoint) XXX_DiscardUnknown 

func (m *DataPoint) XXX_DiscardUnknown()

func (*DataPoint) XXX_Marshal 

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

func (*DataPoint) XXX_Merge 

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

func (*DataPoint) XXX_Size 

func (m *DataPoint) XXX_Size() int

func (*DataPoint) XXX_Unmarshal 

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

type DataPointGroup 

type DataPointGroup struct {
	// Types that are valid to be assigned 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"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*DataPointGroup) Descriptor 

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

func (*DataPointGroup) GetDataId 

func (m *DataPointGroup) GetDataId() *DataID

func (*DataPointGroup) GetDataIdAlias 

func (m *DataPointGroup) GetDataIdAlias() uint32

func (*DataPointGroup) GetDataIdOrAlias 

func (m *DataPointGroup) GetDataIdOrAlias() isDataPointGroup_DataIdOrAlias

func (*DataPointGroup) GetDataPoints 

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

func (*DataPointGroup) Marshal 

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

func (*DataPointGroup) MarshalTo 

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

func (*DataPointGroup) MarshalToSizedBuffer 

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

func (*DataPointGroup) ProtoMessage 

func (*DataPointGroup) ProtoMessage()

func (*DataPointGroup) Reset 

func (m *DataPointGroup) Reset()

func (*DataPointGroup) Size 

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

func (*DataPointGroup) String 

func (m *DataPointGroup) String() string

func (*DataPointGroup) Unmarshal 

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

func (*DataPointGroup) XXX_DiscardUnknown 

func (m *DataPointGroup) XXX_DiscardUnknown()

func (*DataPointGroup) XXX_Marshal 

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

func (*DataPointGroup) XXX_Merge 

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

func (*DataPointGroup) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*DataPointGroup) XXX_Size 

func (m *DataPointGroup) XXX_Size() int

func (*DataPointGroup) XXX_Unmarshal 

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

type DataPointGroup_DataId 

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

func (*DataPointGroup_DataId) MarshalTo 

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

func (*DataPointGroup_DataId) MarshalToSizedBuffer 

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

func (*DataPointGroup_DataId) Size 

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

type DataPointGroup_DataIdAlias 

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

func (*DataPointGroup_DataIdAlias) MarshalTo 

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

func (*DataPointGroup_DataIdAlias) MarshalToSizedBuffer 

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

func (*DataPointGroup_DataIdAlias) Size 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                              `json:"-"`
	XXX_unrecognized     []byte                                `json:"-"`
	XXX_sizecache        int32                                 `json:"-"`
}

func (*Disconnect) Descriptor 

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

func (*Disconnect) GetExtensionFields 

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

func (*Disconnect) GetResultCode 

func (m *Disconnect) GetResultCode() ResultCode

func (*Disconnect) GetResultString 

func (m *Disconnect) GetResultString() string

func (*Disconnect) Marshal 

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

func (*Disconnect) MarshalTo 

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

func (*Disconnect) MarshalToSizedBuffer 

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

func (*Disconnect) ProtoMessage 

func (*Disconnect) ProtoMessage()

func (*Disconnect) Reset 

func (m *Disconnect) Reset()

func (*Disconnect) Size 

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

func (*Disconnect) String 

func (m *Disconnect) String() string

func (*Disconnect) Unmarshal 

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

func (*Disconnect) XXX_DiscardUnknown 

func (m *Disconnect) XXX_DiscardUnknown()

func (*Disconnect) XXX_Marshal 

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

func (*Disconnect) XXX_Merge 

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

func (*Disconnect) XXX_Size 

func (m *Disconnect) XXX_Size() int

func (*Disconnect) XXX_Unmarshal 

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

type DownstreamAbnormalClose 

type DownstreamAbnormalClose struct {
	StreamId             []byte   `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DownstreamAbnormalClose) Descriptor 

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

func (*DownstreamAbnormalClose) GetStreamId 

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

func (*DownstreamAbnormalClose) Marshal 

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

func (*DownstreamAbnormalClose) MarshalTo 

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

func (*DownstreamAbnormalClose) MarshalToSizedBuffer 

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

func (*DownstreamAbnormalClose) ProtoMessage 

func (*DownstreamAbnormalClose) ProtoMessage()

func (*DownstreamAbnormalClose) Reset 

func (m *DownstreamAbnormalClose) Reset()

func (*DownstreamAbnormalClose) Size 

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

func (*DownstreamAbnormalClose) String 

func (m *DownstreamAbnormalClose) String() string

func (*DownstreamAbnormalClose) Unmarshal 

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

func (*DownstreamAbnormalClose) XXX_DiscardUnknown 

func (m *DownstreamAbnormalClose) XXX_DiscardUnknown()

func (*DownstreamAbnormalClose) XXX_Marshal 

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

func (*DownstreamAbnormalClose) XXX_Merge 

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

func (*DownstreamAbnormalClose) XXX_Size 

func (m *DownstreamAbnormalClose) XXX_Size() int

func (*DownstreamAbnormalClose) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                                  `json:"-"`
	XXX_unrecognized     []byte                                    `json:"-"`
	XXX_sizecache        int32                                     `json:"-"`
}

func (*DownstreamCall) Descriptor 

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

func (*DownstreamCall) GetCallId 

func (m *DownstreamCall) GetCallId() string

func (*DownstreamCall) GetExtensionFields 

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

func (*DownstreamCall) GetName 

func (m *DownstreamCall) GetName() string

func (*DownstreamCall) GetPayload 

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

func (*DownstreamCall) GetRequestCallId 

func (m *DownstreamCall) GetRequestCallId() string

func (*DownstreamCall) GetSourceNodeId 

func (m *DownstreamCall) GetSourceNodeId() string

func (*DownstreamCall) GetType 

func (m *DownstreamCall) GetType() string

func (*DownstreamCall) Marshal 

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

func (*DownstreamCall) MarshalTo 

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

func (*DownstreamCall) MarshalToSizedBuffer 

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

func (*DownstreamCall) ProtoMessage 

func (*DownstreamCall) ProtoMessage()

func (*DownstreamCall) Reset 

func (m *DownstreamCall) Reset()

func (*DownstreamCall) Size 

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

func (*DownstreamCall) String 

func (m *DownstreamCall) String() string

func (*DownstreamCall) Unmarshal 

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

func (*DownstreamCall) XXX_DiscardUnknown 

func (m *DownstreamCall) XXX_DiscardUnknown()

func (*DownstreamCall) XXX_Marshal 

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

func (*DownstreamCall) XXX_Merge 

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

func (*DownstreamCall) XXX_Size 

func (m *DownstreamCall) XXX_Size() int

func (*DownstreamCall) XXX_Unmarshal 

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

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 valid to be assigned 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"`
	XXX_NoUnkeyedLiteral struct{}                                   `json:"-"`
	XXX_unrecognized     []byte                                     `json:"-"`
	XXX_sizecache        int32                                      `json:"-"`
}

func (*DownstreamChunk) Descriptor 

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

func (*DownstreamChunk) GetExtensionFields 

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

func (*DownstreamChunk) GetStreamChunk 

func (m *DownstreamChunk) GetStreamChunk() *StreamChunk

func (*DownstreamChunk) GetStreamIdAlias 

func (m *DownstreamChunk) GetStreamIdAlias() uint32

func (*DownstreamChunk) GetUpstreamAlias 

func (m *DownstreamChunk) GetUpstreamAlias() uint32

func (*DownstreamChunk) GetUpstreamInfo 

func (m *DownstreamChunk) GetUpstreamInfo() *UpstreamInfo

func (*DownstreamChunk) GetUpstreamOrAlias 

func (m *DownstreamChunk) GetUpstreamOrAlias() isDownstreamChunk_UpstreamOrAlias

func (*DownstreamChunk) Marshal 

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

func (*DownstreamChunk) MarshalTo 

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

func (*DownstreamChunk) MarshalToSizedBuffer 

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

func (*DownstreamChunk) ProtoMessage 

func (*DownstreamChunk) ProtoMessage()

func (*DownstreamChunk) Reset 

func (m *DownstreamChunk) Reset()

func (*DownstreamChunk) Size 

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

func (*DownstreamChunk) String 

func (m *DownstreamChunk) String() string

func (*DownstreamChunk) Unmarshal 

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

func (*DownstreamChunk) XXX_DiscardUnknown 

func (m *DownstreamChunk) XXX_DiscardUnknown()

func (*DownstreamChunk) XXX_Marshal 

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

func (*DownstreamChunk) XXX_Merge 

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

func (*DownstreamChunk) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*DownstreamChunk) XXX_Size 

func (m *DownstreamChunk) XXX_Size() int

func (*DownstreamChunk) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                                      `json:"-"`
	XXX_unrecognized     []byte                                        `json:"-"`
	XXX_sizecache        int32                                         `json:"-"`
}

func (*DownstreamChunkAck) Descriptor 

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

func (*DownstreamChunkAck) GetAckId 

func (m *DownstreamChunkAck) GetAckId() uint32

func (*DownstreamChunkAck) GetDataIdAliases 

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

func (*DownstreamChunkAck) GetExtensionFields 

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

func (*DownstreamChunkAck) GetResults 

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

func (*DownstreamChunkAck) GetStreamIdAlias 

func (m *DownstreamChunkAck) GetStreamIdAlias() uint32

func (*DownstreamChunkAck) GetUpstreamAliases 

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

func (*DownstreamChunkAck) Marshal 

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

func (*DownstreamChunkAck) MarshalTo 

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

func (*DownstreamChunkAck) MarshalToSizedBuffer 

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

func (*DownstreamChunkAck) ProtoMessage 

func (*DownstreamChunkAck) ProtoMessage()

func (*DownstreamChunkAck) Reset 

func (m *DownstreamChunkAck) Reset()

func (*DownstreamChunkAck) Size 

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

func (*DownstreamChunkAck) String 

func (m *DownstreamChunkAck) String() string

func (*DownstreamChunkAck) Unmarshal 

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

func (*DownstreamChunkAck) XXX_DiscardUnknown 

func (m *DownstreamChunkAck) XXX_DiscardUnknown()

func (*DownstreamChunkAck) XXX_Marshal 

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

func (*DownstreamChunkAck) XXX_Merge 

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

func (*DownstreamChunkAck) XXX_Size 

func (m *DownstreamChunkAck) XXX_Size() int

func (*DownstreamChunkAck) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                                              `json:"-"`
	XXX_unrecognized     []byte                                                `json:"-"`
	XXX_sizecache        int32                                                 `json:"-"`
}

func (*DownstreamChunkAckComplete) Descriptor 

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

func (*DownstreamChunkAckComplete) GetAckId 

func (m *DownstreamChunkAckComplete) GetAckId() uint32

func (*DownstreamChunkAckComplete) GetExtensionFields 

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

func (*DownstreamChunkAckComplete) GetResultCode 

func (m *DownstreamChunkAckComplete) GetResultCode() ResultCode

func (*DownstreamChunkAckComplete) GetResultString 

func (m *DownstreamChunkAckComplete) GetResultString() string

func (*DownstreamChunkAckComplete) GetStreamIdAlias 

func (m *DownstreamChunkAckComplete) GetStreamIdAlias() uint32

func (*DownstreamChunkAckComplete) Marshal 

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

func (*DownstreamChunkAckComplete) MarshalTo 

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

func (*DownstreamChunkAckComplete) MarshalToSizedBuffer 

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

func (*DownstreamChunkAckComplete) ProtoMessage 

func (*DownstreamChunkAckComplete) ProtoMessage()

func (*DownstreamChunkAckComplete) Reset 

func (m *DownstreamChunkAckComplete) Reset()

func (*DownstreamChunkAckComplete) Size 

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

func (*DownstreamChunkAckComplete) String 

func (m *DownstreamChunkAckComplete) String() string

func (*DownstreamChunkAckComplete) Unmarshal 

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

func (*DownstreamChunkAckComplete) XXX_DiscardUnknown 

func (m *DownstreamChunkAckComplete) XXX_DiscardUnknown()

func (*DownstreamChunkAckComplete) XXX_Marshal 

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

func (*DownstreamChunkAckComplete) XXX_Merge 

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

func (*DownstreamChunkAckComplete) XXX_Size 

func (m *DownstreamChunkAckComplete) XXX_Size() int

func (*DownstreamChunkAckComplete) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral     struct{}                                         `json:"-"`
	XXX_unrecognized         []byte                                           `json:"-"`
	XXX_sizecache            int32                                            `json:"-"`
}

func (*DownstreamChunkResult) Descriptor 

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

func (*DownstreamChunkResult) GetExtensionFields 

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

func (*DownstreamChunkResult) GetResultCode 

func (m *DownstreamChunkResult) GetResultCode() ResultCode

func (*DownstreamChunkResult) GetResultString 

func (m *DownstreamChunkResult) GetResultString() string

func (*DownstreamChunkResult) GetSequenceNumberInUpstream 

func (m *DownstreamChunkResult) GetSequenceNumberInUpstream() uint32

func (*DownstreamChunkResult) GetStreamIdOfUpstream 

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

func (*DownstreamChunkResult) Marshal 

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

func (*DownstreamChunkResult) MarshalTo 

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

func (*DownstreamChunkResult) MarshalToSizedBuffer 

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

func (*DownstreamChunkResult) ProtoMessage 

func (*DownstreamChunkResult) ProtoMessage()

func (*DownstreamChunkResult) Reset 

func (m *DownstreamChunkResult) Reset()

func (*DownstreamChunkResult) Size 

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

func (*DownstreamChunkResult) String 

func (m *DownstreamChunkResult) String() string

func (*DownstreamChunkResult) Unmarshal 

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

func (*DownstreamChunkResult) XXX_DiscardUnknown 

func (m *DownstreamChunkResult) XXX_DiscardUnknown()

func (*DownstreamChunkResult) XXX_Marshal 

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

func (*DownstreamChunkResult) XXX_Merge 

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

func (*DownstreamChunkResult) XXX_Size 

func (m *DownstreamChunkResult) XXX_Size() int

func (*DownstreamChunkResult) XXX_Unmarshal 

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

type DownstreamChunk_UpstreamAlias 

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

func (*DownstreamChunk_UpstreamAlias) MarshalTo 

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

func (*DownstreamChunk_UpstreamAlias) MarshalToSizedBuffer 

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

func (*DownstreamChunk_UpstreamAlias) Size 

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

type DownstreamChunk_UpstreamInfo 

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

func (*DownstreamChunk_UpstreamInfo) MarshalTo 

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

func (*DownstreamChunk_UpstreamInfo) MarshalToSizedBuffer 

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

func (*DownstreamChunk_UpstreamInfo) Size 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                                          `json:"-"`
	XXX_unrecognized     []byte                                            `json:"-"`
	XXX_sizecache        int32                                             `json:"-"`
}

func (*DownstreamCloseRequest) Descriptor 

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

func (*DownstreamCloseRequest) GetExtensionFields 

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

func (*DownstreamCloseRequest) GetRequestId 

func (m *DownstreamCloseRequest) GetRequestId() uint32

func (*DownstreamCloseRequest) GetStreamId 

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

func (*DownstreamCloseRequest) Marshal 

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

func (*DownstreamCloseRequest) MarshalTo 

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

func (*DownstreamCloseRequest) MarshalToSizedBuffer 

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

func (*DownstreamCloseRequest) ProtoMessage 

func (*DownstreamCloseRequest) ProtoMessage()

func (*DownstreamCloseRequest) Reset 

func (m *DownstreamCloseRequest) Reset()

func (*DownstreamCloseRequest) Size 

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

func (*DownstreamCloseRequest) String 

func (m *DownstreamCloseRequest) String() string

func (*DownstreamCloseRequest) Unmarshal 

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

func (*DownstreamCloseRequest) XXX_DiscardUnknown 

func (m *DownstreamCloseRequest) XXX_DiscardUnknown()

func (*DownstreamCloseRequest) XXX_Marshal 

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

func (*DownstreamCloseRequest) XXX_Merge 

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

func (*DownstreamCloseRequest) XXX_Size 

func (m *DownstreamCloseRequest) XXX_Size() int

func (*DownstreamCloseRequest) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                                           `json:"-"`
	XXX_unrecognized     []byte                                             `json:"-"`
	XXX_sizecache        int32                                              `json:"-"`
}

func (*DownstreamCloseResponse) Descriptor 

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

func (*DownstreamCloseResponse) GetExtensionFields 

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

func (*DownstreamCloseResponse) GetRequestId 

func (m *DownstreamCloseResponse) GetRequestId() uint32

func (*DownstreamCloseResponse) GetResultCode 

func (m *DownstreamCloseResponse) GetResultCode() ResultCode

func (*DownstreamCloseResponse) GetResultString 

func (m *DownstreamCloseResponse) GetResultString() string

func (*DownstreamCloseResponse) Marshal 

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

func (*DownstreamCloseResponse) MarshalTo 

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

func (*DownstreamCloseResponse) MarshalToSizedBuffer 

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

func (*DownstreamCloseResponse) ProtoMessage 

func (*DownstreamCloseResponse) ProtoMessage()

func (*DownstreamCloseResponse) Reset 

func (m *DownstreamCloseResponse) Reset()

func (*DownstreamCloseResponse) Size 

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

func (*DownstreamCloseResponse) String 

func (m *DownstreamCloseResponse) String() string

func (*DownstreamCloseResponse) Unmarshal 

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

func (*DownstreamCloseResponse) XXX_DiscardUnknown 

func (m *DownstreamCloseResponse) XXX_DiscardUnknown()

func (*DownstreamCloseResponse) XXX_Marshal 

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

func (*DownstreamCloseResponse) XXX_Merge 

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

func (*DownstreamCloseResponse) XXX_Size 

func (m *DownstreamCloseResponse) XXX_Size() int

func (*DownstreamCloseResponse) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*DownstreamFilter) Descriptor 

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

func (*DownstreamFilter) GetDataFilters 

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

func (*DownstreamFilter) GetSourceNodeId 

func (m *DownstreamFilter) GetSourceNodeId() string

func (*DownstreamFilter) Marshal 

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

func (*DownstreamFilter) MarshalTo 

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

func (*DownstreamFilter) MarshalToSizedBuffer 

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

func (*DownstreamFilter) ProtoMessage 

func (*DownstreamFilter) ProtoMessage()

func (*DownstreamFilter) Reset 

func (m *DownstreamFilter) Reset()

func (*DownstreamFilter) Size 

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

func (*DownstreamFilter) String 

func (m *DownstreamFilter) String() string

func (*DownstreamFilter) Unmarshal 

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

func (*DownstreamFilter) XXX_DiscardUnknown 

func (m *DownstreamFilter) XXX_DiscardUnknown()

func (*DownstreamFilter) XXX_Marshal 

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

func (*DownstreamFilter) XXX_Merge 

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

func (*DownstreamFilter) XXX_Size 

func (m *DownstreamFilter) XXX_Size() int

func (*DownstreamFilter) XXX_Unmarshal 

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

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 valid to be assigned 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"`
	XXX_NoUnkeyedLiteral struct{}                                      `json:"-"`
	XXX_unrecognized     []byte                                        `json:"-"`
	XXX_sizecache        int32                                         `json:"-"`
}

func (*DownstreamMetadata) Descriptor 

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

func (*DownstreamMetadata) GetBaseTime 

func (m *DownstreamMetadata) GetBaseTime() *BaseTime

func (*DownstreamMetadata) GetDownstreamAbnormalClose 

func (m *DownstreamMetadata) GetDownstreamAbnormalClose() *DownstreamAbnormalClose

func (*DownstreamMetadata) GetDownstreamNormalClose 

func (m *DownstreamMetadata) GetDownstreamNormalClose() *DownstreamNormalClose

func (*DownstreamMetadata) GetDownstreamOpen 

func (m *DownstreamMetadata) GetDownstreamOpen() *DownstreamOpen

func (*DownstreamMetadata) GetDownstreamResume 

func (m *DownstreamMetadata) GetDownstreamResume() *DownstreamResume

func (*DownstreamMetadata) GetExtensionFields 

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

func (*DownstreamMetadata) GetMetadata 

func (m *DownstreamMetadata) GetMetadata() isDownstreamMetadata_Metadata

func (*DownstreamMetadata) GetRequestId 

func (m *DownstreamMetadata) GetRequestId() uint32

func (*DownstreamMetadata) GetSourceNodeId 

func (m *DownstreamMetadata) GetSourceNodeId() string

func (*DownstreamMetadata) GetStreamIdAlias 

func (m *DownstreamMetadata) GetStreamIdAlias() uint32

func (*DownstreamMetadata) GetUpstreamAbnormalClose 

func (m *DownstreamMetadata) GetUpstreamAbnormalClose() *UpstreamAbnormalClose

func (*DownstreamMetadata) GetUpstreamNormalClose 

func (m *DownstreamMetadata) GetUpstreamNormalClose() *UpstreamNormalClose

func (*DownstreamMetadata) GetUpstreamOpen 

func (m *DownstreamMetadata) GetUpstreamOpen() *UpstreamOpen

func (*DownstreamMetadata) GetUpstreamResume 

func (m *DownstreamMetadata) GetUpstreamResume() *UpstreamResume

func (*DownstreamMetadata) Marshal 

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

func (*DownstreamMetadata) MarshalTo 

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

func (*DownstreamMetadata) MarshalToSizedBuffer 

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

func (*DownstreamMetadata) ProtoMessage 

func (*DownstreamMetadata) ProtoMessage()

func (*DownstreamMetadata) Reset 

func (m *DownstreamMetadata) Reset()

func (*DownstreamMetadata) Size 

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

func (*DownstreamMetadata) String 

func (m *DownstreamMetadata) String() string

func (*DownstreamMetadata) Unmarshal 

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

func (*DownstreamMetadata) XXX_DiscardUnknown 

func (m *DownstreamMetadata) XXX_DiscardUnknown()

func (*DownstreamMetadata) XXX_Marshal 

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

func (*DownstreamMetadata) XXX_Merge 

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

func (*DownstreamMetadata) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*DownstreamMetadata) XXX_Size 

func (m *DownstreamMetadata) XXX_Size() int

func (*DownstreamMetadata) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                                         `json:"-"`
	XXX_unrecognized     []byte                                           `json:"-"`
	XXX_sizecache        int32                                            `json:"-"`
}

func (*DownstreamMetadataAck) Descriptor 

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

func (*DownstreamMetadataAck) GetExtensionFields 

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

func (*DownstreamMetadataAck) GetRequestId 

func (m *DownstreamMetadataAck) GetRequestId() uint32

func (*DownstreamMetadataAck) GetResultCode 

func (m *DownstreamMetadataAck) GetResultCode() ResultCode

func (*DownstreamMetadataAck) GetResultString 

func (m *DownstreamMetadataAck) GetResultString() string

func (*DownstreamMetadataAck) Marshal 

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

func (*DownstreamMetadataAck) MarshalTo 

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

func (*DownstreamMetadataAck) MarshalToSizedBuffer 

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

func (*DownstreamMetadataAck) ProtoMessage 

func (*DownstreamMetadataAck) ProtoMessage()

func (*DownstreamMetadataAck) Reset 

func (m *DownstreamMetadataAck) Reset()

func (*DownstreamMetadataAck) Size 

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

func (*DownstreamMetadataAck) String 

func (m *DownstreamMetadataAck) String() string

func (*DownstreamMetadataAck) Unmarshal 

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

func (*DownstreamMetadataAck) XXX_DiscardUnknown 

func (m *DownstreamMetadataAck) XXX_DiscardUnknown()

func (*DownstreamMetadataAck) XXX_Marshal 

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

func (*DownstreamMetadataAck) XXX_Merge 

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

func (*DownstreamMetadataAck) XXX_Size 

func (m *DownstreamMetadataAck) XXX_Size() int

func (*DownstreamMetadataAck) XXX_Unmarshal 

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

type DownstreamMetadata_BaseTime 

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

func (*DownstreamMetadata_BaseTime) MarshalTo 

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

func (*DownstreamMetadata_BaseTime) MarshalToSizedBuffer 

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

func (*DownstreamMetadata_BaseTime) Size 

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

type DownstreamMetadata_DownstreamAbnormalClose 

type DownstreamMetadata_DownstreamAbnormalClose struct {
	DownstreamAbnormalClose *DownstreamAbnormalClose `` /* 138-byte string literal not displayed */
}

func (*DownstreamMetadata_DownstreamAbnormalClose) MarshalTo 

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

func (*DownstreamMetadata_DownstreamAbnormalClose) MarshalToSizedBuffer 

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

func (*DownstreamMetadata_DownstreamAbnormalClose) Size 

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

type DownstreamMetadata_DownstreamNormalClose 

type DownstreamMetadata_DownstreamNormalClose struct {
	DownstreamNormalClose *DownstreamNormalClose `` /* 133-byte string literal not displayed */
}

func (*DownstreamMetadata_DownstreamNormalClose) MarshalTo 

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

func (*DownstreamMetadata_DownstreamNormalClose) MarshalToSizedBuffer 

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

func (*DownstreamMetadata_DownstreamNormalClose) Size 

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

type DownstreamMetadata_DownstreamOpen 

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

func (*DownstreamMetadata_DownstreamOpen) MarshalTo 

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

func (*DownstreamMetadata_DownstreamOpen) MarshalToSizedBuffer 

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

func (*DownstreamMetadata_DownstreamOpen) Size 

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

type DownstreamMetadata_DownstreamResume 

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

func (*DownstreamMetadata_DownstreamResume) MarshalTo 

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

func (*DownstreamMetadata_DownstreamResume) MarshalToSizedBuffer 

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

func (*DownstreamMetadata_DownstreamResume) Size 

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

type DownstreamMetadata_UpstreamAbnormalClose 

type DownstreamMetadata_UpstreamAbnormalClose struct {
	UpstreamAbnormalClose *UpstreamAbnormalClose `` /* 132-byte string literal not displayed */
}

func (*DownstreamMetadata_UpstreamAbnormalClose) MarshalTo 

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

func (*DownstreamMetadata_UpstreamAbnormalClose) MarshalToSizedBuffer 

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

func (*DownstreamMetadata_UpstreamAbnormalClose) Size 

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

type DownstreamMetadata_UpstreamNormalClose 

type DownstreamMetadata_UpstreamNormalClose struct {
	UpstreamNormalClose *UpstreamNormalClose `` /* 126-byte string literal not displayed */
}

func (*DownstreamMetadata_UpstreamNormalClose) MarshalTo 

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

func (*DownstreamMetadata_UpstreamNormalClose) MarshalToSizedBuffer 

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

func (*DownstreamMetadata_UpstreamNormalClose) Size 

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

type DownstreamMetadata_UpstreamOpen 

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

func (*DownstreamMetadata_UpstreamOpen) MarshalTo 

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

func (*DownstreamMetadata_UpstreamOpen) MarshalToSizedBuffer 

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

func (*DownstreamMetadata_UpstreamOpen) Size 

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

type DownstreamMetadata_UpstreamResume 

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

func (*DownstreamMetadata_UpstreamResume) MarshalTo 

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

func (*DownstreamMetadata_UpstreamResume) MarshalToSizedBuffer 

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

func (*DownstreamMetadata_UpstreamResume) Size 

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

type DownstreamNormalClose 

type DownstreamNormalClose struct {
	StreamId             []byte   `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DownstreamNormalClose) Descriptor 

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

func (*DownstreamNormalClose) GetStreamId 

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

func (*DownstreamNormalClose) Marshal 

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

func (*DownstreamNormalClose) MarshalTo 

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

func (*DownstreamNormalClose) MarshalToSizedBuffer 

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

func (*DownstreamNormalClose) ProtoMessage 

func (*DownstreamNormalClose) ProtoMessage()

func (*DownstreamNormalClose) Reset 

func (m *DownstreamNormalClose) Reset()

func (*DownstreamNormalClose) Size 

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

func (*DownstreamNormalClose) String 

func (m *DownstreamNormalClose) String() string

func (*DownstreamNormalClose) Unmarshal 

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

func (*DownstreamNormalClose) XXX_DiscardUnknown 

func (m *DownstreamNormalClose) XXX_DiscardUnknown()

func (*DownstreamNormalClose) XXX_Marshal 

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

func (*DownstreamNormalClose) XXX_Merge 

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

func (*DownstreamNormalClose) XXX_Size 

func (m *DownstreamNormalClose) XXX_Size() int

func (*DownstreamNormalClose) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*DownstreamOpen) Descriptor 

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

func (*DownstreamOpen) GetDownstreamFilters 

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

func (*DownstreamOpen) GetQos 

func (m *DownstreamOpen) GetQos() QoS

func (*DownstreamOpen) GetStreamId 

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

func (*DownstreamOpen) Marshal 

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

func (*DownstreamOpen) MarshalTo 

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

func (*DownstreamOpen) MarshalToSizedBuffer 

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

func (*DownstreamOpen) ProtoMessage 

func (*DownstreamOpen) ProtoMessage()

func (*DownstreamOpen) Reset 

func (m *DownstreamOpen) Reset()

func (*DownstreamOpen) Size 

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

func (*DownstreamOpen) String 

func (m *DownstreamOpen) String() string

func (*DownstreamOpen) Unmarshal 

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

func (*DownstreamOpen) XXX_DiscardUnknown 

func (m *DownstreamOpen) XXX_DiscardUnknown()

func (*DownstreamOpen) XXX_Marshal 

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

func (*DownstreamOpen) XXX_Merge 

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

func (*DownstreamOpen) XXX_Size 

func (m *DownstreamOpen) XXX_Size() int

func (*DownstreamOpen) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                                         `json:"-"`
	XXX_unrecognized     []byte                                           `json:"-"`
	XXX_sizecache        int32                                            `json:"-"`
}

func (*DownstreamOpenRequest) Descriptor 

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

func (*DownstreamOpenRequest) GetDataIdAliases 

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

func (*DownstreamOpenRequest) GetDesiredStreamIdAlias 

func (m *DownstreamOpenRequest) GetDesiredStreamIdAlias() uint32

func (*DownstreamOpenRequest) GetDownstreamFilters 

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

func (*DownstreamOpenRequest) GetExpiryInterval 

func (m *DownstreamOpenRequest) GetExpiryInterval() uint32

func (*DownstreamOpenRequest) GetExtensionFields 

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

func (*DownstreamOpenRequest) GetOmitEmptyChunk 

func (m *DownstreamOpenRequest) GetOmitEmptyChunk() bool

func (*DownstreamOpenRequest) GetQos 

func (m *DownstreamOpenRequest) GetQos() QoS

func (*DownstreamOpenRequest) GetRequestId 

func (m *DownstreamOpenRequest) GetRequestId() uint32

func (*DownstreamOpenRequest) Marshal 

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

func (*DownstreamOpenRequest) MarshalTo 

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

func (*DownstreamOpenRequest) MarshalToSizedBuffer 

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

func (*DownstreamOpenRequest) ProtoMessage 

func (*DownstreamOpenRequest) ProtoMessage()

func (*DownstreamOpenRequest) Reset 

func (m *DownstreamOpenRequest) Reset()

func (*DownstreamOpenRequest) Size 

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

func (*DownstreamOpenRequest) String 

func (m *DownstreamOpenRequest) String() string

func (*DownstreamOpenRequest) Unmarshal 

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

func (*DownstreamOpenRequest) XXX_DiscardUnknown 

func (m *DownstreamOpenRequest) XXX_DiscardUnknown()

func (*DownstreamOpenRequest) XXX_Marshal 

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

func (*DownstreamOpenRequest) XXX_Merge 

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

func (*DownstreamOpenRequest) XXX_Size 

func (m *DownstreamOpenRequest) XXX_Size() int

func (*DownstreamOpenRequest) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                                          `json:"-"`
	XXX_unrecognized     []byte                                            `json:"-"`
	XXX_sizecache        int32                                             `json:"-"`
}

func (*DownstreamOpenResponse) Descriptor 

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

func (*DownstreamOpenResponse) GetAssignedStreamId 

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

func (*DownstreamOpenResponse) GetExtensionFields 

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

func (*DownstreamOpenResponse) GetRequestId 

func (m *DownstreamOpenResponse) GetRequestId() uint32

func (*DownstreamOpenResponse) GetResultCode 

func (m *DownstreamOpenResponse) GetResultCode() ResultCode

func (*DownstreamOpenResponse) GetResultString 

func (m *DownstreamOpenResponse) GetResultString() string

func (*DownstreamOpenResponse) GetServerTime 

func (m *DownstreamOpenResponse) GetServerTime() int64

func (*DownstreamOpenResponse) Marshal 

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

func (*DownstreamOpenResponse) MarshalTo 

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

func (*DownstreamOpenResponse) MarshalToSizedBuffer 

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

func (*DownstreamOpenResponse) ProtoMessage 

func (*DownstreamOpenResponse) ProtoMessage()

func (*DownstreamOpenResponse) Reset 

func (m *DownstreamOpenResponse) Reset()

func (*DownstreamOpenResponse) Size 

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

func (*DownstreamOpenResponse) String 

func (m *DownstreamOpenResponse) String() string

func (*DownstreamOpenResponse) Unmarshal 

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

func (*DownstreamOpenResponse) XXX_DiscardUnknown 

func (m *DownstreamOpenResponse) XXX_DiscardUnknown()

func (*DownstreamOpenResponse) XXX_Marshal 

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

func (*DownstreamOpenResponse) XXX_Merge 

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

func (*DownstreamOpenResponse) XXX_Size 

func (m *DownstreamOpenResponse) XXX_Size() int

func (*DownstreamOpenResponse) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*DownstreamResume) Descriptor 

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

func (*DownstreamResume) GetDownstreamFilters 

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

func (*DownstreamResume) GetQos 

func (m *DownstreamResume) GetQos() QoS

func (*DownstreamResume) GetStreamId 

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

func (*DownstreamResume) Marshal 

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

func (*DownstreamResume) MarshalTo 

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

func (*DownstreamResume) MarshalToSizedBuffer 

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

func (*DownstreamResume) ProtoMessage 

func (*DownstreamResume) ProtoMessage()

func (*DownstreamResume) Reset 

func (m *DownstreamResume) Reset()

func (*DownstreamResume) Size 

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

func (*DownstreamResume) String 

func (m *DownstreamResume) String() string

func (*DownstreamResume) Unmarshal 

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

func (*DownstreamResume) XXX_DiscardUnknown 

func (m *DownstreamResume) XXX_DiscardUnknown()

func (*DownstreamResume) XXX_Marshal 

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

func (*DownstreamResume) XXX_Merge 

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

func (*DownstreamResume) XXX_Size 

func (m *DownstreamResume) XXX_Size() int

func (*DownstreamResume) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                                           `json:"-"`
	XXX_unrecognized     []byte                                             `json:"-"`
	XXX_sizecache        int32                                              `json:"-"`
}

func (*DownstreamResumeRequest) Descriptor 

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

func (*DownstreamResumeRequest) GetDesiredStreamIdAlias 

func (m *DownstreamResumeRequest) GetDesiredStreamIdAlias() uint32

func (*DownstreamResumeRequest) GetExtensionFields 

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

func (*DownstreamResumeRequest) GetRequestId 

func (m *DownstreamResumeRequest) GetRequestId() uint32

func (*DownstreamResumeRequest) GetStreamId 

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

func (*DownstreamResumeRequest) Marshal 

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

func (*DownstreamResumeRequest) MarshalTo 

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

func (*DownstreamResumeRequest) MarshalToSizedBuffer 

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

func (*DownstreamResumeRequest) ProtoMessage 

func (*DownstreamResumeRequest) ProtoMessage()

func (*DownstreamResumeRequest) Reset 

func (m *DownstreamResumeRequest) Reset()

func (*DownstreamResumeRequest) Size 

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

func (*DownstreamResumeRequest) String 

func (m *DownstreamResumeRequest) String() string

func (*DownstreamResumeRequest) Unmarshal 

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

func (*DownstreamResumeRequest) XXX_DiscardUnknown 

func (m *DownstreamResumeRequest) XXX_DiscardUnknown()

func (*DownstreamResumeRequest) XXX_Marshal 

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

func (*DownstreamResumeRequest) XXX_Merge 

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

func (*DownstreamResumeRequest) XXX_Size 

func (m *DownstreamResumeRequest) XXX_Size() int

func (*DownstreamResumeRequest) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                                            `json:"-"`
	XXX_unrecognized     []byte                                              `json:"-"`
	XXX_sizecache        int32                                               `json:"-"`
}

func (*DownstreamResumeResponse) Descriptor 

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

func (*DownstreamResumeResponse) GetExtensionFields 

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

func (*DownstreamResumeResponse) GetRequestId 

func (m *DownstreamResumeResponse) GetRequestId() uint32

func (*DownstreamResumeResponse) GetResultCode 

func (m *DownstreamResumeResponse) GetResultCode() ResultCode

func (*DownstreamResumeResponse) GetResultString 

func (m *DownstreamResumeResponse) GetResultString() string

func (*DownstreamResumeResponse) Marshal 

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

func (*DownstreamResumeResponse) MarshalTo 

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

func (*DownstreamResumeResponse) MarshalToSizedBuffer 

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

func (*DownstreamResumeResponse) ProtoMessage 

func (*DownstreamResumeResponse) ProtoMessage()

func (*DownstreamResumeResponse) Reset 

func (m *DownstreamResumeResponse) Reset()

func (*DownstreamResumeResponse) Size 

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

func (*DownstreamResumeResponse) String 

func (m *DownstreamResumeResponse) String() string

func (*DownstreamResumeResponse) Unmarshal 

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

func (*DownstreamResumeResponse) XXX_DiscardUnknown 

func (m *DownstreamResumeResponse) XXX_DiscardUnknown()

func (*DownstreamResumeResponse) XXX_Marshal 

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

func (*DownstreamResumeResponse) XXX_Merge 

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

func (*DownstreamResumeResponse) XXX_Size 

func (m *DownstreamResumeResponse) XXX_Size() int

func (*DownstreamResumeResponse) XXX_Unmarshal 

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

type Message 

type Message struct {
	// Types that are valid to be assigned 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"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Message) Descriptor 

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

func (*Message) GetConnectRequest 

func (m *Message) GetConnectRequest() *ConnectRequest

func (*Message) GetConnectResponse 

func (m *Message) GetConnectResponse() *ConnectResponse

func (*Message) GetDisconnect 

func (m *Message) GetDisconnect() *Disconnect

func (*Message) GetDownstreamCall 

func (m *Message) GetDownstreamCall() *DownstreamCall

func (*Message) GetDownstreamChunk 

func (m *Message) GetDownstreamChunk() *DownstreamChunk

func (*Message) GetDownstreamChunkAck 

func (m *Message) GetDownstreamChunkAck() *DownstreamChunkAck

func (*Message) GetDownstreamChunkAckComplete 

func (m *Message) GetDownstreamChunkAckComplete() *DownstreamChunkAckComplete

func (*Message) GetDownstreamCloseRequest 

func (m *Message) GetDownstreamCloseRequest() *DownstreamCloseRequest

func (*Message) GetDownstreamCloseResponse 

func (m *Message) GetDownstreamCloseResponse() *DownstreamCloseResponse

func (*Message) GetDownstreamMetadata 

func (m *Message) GetDownstreamMetadata() *DownstreamMetadata

func (*Message) GetDownstreamMetadataAck 

func (m *Message) GetDownstreamMetadataAck() *DownstreamMetadataAck

func (*Message) GetDownstreamOpenRequest 

func (m *Message) GetDownstreamOpenRequest() *DownstreamOpenRequest

func (*Message) GetDownstreamOpenResponse 

func (m *Message) GetDownstreamOpenResponse() *DownstreamOpenResponse

func (*Message) GetDownstreamResumeRequest 

func (m *Message) GetDownstreamResumeRequest() *DownstreamResumeRequest

func (*Message) GetDownstreamResumeResponse 

func (m *Message) GetDownstreamResumeResponse() *DownstreamResumeResponse

func (*Message) GetMessage 

func (m *Message) GetMessage() isMessage_Message

func (*Message) GetPing 

func (m *Message) GetPing() *Ping

func (*Message) GetPong 

func (m *Message) GetPong() *Pong

func (*Message) GetUpstreamCall 

func (m *Message) GetUpstreamCall() *UpstreamCall

func (*Message) GetUpstreamCallAck 

func (m *Message) GetUpstreamCallAck() *UpstreamCallAck

func (*Message) GetUpstreamChunk 

func (m *Message) GetUpstreamChunk() *UpstreamChunk

func (*Message) GetUpstreamChunkAck 

func (m *Message) GetUpstreamChunkAck() *UpstreamChunkAck

func (*Message) GetUpstreamCloseRequest 

func (m *Message) GetUpstreamCloseRequest() *UpstreamCloseRequest

func (*Message) GetUpstreamCloseResponse 

func (m *Message) GetUpstreamCloseResponse() *UpstreamCloseResponse

func (*Message) GetUpstreamMetadata 

func (m *Message) GetUpstreamMetadata() *UpstreamMetadata

func (*Message) GetUpstreamMetadataAck 

func (m *Message) GetUpstreamMetadataAck() *UpstreamMetadataAck

func (*Message) GetUpstreamOpenRequest 

func (m *Message) GetUpstreamOpenRequest() *UpstreamOpenRequest

func (*Message) GetUpstreamOpenResponse 

func (m *Message) GetUpstreamOpenResponse() *UpstreamOpenResponse

func (*Message) GetUpstreamResumeRequest 

func (m *Message) GetUpstreamResumeRequest() *UpstreamResumeRequest

func (*Message) GetUpstreamResumeResponse 

func (m *Message) GetUpstreamResumeResponse() *UpstreamResumeResponse

func (*Message) Marshal 

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

func (*Message) MarshalTo 

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

func (*Message) MarshalToSizedBuffer 

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

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) Size 

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

func (*Message) String 

func (m *Message) String() string

func (*Message) Unmarshal 

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

func (*Message) XXX_DiscardUnknown 

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal 

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

func (*Message) XXX_Merge 

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

func (*Message) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Message) XXX_Size 

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal 

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

type Message_ConnectRequest 

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

func (*Message_ConnectRequest) MarshalTo 

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

func (*Message_ConnectRequest) MarshalToSizedBuffer 

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

func (*Message_ConnectRequest) Size 

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

type Message_ConnectResponse 

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

func (*Message_ConnectResponse) MarshalTo 

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

func (*Message_ConnectResponse) MarshalToSizedBuffer 

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

func (*Message_ConnectResponse) Size 

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

type Message_Disconnect 

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

func (*Message_Disconnect) MarshalTo 

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

func (*Message_Disconnect) MarshalToSizedBuffer 

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

func (*Message_Disconnect) Size 

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

type Message_DownstreamCall 

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

func (*Message_DownstreamCall) MarshalTo 

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

func (*Message_DownstreamCall) MarshalToSizedBuffer 

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

func (*Message_DownstreamCall) Size 

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

type Message_DownstreamChunk 

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

func (*Message_DownstreamChunk) MarshalTo 

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

func (*Message_DownstreamChunk) MarshalToSizedBuffer 

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

func (*Message_DownstreamChunk) Size 

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

type Message_DownstreamChunkAck 

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

func (*Message_DownstreamChunkAck) MarshalTo 

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

func (*Message_DownstreamChunkAck) MarshalToSizedBuffer 

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

func (*Message_DownstreamChunkAck) Size 

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

type Message_DownstreamChunkAckComplete 

type Message_DownstreamChunkAckComplete struct {
	DownstreamChunkAckComplete *DownstreamChunkAckComplete `` /* 151-byte string literal not displayed */
}

func (*Message_DownstreamChunkAckComplete) MarshalTo 

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

func (*Message_DownstreamChunkAckComplete) MarshalToSizedBuffer 

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

func (*Message_DownstreamChunkAckComplete) Size 

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

type Message_DownstreamCloseRequest 

type Message_DownstreamCloseRequest struct {
	DownstreamCloseRequest *DownstreamCloseRequest `` /* 137-byte string literal not displayed */
}

func (*Message_DownstreamCloseRequest) MarshalTo 

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

func (*Message_DownstreamCloseRequest) MarshalToSizedBuffer 

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

func (*Message_DownstreamCloseRequest) Size 

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

type Message_DownstreamCloseResponse 

type Message_DownstreamCloseResponse struct {
	DownstreamCloseResponse *DownstreamCloseResponse `` /* 140-byte string literal not displayed */
}

func (*Message_DownstreamCloseResponse) MarshalTo 

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

func (*Message_DownstreamCloseResponse) MarshalToSizedBuffer 

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

func (*Message_DownstreamCloseResponse) Size 

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

type Message_DownstreamMetadata 

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

func (*Message_DownstreamMetadata) MarshalTo 

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

func (*Message_DownstreamMetadata) MarshalToSizedBuffer 

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

func (*Message_DownstreamMetadata) Size 

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

type Message_DownstreamMetadataAck 

type Message_DownstreamMetadataAck struct {
	DownstreamMetadataAck *DownstreamMetadataAck `` /* 134-byte string literal not displayed */
}

func (*Message_DownstreamMetadataAck) MarshalTo 

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

func (*Message_DownstreamMetadataAck) MarshalToSizedBuffer 

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

func (*Message_DownstreamMetadataAck) Size 

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

type Message_DownstreamOpenRequest 

type Message_DownstreamOpenRequest struct {
	DownstreamOpenRequest *DownstreamOpenRequest `` /* 134-byte string literal not displayed */
}

func (*Message_DownstreamOpenRequest) MarshalTo 

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

func (*Message_DownstreamOpenRequest) MarshalToSizedBuffer 

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

func (*Message_DownstreamOpenRequest) Size 

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

type Message_DownstreamOpenResponse 

type Message_DownstreamOpenResponse struct {
	DownstreamOpenResponse *DownstreamOpenResponse `` /* 137-byte string literal not displayed */
}

func (*Message_DownstreamOpenResponse) MarshalTo 

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

func (*Message_DownstreamOpenResponse) MarshalToSizedBuffer 

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

func (*Message_DownstreamOpenResponse) Size 

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

type Message_DownstreamResumeRequest 

type Message_DownstreamResumeRequest struct {
	DownstreamResumeRequest *DownstreamResumeRequest `` /* 140-byte string literal not displayed */
}

func (*Message_DownstreamResumeRequest) MarshalTo 

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

func (*Message_DownstreamResumeRequest) MarshalToSizedBuffer 

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

func (*Message_DownstreamResumeRequest) Size 

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

type Message_DownstreamResumeResponse 

type Message_DownstreamResumeResponse struct {
	DownstreamResumeResponse *DownstreamResumeResponse `` /* 143-byte string literal not displayed */
}

func (*Message_DownstreamResumeResponse) MarshalTo 

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

func (*Message_DownstreamResumeResponse) MarshalToSizedBuffer 

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

func (*Message_DownstreamResumeResponse) Size 

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

type Message_Ping 

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

func (*Message_Ping) MarshalTo 

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

func (*Message_Ping) MarshalToSizedBuffer 

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

func (*Message_Ping) Size 

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

type Message_Pong 

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

func (*Message_Pong) MarshalTo 

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

func (*Message_Pong) MarshalToSizedBuffer 

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

func (*Message_Pong) Size 

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

type Message_UpstreamCall 

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

func (*Message_UpstreamCall) MarshalTo 

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

func (*Message_UpstreamCall) MarshalToSizedBuffer 

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

func (*Message_UpstreamCall) Size 

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

type Message_UpstreamCallAck 

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

func (*Message_UpstreamCallAck) MarshalTo 

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

func (*Message_UpstreamCallAck) MarshalToSizedBuffer 

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

func (*Message_UpstreamCallAck) Size 

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

type Message_UpstreamChunk 

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

func (*Message_UpstreamChunk) MarshalTo 

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

func (*Message_UpstreamChunk) MarshalToSizedBuffer 

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

func (*Message_UpstreamChunk) Size 

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

type Message_UpstreamChunkAck 

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

func (*Message_UpstreamChunkAck) MarshalTo 

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

func (*Message_UpstreamChunkAck) MarshalToSizedBuffer 

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

func (*Message_UpstreamChunkAck) Size 

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

type Message_UpstreamCloseRequest 

type Message_UpstreamCloseRequest struct {
	UpstreamCloseRequest *UpstreamCloseRequest `` /* 130-byte string literal not displayed */
}

func (*Message_UpstreamCloseRequest) MarshalTo 

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

func (*Message_UpstreamCloseRequest) MarshalToSizedBuffer 

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

func (*Message_UpstreamCloseRequest) Size 

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

type Message_UpstreamCloseResponse 

type Message_UpstreamCloseResponse struct {
	UpstreamCloseResponse *UpstreamCloseResponse `` /* 133-byte string literal not displayed */
}

func (*Message_UpstreamCloseResponse) MarshalTo 

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

func (*Message_UpstreamCloseResponse) MarshalToSizedBuffer 

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

func (*Message_UpstreamCloseResponse) Size 

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

type Message_UpstreamMetadata 

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

func (*Message_UpstreamMetadata) MarshalTo 

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

func (*Message_UpstreamMetadata) MarshalToSizedBuffer 

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

func (*Message_UpstreamMetadata) Size 

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

type Message_UpstreamMetadataAck 

type Message_UpstreamMetadataAck struct {
	UpstreamMetadataAck *UpstreamMetadataAck `` /* 127-byte string literal not displayed */
}

func (*Message_UpstreamMetadataAck) MarshalTo 

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

func (*Message_UpstreamMetadataAck) MarshalToSizedBuffer 

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

func (*Message_UpstreamMetadataAck) Size 

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

type Message_UpstreamOpenRequest 

type Message_UpstreamOpenRequest struct {
	UpstreamOpenRequest *UpstreamOpenRequest `` /* 127-byte string literal not displayed */
}

func (*Message_UpstreamOpenRequest) MarshalTo 

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

func (*Message_UpstreamOpenRequest) MarshalToSizedBuffer 

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

func (*Message_UpstreamOpenRequest) Size 

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

type Message_UpstreamOpenResponse 

type Message_UpstreamOpenResponse struct {
	UpstreamOpenResponse *UpstreamOpenResponse `` /* 130-byte string literal not displayed */
}

func (*Message_UpstreamOpenResponse) MarshalTo 

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

func (*Message_UpstreamOpenResponse) MarshalToSizedBuffer 

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

func (*Message_UpstreamOpenResponse) Size 

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

type Message_UpstreamResumeRequest 

type Message_UpstreamResumeRequest struct {
	UpstreamResumeRequest *UpstreamResumeRequest `` /* 133-byte string literal not displayed */
}

func (*Message_UpstreamResumeRequest) MarshalTo 

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

func (*Message_UpstreamResumeRequest) MarshalToSizedBuffer 

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

func (*Message_UpstreamResumeRequest) Size 

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

type Message_UpstreamResumeResponse 

type Message_UpstreamResumeResponse struct {
	UpstreamResumeResponse *UpstreamResumeResponse `` /* 136-byte string literal not displayed */
}

func (*Message_UpstreamResumeResponse) MarshalTo 

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

func (*Message_UpstreamResumeResponse) MarshalToSizedBuffer 

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

func (*Message_UpstreamResumeResponse) Size 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*Ping) Descriptor 

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

func (*Ping) GetExtensionFields 

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

func (*Ping) GetRequestId 

func (m *Ping) GetRequestId() uint32

func (*Ping) Marshal 

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

func (*Ping) MarshalTo 

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

func (*Ping) MarshalToSizedBuffer 

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

func (*Ping) ProtoMessage 

func (*Ping) ProtoMessage()

func (*Ping) Reset 

func (m *Ping) Reset()

func (*Ping) Size 

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

func (*Ping) String 

func (m *Ping) String() string

func (*Ping) Unmarshal 

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

func (*Ping) XXX_DiscardUnknown 

func (m *Ping) XXX_DiscardUnknown()

func (*Ping) XXX_Marshal 

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

func (*Ping) XXX_Merge 

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

func (*Ping) XXX_Size 

func (m *Ping) XXX_Size() int

func (*Ping) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*Pong) Descriptor 

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

func (*Pong) GetExtensionFields 

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

func (*Pong) GetRequestId 

func (m *Pong) GetRequestId() uint32

func (*Pong) Marshal 

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

func (*Pong) MarshalTo 

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

func (*Pong) MarshalToSizedBuffer 

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

func (*Pong) ProtoMessage 

func (*Pong) ProtoMessage()

func (*Pong) Reset 

func (m *Pong) Reset()

func (*Pong) Size 

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

func (*Pong) String 

func (m *Pong) String() string

func (*Pong) Unmarshal 

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

func (*Pong) XXX_DiscardUnknown 

func (m *Pong) XXX_DiscardUnknown()

func (*Pong) XXX_Marshal 

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

func (*Pong) XXX_Merge 

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

func (*Pong) XXX_Size 

func (m *Pong) XXX_Size() int

func (*Pong) XXX_Unmarshal 

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

type QoS 

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

func (QoS) EnumDescriptor 

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

func (QoS) String 

func (x QoS) String() string

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

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

func (ResultCode) String 

func (x ResultCode) String() string

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"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*StreamChunk) Descriptor 

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

func (*StreamChunk) GetDataPointGroups 

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

func (*StreamChunk) GetSequenceNumber 

func (m *StreamChunk) GetSequenceNumber() uint32

func (*StreamChunk) Marshal 

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

func (*StreamChunk) MarshalTo 

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

func (*StreamChunk) MarshalToSizedBuffer 

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

func (*StreamChunk) ProtoMessage 

func (*StreamChunk) ProtoMessage()

func (*StreamChunk) Reset 

func (m *StreamChunk) Reset()

func (*StreamChunk) Size 

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

func (*StreamChunk) String 

func (m *StreamChunk) String() string

func (*StreamChunk) Unmarshal 

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

func (*StreamChunk) XXX_DiscardUnknown 

func (m *StreamChunk) XXX_DiscardUnknown()

func (*StreamChunk) XXX_Marshal 

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

func (*StreamChunk) XXX_Merge 

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

func (*StreamChunk) XXX_Size 

func (m *StreamChunk) XXX_Size() int

func (*StreamChunk) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpstreamAbnormalClose) Descriptor 

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

func (*UpstreamAbnormalClose) GetSessionId 

func (m *UpstreamAbnormalClose) GetSessionId() string

func (*UpstreamAbnormalClose) GetStreamId 

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

func (*UpstreamAbnormalClose) Marshal 

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

func (*UpstreamAbnormalClose) MarshalTo 

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

func (*UpstreamAbnormalClose) MarshalToSizedBuffer 

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

func (*UpstreamAbnormalClose) ProtoMessage 

func (*UpstreamAbnormalClose) ProtoMessage()

func (*UpstreamAbnormalClose) Reset 

func (m *UpstreamAbnormalClose) Reset()

func (*UpstreamAbnormalClose) Size 

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

func (*UpstreamAbnormalClose) String 

func (m *UpstreamAbnormalClose) String() string

func (*UpstreamAbnormalClose) Unmarshal 

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

func (*UpstreamAbnormalClose) XXX_DiscardUnknown 

func (m *UpstreamAbnormalClose) XXX_DiscardUnknown()

func (*UpstreamAbnormalClose) XXX_Marshal 

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

func (*UpstreamAbnormalClose) XXX_Merge 

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

func (*UpstreamAbnormalClose) XXX_Size 

func (m *UpstreamAbnormalClose) XXX_Size() int

func (*UpstreamAbnormalClose) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                                `json:"-"`
	XXX_unrecognized     []byte                                  `json:"-"`
	XXX_sizecache        int32                                   `json:"-"`
}

func (*UpstreamCall) Descriptor 

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

func (*UpstreamCall) GetCallId 

func (m *UpstreamCall) GetCallId() string

func (*UpstreamCall) GetDestinationNodeId 

func (m *UpstreamCall) GetDestinationNodeId() string

func (*UpstreamCall) GetExtensionFields 

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

func (*UpstreamCall) GetName 

func (m *UpstreamCall) GetName() string

func (*UpstreamCall) GetPayload 

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

func (*UpstreamCall) GetRequestCallId 

func (m *UpstreamCall) GetRequestCallId() string

func (*UpstreamCall) GetType 

func (m *UpstreamCall) GetType() string

func (*UpstreamCall) Marshal 

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

func (*UpstreamCall) MarshalTo 

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

func (*UpstreamCall) MarshalToSizedBuffer 

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

func (*UpstreamCall) ProtoMessage 

func (*UpstreamCall) ProtoMessage()

func (*UpstreamCall) Reset 

func (m *UpstreamCall) Reset()

func (*UpstreamCall) Size 

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

func (*UpstreamCall) String 

func (m *UpstreamCall) String() string

func (*UpstreamCall) Unmarshal 

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

func (*UpstreamCall) XXX_DiscardUnknown 

func (m *UpstreamCall) XXX_DiscardUnknown()

func (*UpstreamCall) XXX_Marshal 

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

func (*UpstreamCall) XXX_Merge 

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

func (*UpstreamCall) XXX_Size 

func (m *UpstreamCall) XXX_Size() int

func (*UpstreamCall) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                                   `json:"-"`
	XXX_unrecognized     []byte                                     `json:"-"`
	XXX_sizecache        int32                                      `json:"-"`
}

func (*UpstreamCallAck) Descriptor 

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

func (*UpstreamCallAck) GetCallId 

func (m *UpstreamCallAck) GetCallId() string

func (*UpstreamCallAck) GetExtensionFields 

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

func (*UpstreamCallAck) GetResultCode 

func (m *UpstreamCallAck) GetResultCode() ResultCode

func (*UpstreamCallAck) GetResultString 

func (m *UpstreamCallAck) GetResultString() string

func (*UpstreamCallAck) Marshal 

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

func (*UpstreamCallAck) MarshalTo 

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

func (*UpstreamCallAck) MarshalToSizedBuffer 

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

func (*UpstreamCallAck) ProtoMessage 

func (*UpstreamCallAck) ProtoMessage()

func (*UpstreamCallAck) Reset 

func (m *UpstreamCallAck) Reset()

func (*UpstreamCallAck) Size 

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

func (*UpstreamCallAck) String 

func (m *UpstreamCallAck) String() string

func (*UpstreamCallAck) Unmarshal 

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

func (*UpstreamCallAck) XXX_DiscardUnknown 

func (m *UpstreamCallAck) XXX_DiscardUnknown()

func (*UpstreamCallAck) XXX_Marshal 

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

func (*UpstreamCallAck) XXX_Merge 

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

func (*UpstreamCallAck) XXX_Size 

func (m *UpstreamCallAck) XXX_Size() int

func (*UpstreamCallAck) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                                 `json:"-"`
	XXX_unrecognized     []byte                                   `json:"-"`
	XXX_sizecache        int32                                    `json:"-"`
}

func (*UpstreamChunk) Descriptor 

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

func (*UpstreamChunk) GetDataIds 

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

func (*UpstreamChunk) GetExtensionFields 

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

func (*UpstreamChunk) GetStreamChunk 

func (m *UpstreamChunk) GetStreamChunk() *StreamChunk

func (*UpstreamChunk) GetStreamIdAlias 

func (m *UpstreamChunk) GetStreamIdAlias() uint32

func (*UpstreamChunk) Marshal 

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

func (*UpstreamChunk) MarshalTo 

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

func (*UpstreamChunk) MarshalToSizedBuffer 

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

func (*UpstreamChunk) ProtoMessage 

func (*UpstreamChunk) ProtoMessage()

func (*UpstreamChunk) Reset 

func (m *UpstreamChunk) Reset()

func (*UpstreamChunk) Size 

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

func (*UpstreamChunk) String 

func (m *UpstreamChunk) String() string

func (*UpstreamChunk) Unmarshal 

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

func (*UpstreamChunk) XXX_DiscardUnknown 

func (m *UpstreamChunk) XXX_DiscardUnknown()

func (*UpstreamChunk) XXX_Marshal 

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

func (*UpstreamChunk) XXX_Merge 

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

func (*UpstreamChunk) XXX_Size 

func (m *UpstreamChunk) XXX_Size() int

func (*UpstreamChunk) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

func (*UpstreamChunkAck) Descriptor 

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

func (*UpstreamChunkAck) GetDataIdAliases 

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

func (*UpstreamChunkAck) GetExtensionFields 

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

func (*UpstreamChunkAck) GetResults 

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

func (*UpstreamChunkAck) GetStreamIdAlias 

func (m *UpstreamChunkAck) GetStreamIdAlias() uint32

func (*UpstreamChunkAck) Marshal 

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

func (*UpstreamChunkAck) MarshalTo 

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

func (*UpstreamChunkAck) MarshalToSizedBuffer 

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

func (*UpstreamChunkAck) ProtoMessage 

func (*UpstreamChunkAck) ProtoMessage()

func (*UpstreamChunkAck) Reset 

func (m *UpstreamChunkAck) Reset()

func (*UpstreamChunkAck) Size 

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

func (*UpstreamChunkAck) String 

func (m *UpstreamChunkAck) String() string

func (*UpstreamChunkAck) Unmarshal 

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

func (*UpstreamChunkAck) XXX_DiscardUnknown 

func (m *UpstreamChunkAck) XXX_DiscardUnknown()

func (*UpstreamChunkAck) XXX_Marshal 

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

func (*UpstreamChunkAck) XXX_Merge 

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

func (*UpstreamChunkAck) XXX_Size 

func (m *UpstreamChunkAck) XXX_Size() int

func (*UpstreamChunkAck) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                                       `json:"-"`
	XXX_unrecognized     []byte                                         `json:"-"`
	XXX_sizecache        int32                                          `json:"-"`
}

func (*UpstreamChunkResult) Descriptor 

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

func (*UpstreamChunkResult) GetExtensionFields 

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

func (*UpstreamChunkResult) GetResultCode 

func (m *UpstreamChunkResult) GetResultCode() ResultCode

func (*UpstreamChunkResult) GetResultString 

func (m *UpstreamChunkResult) GetResultString() string

func (*UpstreamChunkResult) GetSequenceNumber 

func (m *UpstreamChunkResult) GetSequenceNumber() uint32

func (*UpstreamChunkResult) Marshal 

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

func (*UpstreamChunkResult) MarshalTo 

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

func (*UpstreamChunkResult) MarshalToSizedBuffer 

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

func (*UpstreamChunkResult) ProtoMessage 

func (*UpstreamChunkResult) ProtoMessage()

func (*UpstreamChunkResult) Reset 

func (m *UpstreamChunkResult) Reset()

func (*UpstreamChunkResult) Size 

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

func (*UpstreamChunkResult) String 

func (m *UpstreamChunkResult) String() string

func (*UpstreamChunkResult) Unmarshal 

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

func (*UpstreamChunkResult) XXX_DiscardUnknown 

func (m *UpstreamChunkResult) XXX_DiscardUnknown()

func (*UpstreamChunkResult) XXX_Marshal 

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

func (*UpstreamChunkResult) XXX_Merge 

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

func (*UpstreamChunkResult) XXX_Size 

func (m *UpstreamChunkResult) XXX_Size() int

func (*UpstreamChunkResult) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                                        `json:"-"`
	XXX_unrecognized     []byte                                          `json:"-"`
	XXX_sizecache        int32                                           `json:"-"`
}

func (*UpstreamCloseRequest) Descriptor 

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

func (*UpstreamCloseRequest) GetExtensionFields 

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

func (*UpstreamCloseRequest) GetFinalSequenceNumber 

func (m *UpstreamCloseRequest) GetFinalSequenceNumber() uint32

func (*UpstreamCloseRequest) GetRequestId 

func (m *UpstreamCloseRequest) GetRequestId() uint32

func (*UpstreamCloseRequest) GetStreamId 

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

func (*UpstreamCloseRequest) GetTotalDataPoints 

func (m *UpstreamCloseRequest) GetTotalDataPoints() uint64

func (*UpstreamCloseRequest) Marshal 

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

func (*UpstreamCloseRequest) MarshalTo 

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

func (*UpstreamCloseRequest) MarshalToSizedBuffer 

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

func (*UpstreamCloseRequest) ProtoMessage 

func (*UpstreamCloseRequest) ProtoMessage()

func (*UpstreamCloseRequest) Reset 

func (m *UpstreamCloseRequest) Reset()

func (*UpstreamCloseRequest) Size 

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

func (*UpstreamCloseRequest) String 

func (m *UpstreamCloseRequest) String() string

func (*UpstreamCloseRequest) Unmarshal 

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

func (*UpstreamCloseRequest) XXX_DiscardUnknown 

func (m *UpstreamCloseRequest) XXX_DiscardUnknown()

func (*UpstreamCloseRequest) XXX_Marshal 

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

func (*UpstreamCloseRequest) XXX_Merge 

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

func (*UpstreamCloseRequest) XXX_Size 

func (m *UpstreamCloseRequest) XXX_Size() int

func (*UpstreamCloseRequest) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                                         `json:"-"`
	XXX_unrecognized     []byte                                           `json:"-"`
	XXX_sizecache        int32                                            `json:"-"`
}

func (*UpstreamCloseResponse) Descriptor 

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

func (*UpstreamCloseResponse) GetExtensionFields 

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

func (*UpstreamCloseResponse) GetRequestId 

func (m *UpstreamCloseResponse) GetRequestId() uint32

func (*UpstreamCloseResponse) GetResultCode 

func (m *UpstreamCloseResponse) GetResultCode() ResultCode

func (*UpstreamCloseResponse) GetResultString 

func (m *UpstreamCloseResponse) GetResultString() string

func (*UpstreamCloseResponse) Marshal 

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

func (*UpstreamCloseResponse) MarshalTo 

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

func (*UpstreamCloseResponse) MarshalToSizedBuffer 

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

func (*UpstreamCloseResponse) ProtoMessage 

func (*UpstreamCloseResponse) ProtoMessage()

func (*UpstreamCloseResponse) Reset 

func (m *UpstreamCloseResponse) Reset()

func (*UpstreamCloseResponse) Size 

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

func (*UpstreamCloseResponse) String 

func (m *UpstreamCloseResponse) String() string

func (*UpstreamCloseResponse) Unmarshal 

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

func (*UpstreamCloseResponse) XXX_DiscardUnknown 

func (m *UpstreamCloseResponse) XXX_DiscardUnknown()

func (*UpstreamCloseResponse) XXX_Marshal 

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

func (*UpstreamCloseResponse) XXX_Merge 

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

func (*UpstreamCloseResponse) XXX_Size 

func (m *UpstreamCloseResponse) XXX_Size() int

func (*UpstreamCloseResponse) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpstreamInfo) Descriptor 

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

func (*UpstreamInfo) GetSessionId 

func (m *UpstreamInfo) GetSessionId() string

func (*UpstreamInfo) GetSourceNodeId 

func (m *UpstreamInfo) GetSourceNodeId() string

func (*UpstreamInfo) GetStreamId 

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

func (*UpstreamInfo) Marshal 

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

func (*UpstreamInfo) MarshalTo 

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

func (*UpstreamInfo) MarshalToSizedBuffer 

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

func (*UpstreamInfo) ProtoMessage 

func (*UpstreamInfo) ProtoMessage()

func (*UpstreamInfo) Reset 

func (m *UpstreamInfo) Reset()

func (*UpstreamInfo) Size 

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

func (*UpstreamInfo) String 

func (m *UpstreamInfo) String() string

func (*UpstreamInfo) Unmarshal 

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

func (*UpstreamInfo) XXX_DiscardUnknown 

func (m *UpstreamInfo) XXX_DiscardUnknown()

func (*UpstreamInfo) XXX_Marshal 

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

func (*UpstreamInfo) XXX_Merge 

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

func (*UpstreamInfo) XXX_Size 

func (m *UpstreamInfo) XXX_Size() int

func (*UpstreamInfo) XXX_Unmarshal 

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

type UpstreamMetadata 

type UpstreamMetadata struct {
	RequestId uint32 `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Types that are valid to be assigned 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"`
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

func (*UpstreamMetadata) Descriptor 

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

func (*UpstreamMetadata) GetBaseTime 

func (m *UpstreamMetadata) GetBaseTime() *BaseTime

func (*UpstreamMetadata) GetExtensionFields 

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

func (*UpstreamMetadata) GetMetadata 

func (m *UpstreamMetadata) GetMetadata() isUpstreamMetadata_Metadata

func (*UpstreamMetadata) GetRequestId 

func (m *UpstreamMetadata) GetRequestId() uint32

func (*UpstreamMetadata) Marshal 

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

func (*UpstreamMetadata) MarshalTo 

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

func (*UpstreamMetadata) MarshalToSizedBuffer 

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

func (*UpstreamMetadata) ProtoMessage 

func (*UpstreamMetadata) ProtoMessage()

func (*UpstreamMetadata) Reset 

func (m *UpstreamMetadata) Reset()

func (*UpstreamMetadata) Size 

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

func (*UpstreamMetadata) String 

func (m *UpstreamMetadata) String() string

func (*UpstreamMetadata) Unmarshal 

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

func (*UpstreamMetadata) XXX_DiscardUnknown 

func (m *UpstreamMetadata) XXX_DiscardUnknown()

func (*UpstreamMetadata) XXX_Marshal 

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

func (*UpstreamMetadata) XXX_Merge 

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

func (*UpstreamMetadata) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*UpstreamMetadata) XXX_Size 

func (m *UpstreamMetadata) XXX_Size() int

func (*UpstreamMetadata) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                                       `json:"-"`
	XXX_unrecognized     []byte                                         `json:"-"`
	XXX_sizecache        int32                                          `json:"-"`
}

func (*UpstreamMetadataAck) Descriptor 

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

func (*UpstreamMetadataAck) GetExtensionFields 

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

func (*UpstreamMetadataAck) GetRequestId 

func (m *UpstreamMetadataAck) GetRequestId() uint32

func (*UpstreamMetadataAck) GetResultCode 

func (m *UpstreamMetadataAck) GetResultCode() ResultCode

func (*UpstreamMetadataAck) GetResultString 

func (m *UpstreamMetadataAck) GetResultString() string

func (*UpstreamMetadataAck) Marshal 

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

func (*UpstreamMetadataAck) MarshalTo 

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

func (*UpstreamMetadataAck) MarshalToSizedBuffer 

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

func (*UpstreamMetadataAck) ProtoMessage 

func (*UpstreamMetadataAck) ProtoMessage()

func (*UpstreamMetadataAck) Reset 

func (m *UpstreamMetadataAck) Reset()

func (*UpstreamMetadataAck) Size 

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

func (*UpstreamMetadataAck) String 

func (m *UpstreamMetadataAck) String() string

func (*UpstreamMetadataAck) Unmarshal 

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

func (*UpstreamMetadataAck) XXX_DiscardUnknown 

func (m *UpstreamMetadataAck) XXX_DiscardUnknown()

func (*UpstreamMetadataAck) XXX_Marshal 

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

func (*UpstreamMetadataAck) XXX_Merge 

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

func (*UpstreamMetadataAck) XXX_Size 

func (m *UpstreamMetadataAck) XXX_Size() int

func (*UpstreamMetadataAck) XXX_Unmarshal 

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

type UpstreamMetadata_BaseTime 

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

func (*UpstreamMetadata_BaseTime) MarshalTo 

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

func (*UpstreamMetadata_BaseTime) MarshalToSizedBuffer 

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

func (*UpstreamMetadata_BaseTime) Size 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpstreamNormalClose) Descriptor 

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

func (*UpstreamNormalClose) GetFinalSequenceNumber 

func (m *UpstreamNormalClose) GetFinalSequenceNumber() uint32

func (*UpstreamNormalClose) GetSessionId 

func (m *UpstreamNormalClose) GetSessionId() string

func (*UpstreamNormalClose) GetStreamId 

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

func (*UpstreamNormalClose) GetTotalDataPoints 

func (m *UpstreamNormalClose) GetTotalDataPoints() uint64

func (*UpstreamNormalClose) Marshal 

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

func (*UpstreamNormalClose) MarshalTo 

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

func (*UpstreamNormalClose) MarshalToSizedBuffer 

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

func (*UpstreamNormalClose) ProtoMessage 

func (*UpstreamNormalClose) ProtoMessage()

func (*UpstreamNormalClose) Reset 

func (m *UpstreamNormalClose) Reset()

func (*UpstreamNormalClose) Size 

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

func (*UpstreamNormalClose) String 

func (m *UpstreamNormalClose) String() string

func (*UpstreamNormalClose) Unmarshal 

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

func (*UpstreamNormalClose) XXX_DiscardUnknown 

func (m *UpstreamNormalClose) XXX_DiscardUnknown()

func (*UpstreamNormalClose) XXX_Marshal 

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

func (*UpstreamNormalClose) XXX_Merge 

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

func (*UpstreamNormalClose) XXX_Size 

func (m *UpstreamNormalClose) XXX_Size() int

func (*UpstreamNormalClose) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpstreamOpen) Descriptor 

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

func (*UpstreamOpen) GetQos 

func (m *UpstreamOpen) GetQos() QoS

func (*UpstreamOpen) GetSessionId 

func (m *UpstreamOpen) GetSessionId() string

func (*UpstreamOpen) GetStreamId 

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

func (*UpstreamOpen) Marshal 

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

func (*UpstreamOpen) MarshalTo 

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

func (*UpstreamOpen) MarshalToSizedBuffer 

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

func (*UpstreamOpen) ProtoMessage 

func (*UpstreamOpen) ProtoMessage()

func (*UpstreamOpen) Reset 

func (m *UpstreamOpen) Reset()

func (*UpstreamOpen) Size 

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

func (*UpstreamOpen) String 

func (m *UpstreamOpen) String() string

func (*UpstreamOpen) Unmarshal 

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

func (*UpstreamOpen) XXX_DiscardUnknown 

func (m *UpstreamOpen) XXX_DiscardUnknown()

func (*UpstreamOpen) XXX_Marshal 

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

func (*UpstreamOpen) XXX_Merge 

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

func (*UpstreamOpen) XXX_Size 

func (m *UpstreamOpen) XXX_Size() int

func (*UpstreamOpen) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                                       `json:"-"`
	XXX_unrecognized     []byte                                         `json:"-"`
	XXX_sizecache        int32                                          `json:"-"`
}

func (*UpstreamOpenRequest) Descriptor 

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

func (*UpstreamOpenRequest) GetAckInterval 

func (m *UpstreamOpenRequest) GetAckInterval() uint32

func (*UpstreamOpenRequest) GetDataIds 

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

func (*UpstreamOpenRequest) GetExpiryInterval 

func (m *UpstreamOpenRequest) GetExpiryInterval() uint32

func (*UpstreamOpenRequest) GetExtensionFields 

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

func (*UpstreamOpenRequest) GetQos 

func (m *UpstreamOpenRequest) GetQos() QoS

func (*UpstreamOpenRequest) GetRequestId 

func (m *UpstreamOpenRequest) GetRequestId() uint32

func (*UpstreamOpenRequest) GetSessionId 

func (m *UpstreamOpenRequest) GetSessionId() string

func (*UpstreamOpenRequest) Marshal 

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

func (*UpstreamOpenRequest) MarshalTo 

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

func (*UpstreamOpenRequest) MarshalToSizedBuffer 

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

func (*UpstreamOpenRequest) ProtoMessage 

func (*UpstreamOpenRequest) ProtoMessage()

func (*UpstreamOpenRequest) Reset 

func (m *UpstreamOpenRequest) Reset()

func (*UpstreamOpenRequest) Size 

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

func (*UpstreamOpenRequest) String 

func (m *UpstreamOpenRequest) String() string

func (*UpstreamOpenRequest) Unmarshal 

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

func (*UpstreamOpenRequest) XXX_DiscardUnknown 

func (m *UpstreamOpenRequest) XXX_DiscardUnknown()

func (*UpstreamOpenRequest) XXX_Marshal 

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

func (*UpstreamOpenRequest) XXX_Merge 

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

func (*UpstreamOpenRequest) XXX_Size 

func (m *UpstreamOpenRequest) XXX_Size() int

func (*UpstreamOpenRequest) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral  struct{}                                        `json:"-"`
	XXX_unrecognized      []byte                                          `json:"-"`
	XXX_sizecache         int32                                           `json:"-"`
}

func (*UpstreamOpenResponse) Descriptor 

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

func (*UpstreamOpenResponse) GetAssignedStreamId 

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

func (*UpstreamOpenResponse) GetAssignedStreamIdAlias 

func (m *UpstreamOpenResponse) GetAssignedStreamIdAlias() uint32

func (*UpstreamOpenResponse) GetDataIdAliases 

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

func (*UpstreamOpenResponse) GetExtensionFields 

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

func (*UpstreamOpenResponse) GetRequestId 

func (m *UpstreamOpenResponse) GetRequestId() uint32

func (*UpstreamOpenResponse) GetResultCode 

func (m *UpstreamOpenResponse) GetResultCode() ResultCode

func (*UpstreamOpenResponse) GetResultString 

func (m *UpstreamOpenResponse) GetResultString() string

func (*UpstreamOpenResponse) GetServerTime 

func (m *UpstreamOpenResponse) GetServerTime() int64

func (*UpstreamOpenResponse) Marshal 

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

func (*UpstreamOpenResponse) MarshalTo 

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

func (*UpstreamOpenResponse) MarshalToSizedBuffer 

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

func (*UpstreamOpenResponse) ProtoMessage 

func (*UpstreamOpenResponse) ProtoMessage()

func (*UpstreamOpenResponse) Reset 

func (m *UpstreamOpenResponse) Reset()

func (*UpstreamOpenResponse) Size 

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

func (*UpstreamOpenResponse) String 

func (m *UpstreamOpenResponse) String() string

func (*UpstreamOpenResponse) Unmarshal 

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

func (*UpstreamOpenResponse) XXX_DiscardUnknown 

func (m *UpstreamOpenResponse) XXX_DiscardUnknown()

func (*UpstreamOpenResponse) XXX_Marshal 

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

func (*UpstreamOpenResponse) XXX_Merge 

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

func (*UpstreamOpenResponse) XXX_Size 

func (m *UpstreamOpenResponse) XXX_Size() int

func (*UpstreamOpenResponse) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpstreamResume) Descriptor 

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

func (*UpstreamResume) GetQos 

func (m *UpstreamResume) GetQos() QoS

func (*UpstreamResume) GetSessionId 

func (m *UpstreamResume) GetSessionId() string

func (*UpstreamResume) GetStreamId 

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

func (*UpstreamResume) Marshal 

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

func (*UpstreamResume) MarshalTo 

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

func (*UpstreamResume) MarshalToSizedBuffer 

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

func (*UpstreamResume) ProtoMessage 

func (*UpstreamResume) ProtoMessage()

func (*UpstreamResume) Reset 

func (m *UpstreamResume) Reset()

func (*UpstreamResume) Size 

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

func (*UpstreamResume) String 

func (m *UpstreamResume) String() string

func (*UpstreamResume) Unmarshal 

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

func (*UpstreamResume) XXX_DiscardUnknown 

func (m *UpstreamResume) XXX_DiscardUnknown()

func (*UpstreamResume) XXX_Marshal 

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

func (*UpstreamResume) XXX_Merge 

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

func (*UpstreamResume) XXX_Size 

func (m *UpstreamResume) XXX_Size() int

func (*UpstreamResume) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                                         `json:"-"`
	XXX_unrecognized     []byte                                           `json:"-"`
	XXX_sizecache        int32                                            `json:"-"`
}

func (*UpstreamResumeRequest) Descriptor 

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

func (*UpstreamResumeRequest) GetExtensionFields 

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

func (*UpstreamResumeRequest) GetRequestId 

func (m *UpstreamResumeRequest) GetRequestId() uint32

func (*UpstreamResumeRequest) GetStreamId 

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

func (*UpstreamResumeRequest) Marshal 

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

func (*UpstreamResumeRequest) MarshalTo 

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

func (*UpstreamResumeRequest) MarshalToSizedBuffer 

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

func (*UpstreamResumeRequest) ProtoMessage 

func (*UpstreamResumeRequest) ProtoMessage()

func (*UpstreamResumeRequest) Reset 

func (m *UpstreamResumeRequest) Reset()

func (*UpstreamResumeRequest) Size 

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

func (*UpstreamResumeRequest) String 

func (m *UpstreamResumeRequest) String() string

func (*UpstreamResumeRequest) Unmarshal 

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

func (*UpstreamResumeRequest) XXX_DiscardUnknown 

func (m *UpstreamResumeRequest) XXX_DiscardUnknown()

func (*UpstreamResumeRequest) XXX_Marshal 

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

func (*UpstreamResumeRequest) XXX_Merge 

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

func (*UpstreamResumeRequest) XXX_Size 

func (m *UpstreamResumeRequest) XXX_Size() int

func (*UpstreamResumeRequest) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral  struct{}                                          `json:"-"`
	XXX_unrecognized      []byte                                            `json:"-"`
	XXX_sizecache         int32                                             `json:"-"`
}

func (*UpstreamResumeResponse) Descriptor 

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

func (*UpstreamResumeResponse) GetAssignedStreamIdAlias 

func (m *UpstreamResumeResponse) GetAssignedStreamIdAlias() uint32

func (*UpstreamResumeResponse) GetExtensionFields 

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

func (*UpstreamResumeResponse) GetRequestId 

func (m *UpstreamResumeResponse) GetRequestId() uint32

func (*UpstreamResumeResponse) GetResultCode 

func (m *UpstreamResumeResponse) GetResultCode() ResultCode

func (*UpstreamResumeResponse) GetResultString 

func (m *UpstreamResumeResponse) GetResultString() string

func (*UpstreamResumeResponse) Marshal 

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

func (*UpstreamResumeResponse) MarshalTo 

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

func (*UpstreamResumeResponse) MarshalToSizedBuffer 

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

func (*UpstreamResumeResponse) ProtoMessage 

func (*UpstreamResumeResponse) ProtoMessage()

func (*UpstreamResumeResponse) Reset 

func (m *UpstreamResumeResponse) Reset()

func (*UpstreamResumeResponse) Size 

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

func (*UpstreamResumeResponse) String 

func (m *UpstreamResumeResponse) String() string

func (*UpstreamResumeResponse) Unmarshal 

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

func (*UpstreamResumeResponse) XXX_DiscardUnknown 

func (m *UpstreamResumeResponse) XXX_DiscardUnknown()

func (*UpstreamResumeResponse) XXX_Marshal 

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

func (*UpstreamResumeResponse) XXX_Merge 

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

func (*UpstreamResumeResponse) XXX_Size 

func (m *UpstreamResumeResponse) XXX_Size() int

func (*UpstreamResumeResponse) XXX_Unmarshal 

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

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.