pubsub_pb

type ControlExtensions struct {
	PartialMessages *bool `protobuf:"varint,10,opt,name=partialMessages" json:"partialMessages,omitempty"`
	// Experimental extensions must use field numbers larger than 0x200000 to be
	// encoded with 4 bytes
	TestExtension *bool `protobuf:"varint,6492434,opt,name=testExtension" json:"testExtension,omitempty"`
	// contains filtered or unexported fields
}

type ControlGraft struct {
	TopicID *string `protobuf:"bytes,1,opt,name=topicID" json:"topicID,omitempty"`
	// contains filtered or unexported fields
}

type ControlIDontWant struct {

	// implementors from other languages should use bytes here - go protobuf emits
	// invalid utf8 strings
	MessageIDs []string `protobuf:"bytes,1,rep,name=messageIDs" json:"messageIDs,omitempty"`
	// contains filtered or unexported fields
}

type ControlIHave struct {
	TopicID *string `protobuf:"bytes,1,opt,name=topicID" json:"topicID,omitempty"`
	// implementors from other languages should use bytes here - go protobuf emits
	// invalid utf8 strings
	MessageIDs []string `protobuf:"bytes,2,rep,name=messageIDs" json:"messageIDs,omitempty"`
	// contains filtered or unexported fields
}

type ControlIWant struct {

	// implementors from other languages should use bytes here - go protobuf emits
	// invalid utf8 strings
	MessageIDs []string `protobuf:"bytes,1,rep,name=messageIDs" json:"messageIDs,omitempty"`
	// contains filtered or unexported fields
}

type ControlMessage struct {
	Ihave      []*ControlIHave     `protobuf:"bytes,1,rep,name=ihave" json:"ihave,omitempty"`
	Iwant      []*ControlIWant     `protobuf:"bytes,2,rep,name=iwant" json:"iwant,omitempty"`
	Graft      []*ControlGraft     `protobuf:"bytes,3,rep,name=graft" json:"graft,omitempty"`
	Prune      []*ControlPrune     `protobuf:"bytes,4,rep,name=prune" json:"prune,omitempty"`
	Idontwant  []*ControlIDontWant `protobuf:"bytes,5,rep,name=idontwant" json:"idontwant,omitempty"`
	Extensions *ControlExtensions  `protobuf:"bytes,6,opt,name=extensions" json:"extensions,omitempty"`
	// contains filtered or unexported fields
}

type ControlPrune struct {
	TopicID *string     `protobuf:"bytes,1,opt,name=topicID" json:"topicID,omitempty"`
	Peers   []*PeerInfo `protobuf:"bytes,2,rep,name=peers" json:"peers,omitempty"`
	Backoff *uint64     `protobuf:"varint,3,opt,name=backoff" json:"backoff,omitempty"`
	// contains filtered or unexported fields
}

