proto

Documentation

Index

• Constants
• Variables
• type Constants
  • func (*Constants) Descriptor() ([]byte, []int)
  • func (x *Constants) GetMagic() uint64
  • func (*Constants) ProtoMessage()
  • func (x *Constants) ProtoReflect() protoreflect.Message
  • func (x *Constants) Reset()
  • func (x *Constants) String() string
• type DataNode
  • func (*DataNode) Descriptor() ([]byte, []int)
  • func (x *DataNode) GetName() string
  • func (x *DataNode) GetPort() string
  • func (x *DataNode) GetTimestampUsec() []byte
  • func (x *DataNode) GetType() DataNode_Type
  • func (*DataNode) ProtoMessage()
  • func (x *DataNode) ProtoReflect() protoreflect.Message
  • func (x *DataNode) Reset()
  • func (x *DataNode) String() string
• type DataNode_Type
  • func (DataNode_Type) Descriptor() protoreflect.EnumDescriptor
  • func (x DataNode_Type) Enum() *DataNode_Type
  • func (DataNode_Type) EnumDescriptor() ([]byte, []int)
  • func (x DataNode_Type) Number() protoreflect.EnumNumber
  • func (x DataNode_Type) String() string
  • func (DataNode_Type) Type() protoreflect.EnumType
  • func (x *DataNode_Type) UnmarshalJSON(b []byte) error
• type Msg
  • func (*Msg) Descriptor() ([]byte, []int)
  • func (x *Msg) GetDst() *DataNode
  • func (x *Msg) GetMagic() uint64
  • func (x *Msg) GetNodes() []*DataNode
  • func (x *Msg) GetPayload() []byte
  • func (x *Msg) GetSeq() []byte
  • func (x *Msg) GetSrc() *DataNode
  • func (*Msg) ProtoMessage()
  • func (x *Msg) ProtoReflect() protoreflect.Message
  • func (x *Msg) Reset()
  • func (x *Msg) String() string

Constants

const (
	Default_Constants_Magic = uint64(257787339638762)
)

Default values for Constants fields.

const (
	Default_DataNode_Type = DataNode_CLIENT
)

Default values for DataNode fields.

Variables

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

Enum value maps for DataNode_Type.

var File_github_com_google_cloudprober_common_message_proto_message_proto protoreflect.FileDescriptor

Types

type Constants

type Constants struct {
	Magic *uint64 `protobuf:"varint,1,opt,name=magic,def=257787339638762" json:"magic,omitempty"`
	// contains filtered or unexported fields
}

Constants defines constants with default values.

func (*Constants) Descriptor

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

Deprecated: Use Constants.ProtoReflect.Descriptor instead.

func (*Constants) GetMagic

func (x *Constants) GetMagic() uint64

func (*Constants) ProtoMessage

func (*Constants) ProtoMessage()

func (*Constants) ProtoReflect

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

func (*Constants) Reset

func (x *Constants) Reset()

func (*Constants) String

func (x *Constants) String() string

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"`
	// contains filtered or unexported fields
}

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

func (*DataNode) Descriptor

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

Deprecated: Use DataNode.ProtoReflect.Descriptor instead.

func (*DataNode) GetName

func (x *DataNode) GetName() string

func (*DataNode) GetPort

func (x *DataNode) GetPort() string

func (*DataNode) GetTimestampUsec

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

func (*DataNode) GetType

func (x *DataNode) GetType() DataNode_Type

func (*DataNode) ProtoMessage

func (*DataNode) ProtoMessage()

func (*DataNode) ProtoReflect

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

func (*DataNode) Reset

func (x *DataNode) Reset()

func (*DataNode) String

func (x *DataNode) String() string

type DataNode_Type

type DataNode_Type int32

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

func (DataNode_Type) Descriptor

func (DataNode_Type) Descriptor() protoreflect.EnumDescriptor

func (DataNode_Type) Enum

func (x DataNode_Type) Enum() *DataNode_Type

func (DataNode_Type) EnumDescriptor

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

Deprecated: Use DataNode_Type.Descriptor instead.

func (DataNode_Type) Number

func (x DataNode_Type) Number() protoreflect.EnumNumber

func (DataNode_Type) String

func (x DataNode_Type) String() string

func (DataNode_Type) Type

func (DataNode_Type) Type() protoreflect.EnumType

func (*DataNode_Type) UnmarshalJSON

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

Deprecated: Do not use.

type Msg

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

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

func (*Msg) Descriptor

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

Deprecated: Use Msg.ProtoReflect.Descriptor instead.

func (*Msg) GetDst

func (x *Msg) GetDst() *DataNode

func (*Msg) GetMagic

func (x *Msg) GetMagic() uint64

func (*Msg) GetNodes

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

func (*Msg) GetPayload

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

func (*Msg) GetSeq

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

func (*Msg) GetSrc

func (x *Msg) GetSrc() *DataNode

func (*Msg) ProtoMessage

func (*Msg) ProtoMessage()

func (*Msg) ProtoReflect

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

func (*Msg) Reset

func (x *Msg) Reset()

func (*Msg) String

func (x *Msg) String() string