proto

Documentation

Index

• Constants
• Variables
• type Constants
  • func (*Constants) Descriptor() ([]byte, []int)
  • func (m *Constants) GetMagic() uint64
  • func (*Constants) ProtoMessage()
  • func (m *Constants) Reset()
  • func (m *Constants) String() string
  • func (m *Constants) XXX_DiscardUnknown()
  • func (m *Constants) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Constants) XXX_Merge(src proto.Message)
  • func (m *Constants) XXX_Size() int
  • func (m *Constants) XXX_Unmarshal(b []byte) error
• type DataNode
  • func (*DataNode) Descriptor() ([]byte, []int)
  • func (m *DataNode) GetName() string
  • func (m *DataNode) GetPort() string
  • func (m *DataNode) GetTimestampUsec() []byte
  • func (m *DataNode) GetType() DataNode_Type
  • func (*DataNode) ProtoMessage()
  • func (m *DataNode) Reset()
  • func (m *DataNode) String() string
  • func (m *DataNode) XXX_DiscardUnknown()
  • func (m *DataNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *DataNode) XXX_Merge(src proto.Message)
  • func (m *DataNode) XXX_Size() int
  • func (m *DataNode) XXX_Unmarshal(b []byte) error
• type DataNode_Type
  • func (x DataNode_Type) Enum() *DataNode_Type
  • func (DataNode_Type) EnumDescriptor() ([]byte, []int)
  • func (x DataNode_Type) String() string
  • func (x *DataNode_Type) UnmarshalJSON(data []byte) error
• type Msg
  • func (*Msg) Descriptor() ([]byte, []int)
  • func (m *Msg) GetDst() *DataNode
  • func (m *Msg) GetMagic() uint64
  • func (m *Msg) GetNodes() []*DataNode
  • func (m *Msg) GetPayload() []byte
  • func (m *Msg) GetSeq() []byte
  • func (m *Msg) GetSrc() *DataNode
  • func (*Msg) ProtoMessage()
  • func (m *Msg) Reset()
  • func (m *Msg) String() string
  • func (m *Msg) XXX_DiscardUnknown()
  • func (m *Msg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Msg) XXX_Merge(src proto.Message)
  • func (m *Msg) XXX_Size() int
  • func (m *Msg) XXX_Unmarshal(b []byte) error

Constants

const Default_Constants_Magic uint64 = 257787339638762

Variables

var DataNode_Type_name = map[int32]string{
	0: "UNKNOWN",
	1: "CLIENT",
	2: "SERVER",
}

var DataNode_Type_value = map[string]int32{
	"UNKNOWN": 0,
	"CLIENT":  1,
	"SERVER":  2,
}

Types

type Constants

type Constants struct {
	Magic                *uint64  `protobuf:"varint,1,opt,name=magic,def=257787339638762" json:"magic,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Constants defines constants with default values.

func (*Constants) Descriptor

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

func (*Constants) GetMagic

func (m *Constants) GetMagic() uint64

func (*Constants) ProtoMessage

func (*Constants) ProtoMessage()

func (*Constants) Reset

func (m *Constants) Reset()

func (*Constants) String

func (m *Constants) String() string

func (*Constants) XXX_DiscardUnknown

func (m *Constants) XXX_DiscardUnknown()

func (*Constants) XXX_Marshal

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

func (*Constants) XXX_Merge

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

func (*Constants) XXX_Size

func (m *Constants) XXX_Size() int

func (*Constants) XXX_Unmarshal

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

type DataNode

type DataNode struct {
	Type *DataNode_Type `protobuf:"varint,1,opt,name=type,enum=message.DataNode_Type,def=1" json:"type,omitempty"`
	Name *string        `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	Port *string        `protobuf:"bytes,4,opt,name=port" json:"port,omitempty"`
	// 8 bytes of timestamp in pcap-friendly network byte order.
	TimestampUsec        []byte   `protobuf:"bytes,3,opt,name=timestamp_usec,json=timestampUsec" json:"timestamp_usec,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Datanode is something that see's a message AND can modify it.

func (*DataNode) Descriptor

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

func (*DataNode) GetName

func (m *DataNode) GetName() string

func (*DataNode) GetPort

func (m *DataNode) GetPort() string

func (*DataNode) GetTimestampUsec

func (m *DataNode) GetTimestampUsec() []byte

func (*DataNode) GetType

func (m *DataNode) GetType() DataNode_Type

func (*DataNode) ProtoMessage

func (*DataNode) ProtoMessage()

func (*DataNode) Reset

func (m *DataNode) Reset()

func (*DataNode) String

func (m *DataNode) String() string

func (*DataNode) XXX_DiscardUnknown

func (m *DataNode) XXX_DiscardUnknown()

func (*DataNode) XXX_Marshal

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

func (*DataNode) XXX_Merge

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

func (*DataNode) XXX_Size

func (m *DataNode) XXX_Size() int

func (*DataNode) XXX_Unmarshal

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

type DataNode_Type

type DataNode_Type int32

const (
	DataNode_UNKNOWN DataNode_Type = 0
	DataNode_CLIENT  DataNode_Type = 1
	DataNode_SERVER  DataNode_Type = 2
)

const Default_DataNode_Type DataNode_Type = DataNode_CLIENT

func (DataNode_Type) Enum

func (x DataNode_Type) Enum() *DataNode_Type

func (DataNode_Type) EnumDescriptor

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

func (DataNode_Type) String

func (x DataNode_Type) String() string

func (*DataNode_Type) UnmarshalJSON

func (x *DataNode_Type) UnmarshalJSON(data []byte) error

type Msg

type Msg struct {
	Magic *uint64 `protobuf:"fixed64,1,opt,name=magic" json:"magic,omitempty"`
	// 8 bytes of sequence in pcap-friendly network byte order.
	Seq []byte `protobuf:"bytes,2,opt,name=seq" json:"seq,omitempty"`
	// Datanodes seen by this message.
	Src   *DataNode   `protobuf:"bytes,3,opt,name=src" json:"src,omitempty"`
	Dst   *DataNode   `protobuf:"bytes,4,opt,name=dst" json:"dst,omitempty"`
	Nodes []*DataNode `protobuf:"bytes,5,rep,name=nodes" json:"nodes,omitempty"`
	// Optional payload.
	Payload              []byte   `protobuf:"bytes,99,opt,name=payload" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Msg is a message sent over the network. magic, seq, src and dst are required fields.

func (*Msg) Descriptor

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

func (*Msg) GetDst

func (m *Msg) GetDst() *DataNode

func (*Msg) GetMagic

func (m *Msg) GetMagic() uint64

func (*Msg) GetNodes

func (m *Msg) GetNodes() []*DataNode

func (*Msg) GetPayload

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

func (*Msg) GetSeq

func (m *Msg) GetSeq() []byte

func (*Msg) GetSrc

func (m *Msg) GetSrc() *DataNode

func (*Msg) ProtoMessage

func (*Msg) ProtoMessage()

func (*Msg) Reset

func (m *Msg) Reset()

func (*Msg) String

func (m *Msg) String() string

func (*Msg) XXX_DiscardUnknown

func (m *Msg) XXX_DiscardUnknown()

func (*Msg) XXX_Marshal

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

func (*Msg) XXX_Merge

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

func (*Msg) XXX_Size

func (m *Msg) XXX_Size() int

func (*Msg) XXX_Unmarshal

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