type Message struct {
	From      []byte  `protobuf:"bytes,1,opt,name=from" json:"from,omitempty"`
	Data      []byte  `protobuf:"bytes,2,opt,name=data" json:"data,omitempty"`
	Seqno     []byte  `protobuf:"bytes,3,opt,name=seqno" json:"seqno,omitempty"`
	Topic     *string `protobuf:"bytes,4,opt,name=topic" json:"topic,omitempty"`
	Signature []byte  `protobuf:"bytes,5,opt,name=signature" json:"signature,omitempty"`
	Key       []byte  `protobuf:"bytes,6,opt,name=key" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type PartialMessagesExtension struct {
	TopicID *string `protobuf:"bytes,1,opt,name=topicID" json:"topicID,omitempty"`
	GroupID []byte  `protobuf:"bytes,2,opt,name=groupID" json:"groupID,omitempty"`
	// An encoded partial message
	PartialMessage []byte `protobuf:"bytes,3,opt,name=partialMessage" json:"partialMessage,omitempty"`
	// An encoded representation of the parts a peer has and wants.
	PartsMetadata []byte `protobuf:"bytes,4,opt,name=partsMetadata" json:"partsMetadata,omitempty"`
	// contains filtered or unexported fields
}

type PeerInfo struct {
	PeerID           []byte `protobuf:"bytes,1,opt,name=peerID" json:"peerID,omitempty"`
	SignedPeerRecord []byte `protobuf:"bytes,2,opt,name=signedPeerRecord" json:"signedPeerRecord,omitempty"`
	// contains filtered or unexported fields
}

type RPC struct {
	Subscriptions []*RPC_SubOpts            `protobuf:"bytes,1,rep,name=subscriptions" json:"subscriptions,omitempty"`
	Publish       []*Message                `protobuf:"bytes,2,rep,name=publish" json:"publish,omitempty"`
	Control       *ControlMessage           `protobuf:"bytes,3,opt,name=control" json:"control,omitempty"`
	Partial       *PartialMessagesExtension `protobuf:"bytes,10,opt,name=partial" json:"partial,omitempty"`
	// Experimental Extensions should register their messages here. They
	// must use field numbers larger than 0x200000 to be encoded with at least 4
	// bytes
	TestExtension *TestExtension `protobuf:"bytes,6492434,opt,name=testExtension" json:"testExtension,omitempty"`
	// contains filtered or unexported fields
}

type RPC_SubOpts struct {
	Subscribe *bool   `protobuf:"varint,1,opt,name=subscribe" json:"subscribe,omitempty"` // subscribe or unsubcribe
	Topicid   *string `protobuf:"bytes,2,opt,name=topicid" json:"topicid,omitempty"`
	// Used with Partial Messages extension.
	// If set, signals to the receiver that the sender prefers partial messages.
	RequestsPartial *bool `protobuf:"varint,3,opt,name=requestsPartial" json:"requestsPartial,omitempty"`
	// If set, signals to the receiver that the sender supports sending partial
	// messages on this topic. If requestsPartial is true, this is assumed to be
	// true.
	SupportsSendingPartial *bool `protobuf:"varint,4,opt,name=supportsSendingPartial" json:"supportsSendingPartial,omitempty"`
	// contains filtered or unexported fields
}

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

type TraceEvent struct {
	Type                   *TraceEvent_Type                   `protobuf:"varint,1,opt,name=type,enum=pubsub.pb.TraceEvent_Type" json:"type,omitempty"`
	PeerID                 []byte                             `protobuf:"bytes,2,opt,name=peerID" json:"peerID,omitempty"`
	Timestamp              *int64                             `protobuf:"varint,3,opt,name=timestamp" json:"timestamp,omitempty"`
	PublishMessage         *TraceEvent_PublishMessage         `protobuf:"bytes,4,opt,name=publishMessage" json:"publishMessage,omitempty"`
	RejectMessage          *TraceEvent_RejectMessage          `protobuf:"bytes,5,opt,name=rejectMessage" json:"rejectMessage,omitempty"`
	DuplicateMessage       *TraceEvent_DuplicateMessage       `protobuf:"bytes,6,opt,name=duplicateMessage" json:"duplicateMessage,omitempty"`
	DeliverMessage         *TraceEvent_DeliverMessage         `protobuf:"bytes,7,opt,name=deliverMessage" json:"deliverMessage,omitempty"`
	OnNewOutboundStream    *TraceEvent_OnNewOutboundStream    `protobuf:"bytes,8,opt,name=onNewOutboundStream" json:"onNewOutboundStream,omitempty"`
	OnClosedOutboundStream *TraceEvent_OnClosedOutboundStream `protobuf:"bytes,9,opt,name=onClosedOutboundStream" json:"onClosedOutboundStream,omitempty"`
	RecvRPC                *TraceEvent_RecvRPC                `protobuf:"bytes,10,opt,name=recvRPC" json:"recvRPC,omitempty"`
	SendRPC                *TraceEvent_SendRPC                `protobuf:"bytes,11,opt,name=sendRPC" json:"sendRPC,omitempty"`
	DropRPC                *TraceEvent_DropRPC                `protobuf:"bytes,12,opt,name=dropRPC" json:"dropRPC,omitempty"`
	Join                   *TraceEvent_Join                   `protobuf:"bytes,13,opt,name=join" json:"join,omitempty"`
	Leave                  *TraceEvent_Leave                  `protobuf:"bytes,14,opt,name=leave" json:"leave,omitempty"`
	Graft                  *TraceEvent_Graft                  `protobuf:"bytes,15,opt,name=graft" json:"graft,omitempty"`
	Prune                  *TraceEvent_Prune                  `protobuf:"bytes,16,opt,name=prune" json:"prune,omitempty"`
	// contains filtered or unexported fields
}

type TraceEventBatch struct {
	Batch []*TraceEvent `protobuf:"bytes,1,rep,name=batch" json:"batch,omitempty"`
	// contains filtered or unexported fields
}

type TraceEvent_ControlGraftMeta struct {
	Topic *string `protobuf:"bytes,1,opt,name=topic" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

type TraceEvent_ControlIDontWantMeta struct {
	MessageIDs [][]byte `protobuf:"bytes,1,rep,name=messageIDs" json:"messageIDs,omitempty"`
	// contains filtered or unexported fields
}

type TraceEvent_ControlIHaveMeta struct {
	Topic      *string  `protobuf:"bytes,1,opt,name=topic" json:"topic,omitempty"`
	MessageIDs [][]byte `protobuf:"bytes,2,rep,name=messageIDs" json:"messageIDs,omitempty"`
	// contains filtered or unexported fields
}

type TraceEvent_ControlIWantMeta struct {
	MessageIDs [][]byte `protobuf:"bytes,1,rep,name=messageIDs" json:"messageIDs,omitempty"`
	// contains filtered or unexported fields
}

type TraceEvent_ControlMeta struct {
	Ihave     []*TraceEvent_ControlIHaveMeta     `protobuf:"bytes,1,rep,name=ihave" json:"ihave,omitempty"`
	Iwant     []*TraceEvent_ControlIWantMeta     `protobuf:"bytes,2,rep,name=iwant" json:"iwant,omitempty"`
	Graft     []*TraceEvent_ControlGraftMeta     `protobuf:"bytes,3,rep,name=graft" json:"graft,omitempty"`
	Prune     []*TraceEvent_ControlPruneMeta     `protobuf:"bytes,4,rep,name=prune" json:"prune,omitempty"`
	Idontwant []*TraceEvent_ControlIDontWantMeta `protobuf:"bytes,5,rep,name=idontwant" json:"idontwant,omitempty"`
	// contains filtered or unexported fields
}

type TraceEvent_ControlPruneMeta struct {
	Topic *string  `protobuf:"bytes,1,opt,name=topic" json:"topic,omitempty"`
	Peers [][]byte `protobuf:"bytes,2,rep,name=peers" json:"peers,omitempty"`
	// contains filtered or unexported fields
}

type TraceEvent_DeliverMessage struct {
	MessageID    []byte  `protobuf:"bytes,1,opt,name=messageID" json:"messageID,omitempty"`
	Topic        *string `protobuf:"bytes,2,opt,name=topic" json:"topic,omitempty"`
	ReceivedFrom []byte  `protobuf:"bytes,3,opt,name=receivedFrom" json:"receivedFrom,omitempty"`
	// contains filtered or unexported fields
}

type TraceEvent_DropRPC struct {
	SendTo []byte              `protobuf:"bytes,1,opt,name=sendTo" json:"sendTo,omitempty"`
	Meta   *TraceEvent_RPCMeta `protobuf:"bytes,2,opt,name=meta" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

type TraceEvent_DuplicateMessage struct {
	MessageID    []byte  `protobuf:"bytes,1,opt,name=messageID" json:"messageID,omitempty"`
	ReceivedFrom []byte  `protobuf:"bytes,2,opt,name=receivedFrom" json:"receivedFrom,omitempty"`
	Topic        *string `protobuf:"bytes,3,opt,name=topic" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

type TraceEvent_Graft struct {
	PeerID []byte  `protobuf:"bytes,1,opt,name=peerID" json:"peerID,omitempty"`
	Topic  *string `protobuf:"bytes,2,opt,name=topic" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

type TraceEvent_Join struct {
	Topic *string `protobuf:"bytes,1,opt,name=topic" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

type TraceEvent_Leave struct {
	Topic *string `protobuf:"bytes,2,opt,name=topic" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

type TraceEvent_MessageMeta struct {
	MessageID []byte  `protobuf:"bytes,1,opt,name=messageID" json:"messageID,omitempty"`
	Topic     *string `protobuf:"bytes,2,opt,name=topic" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

type TraceEvent_OnClosedOutboundStream struct {
	PeerID []byte `protobuf:"bytes,1,opt,name=peerID" json:"peerID,omitempty"`
	// contains filtered or unexported fields
}

type TraceEvent_OnNewOutboundStream struct {
	PeerID []byte  `protobuf:"bytes,1,opt,name=peerID" json:"peerID,omitempty"`
	Proto  *string `protobuf:"bytes,2,opt,name=proto" json:"proto,omitempty"`
	// contains filtered or unexported fields
}

type TraceEvent_Prune struct {
	PeerID []byte  `protobuf:"bytes,1,opt,name=peerID" json:"peerID,omitempty"`
	Topic  *string `protobuf:"bytes,2,opt,name=topic" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

type TraceEvent_PublishMessage struct {
	MessageID []byte  `protobuf:"bytes,1,opt,name=messageID" json:"messageID,omitempty"`
	Topic     *string `protobuf:"bytes,2,opt,name=topic" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

type TraceEvent_RPCMeta struct {
	Messages     []*TraceEvent_MessageMeta `protobuf:"bytes,1,rep,name=messages" json:"messages,omitempty"`
	Subscription []*TraceEvent_SubMeta     `protobuf:"bytes,2,rep,name=subscription" json:"subscription,omitempty"`
	Control      *TraceEvent_ControlMeta   `protobuf:"bytes,3,opt,name=control" json:"control,omitempty"`
	// contains filtered or unexported fields
}

type TraceEvent_RecvRPC struct {
	ReceivedFrom []byte              `protobuf:"bytes,1,opt,name=receivedFrom" json:"receivedFrom,omitempty"`
	Meta         *TraceEvent_RPCMeta `protobuf:"bytes,2,opt,name=meta" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

type TraceEvent_RejectMessage struct {
	MessageID    []byte  `protobuf:"bytes,1,opt,name=messageID" json:"messageID,omitempty"`
	ReceivedFrom []byte  `protobuf:"bytes,2,opt,name=receivedFrom" json:"receivedFrom,omitempty"`
	Reason       *string `protobuf:"bytes,3,opt,name=reason" json:"reason,omitempty"`
	Topic        *string `protobuf:"bytes,4,opt,name=topic" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

type TraceEvent_SendRPC struct {
	SendTo []byte              `protobuf:"bytes,1,opt,name=sendTo" json:"sendTo,omitempty"`
	Meta   *TraceEvent_RPCMeta `protobuf:"bytes,2,opt,name=meta" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

type TraceEvent_SubMeta struct {
	Subscribe *bool   `protobuf:"varint,1,opt,name=subscribe" json:"subscribe,omitempty"`
	Topic     *string `protobuf:"bytes,2,opt,name=topic" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

type TraceEvent_Type int32