message

Documentation

Index

• Variables
• type NetMessage
  • func NewNetMessage(opts ...NetMessageOption) *NetMessage
  • func (*NetMessage) Descriptor() ([]byte, []int)
  • func (x *NetMessage) GetBody() []byte
  • func (x *NetMessage) GetCoding() string
  • func (x *NetMessage) GetCompress() string
  • func (x *NetMessage) GetHeaders() map[string]*StringList
  • func (x *NetMessage) GetHost() string
  • func (x *NetMessage) GetPath() string
  • func (x *NetMessage) GetPort() int32
  • func (x *NetMessage) GetSchema() string
  • func (x *NetMessage) GetURI() string
  • func (*NetMessage) ProtoMessage()
  • func (x *NetMessage) ProtoReflect() protoreflect.Message
  • func (x *NetMessage) Reset()
  • func (x *NetMessage) String() string
  • func (nmsg *NetMessage) With(opts ...NetMessageOption) *NetMessage
• type NetMessageNative
  • func NewNetMessageNative(opts ...NetMessageNativeOption) *NetMessageNative
  • func (nmsgn *NetMessageNative) With(opts ...NetMessageNativeOption) *NetMessageNative
• type NetMessageNativeOption
  • func NetMessageNativeWithAddress(host string, port int, path string) NetMessageNativeOption
  • func NetMessageNativeWithBody(coding, compress string, body interface{}) NetMessageNativeOption
  • func NetMessageNativeWithHeaders(key string, values []string) NetMessageNativeOption
  • func NetMessageNativeWithProtocol(uri, schema string) NetMessageNativeOption
• type NetMessageOption
  • func NetMessageWithAddress(host string, port int, path string) NetMessageOption
  • func NetMessageWithBody(coding, compress string, body []byte) NetMessageOption
  • func NetMessageWithHeaders(key string, values []string) NetMessageOption
  • func NetMessageWithProtocol(uri, schema string) NetMessageOption
• type StringList
  • func (*StringList) Descriptor() ([]byte, []int)
  • func (x *StringList) GetList() []string
  • func (*StringList) ProtoMessage()
  • func (x *StringList) ProtoReflect() protoreflect.Message
  • func (x *StringList) Reset()
  • func (x *StringList) String() string

Variables

var File_net_message_message_proto protoreflect.FileDescriptor

Types

type NetMessage

type NetMessage struct {
	URI      string                 `protobuf:"bytes,1,opt,name=URI,proto3" json:"URI,omitempty"`
	Schema   string                 `protobuf:"bytes,2,opt,name=Schema,proto3" json:"Schema,omitempty"`
	Host     string                 `protobuf:"bytes,3,opt,name=Host,proto3" json:"Host,omitempty"`
	Port     int32                  `protobuf:"varint,4,opt,name=Port,proto3" json:"Port,omitempty"`
	Path     string                 `protobuf:"bytes,5,opt,name=Path,proto3" json:"Path,omitempty"`
	Headers  map[string]*StringList `` /* 155-byte string literal not displayed */
	Coding   string                 `protobuf:"bytes,7,opt,name=Coding,proto3" json:"Coding,omitempty"`
	Compress string                 `protobuf:"bytes,8,opt,name=Compress,proto3" json:"Compress,omitempty"`
	Body     []byte                 `protobuf:"bytes,9,opt,name=Body,proto3" json:"Body,omitempty"`
	// contains filtered or unexported fields
}

func NewNetMessage

func NewNetMessage(opts ...NetMessageOption) *NetMessage

func (*NetMessage) Descriptor

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

Deprecated: Use NetMessage.ProtoReflect.Descriptor instead.

func (*NetMessage) GetBody

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

func (*NetMessage) GetCoding

func (x *NetMessage) GetCoding() string

func (*NetMessage) GetCompress

func (x *NetMessage) GetCompress() string

func (*NetMessage) GetHeaders

func (x *NetMessage) GetHeaders() map[string]*StringList

func (*NetMessage) GetHost

func (x *NetMessage) GetHost() string

func (*NetMessage) GetPath

func (x *NetMessage) GetPath() string

func (*NetMessage) GetPort

func (x *NetMessage) GetPort() int32

func (*NetMessage) GetSchema

func (x *NetMessage) GetSchema() string

func (*NetMessage) GetURI

func (x *NetMessage) GetURI() string

func (*NetMessage) ProtoMessage

func (*NetMessage) ProtoMessage()

func (*NetMessage) ProtoReflect

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

func (*NetMessage) Reset

func (x *NetMessage) Reset()

func (*NetMessage) String

func (x *NetMessage) String() string

func (*NetMessage) With

func (nmsg *NetMessage) With(opts ...NetMessageOption) *NetMessage

type NetMessageNative

type NetMessageNative struct {
	NetMessage
	Body interface{}
}

func NewNetMessageNative

func NewNetMessageNative(opts ...NetMessageNativeOption) *NetMessageNative

func (*NetMessageNative) With

func (nmsgn *NetMessageNative) With(opts ...NetMessageNativeOption) *NetMessageNative

type NetMessageNativeOption

type NetMessageNativeOption func(msg *NetMessageNative)

func NetMessageNativeWithAddress

func NetMessageNativeWithAddress(host string, port int, path string) NetMessageNativeOption

func NetMessageNativeWithBody

func NetMessageNativeWithBody(coding, compress string, body interface{}) NetMessageNativeOption

func NetMessageNativeWithHeaders

func NetMessageNativeWithHeaders(key string, values []string) NetMessageNativeOption

func NetMessageNativeWithProtocol

func NetMessageNativeWithProtocol(uri, schema string) NetMessageNativeOption

type NetMessageOption

type NetMessageOption func(msg *NetMessage)

func NetMessageWithAddress

func NetMessageWithAddress(host string, port int, path string) NetMessageOption

func NetMessageWithBody

func NetMessageWithBody(coding, compress string, body []byte) NetMessageOption

func NetMessageWithHeaders

func NetMessageWithHeaders(key string, values []string) NetMessageOption

func NetMessageWithProtocol

func NetMessageWithProtocol(uri, schema string) NetMessageOption

type StringList

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

func (*StringList) Descriptor

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

Deprecated: Use StringList.ProtoReflect.Descriptor instead.

func (*StringList) GetList

func (x *StringList) GetList() []string

func (*StringList) ProtoMessage

func (*StringList) ProtoMessage()

func (*StringList) ProtoReflect

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

func (*StringList) Reset

func (x *StringList) Reset()

func (*StringList) String

func (x *StringList) String() string