protocolv1

type CauseError struct {
	ServiceId string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	Message   string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type ConnectMessage struct {

	// Известные параметры
	// "connect.timeout" = 2000
	Params map[string]*Param `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ConnectMessageAck struct {
	// contains filtered or unexported fields
}

type DisconnectMessage struct {
	Params map[string]*Param `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Endpoint struct {
	Service string            `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Version int32             `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	Id      int32             `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"`
	Format  int32             `protobuf:"varint,4,opt,name=format,proto3" json:"format,omitempty"`
	Params  map[string]*Param `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

type EndpointClose struct {
	// contains filtered or unexported fields
}

type EndpointDataMessage struct {
	Type  v1.MessageType `protobuf:"varint,1,opt,name=type,proto3,enum=ras.messages.v1.MessageType" json:"type,omitempty"`
	Bytes []byte         `protobuf:"bytes,2,opt,name=bytes,proto3" json:"bytes,omitempty"`
	// contains filtered or unexported fields
}

type EndpointDataType int32

type EndpointDataVoidMessage struct {
	// contains filtered or unexported fields
}

type EndpointFailureAck struct {
	ServiceId  string      `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	Version    string      `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	EndpointId int32       `protobuf:"varint,3,opt,name=endpoint_id,json=endpointId,proto3" json:"endpoint_id,omitempty"`
	ClassCause string      `protobuf:"bytes,4,opt,name=class_cause,json=classCause,proto3" json:"class_cause,omitempty"`
	Message    string      `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	Trace      []string    `protobuf:"bytes,6,rep,name=trace,proto3" json:"trace,omitempty"`
	Cause      *CauseError `protobuf:"bytes,7,opt,name=cause,proto3" json:"cause,omitempty"`
	// contains filtered or unexported fields
}

type EndpointFailureMessage struct {
	ServiceId string      `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	Message   string      `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Cause     *CauseError `protobuf:"bytes,3,opt,name=cause,proto3" json:"cause,omitempty"`
	// contains filtered or unexported fields
}

type EndpointImpl interface {
	GetVersion() int32
	GetId() int32
	GetService() string
	GetFormat() int32
	NewMessage(data interface{}) (*EndpointMessage, error)
	UnpackMessage(data interface{}, into EndpointMessageParser) error
}

type EndpointMessage struct {
	EndpointId int32            `protobuf:"varint,1,opt,name=endpoint_id,json=endpointId,proto3" json:"endpoint_id,omitempty"`
	Format     int32            `protobuf:"varint,2,opt,name=format,proto3" json:"format,omitempty"`
	Type       EndpointDataType `protobuf:"varint,3,opt,name=type,proto3,enum=ras.protocol.v1.EndpointDataType" json:"type,omitempty"`
	// Types that are assignable to Data:
	//	*EndpointMessage_VoidMessage
	//	*EndpointMessage_Message
	//	*EndpointMessage_Failure
	Data isEndpointMessage_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

type EndpointMessageFormatter interface {
	GetMessageType() v1.MessageType
	Formatter(writer io.Writer, version int32) error
}

type EndpointMessageParser interface {
	GetMessageType() v1.MessageType
	Parse(reader io.Reader, version int32) error
}

type EndpointMessage_Failure struct {
	Failure *EndpointFailureMessage `protobuf:"bytes,6,opt,name=failure,proto3,oneof"`
}

type EndpointMessage_Message struct {
	Message *EndpointDataMessage `protobuf:"bytes,5,opt,name=message,proto3,oneof"`
}

type EndpointMessage_VoidMessage struct {
	VoidMessage *EndpointDataVoidMessage `protobuf:"bytes,4,opt,name=void_message,json=voidMessage,proto3,oneof"`
}

type EndpointOpen struct {
	Service string            `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Version string            `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Params  map[string]*Param `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

type EndpointOpenAck struct {
	Service    string            `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Version    string            `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	EndpointId int32             `protobuf:"varint,3,opt,name=endpoint_id,json=endpointId,proto3" json:"endpoint_id,omitempty"`
	Params     map[string]*Param `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

type NegotiateMessage struct {
	Magic    int32 `protobuf:"varint,1,opt,name=magic,proto3" json:"magic,omitempty"` // Use only one value `475223888`
	Protocol int32 `protobuf:"varint,2,opt,name=protocol,proto3" json:"protocol,omitempty"`
	Version  int32 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

type Packet struct {
	Type PacketType `protobuf:"varint,1,opt,name=type,proto3,enum=ras.protocol.v1.PacketType" json:"type,omitempty"`
	Size int32      `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	Data []byte     `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type PacketMessage interface {
	PacketMessageFormatter
	PacketMessageParser
}

type PacketMessageFormatter interface {
	GetPacketType() PacketType
	Formatter(writer io.Writer, version int32) error
}

type PacketMessageParser interface {
	GetPacketType() PacketType
	Parse(reader io.Reader, version int32) error
}

type PacketType int32

type Param struct {
	Type  ParamType `protobuf:"varint,1,opt,name=type,proto3,enum=ras.protocol.v1.ParamType" json:"type,omitempty"`
	Value []byte    `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type ParamType int32