message

Documentation

Index

• Constants
• Variables
• func ParseSendResp(respList []SendResponse) (remoteNodes []string, respBytes [][]byte, respErrs []string)
• func TopicValidator(localPeer peer.ID, log tplog.Logger, validators ...PubSubMessageValidator) pubsub.ValidatorEx
• type NetworkMessage
  • func (*NetworkMessage) Descriptor() ([]byte, []int)
  • func (m *NetworkMessage) GetData() []byte
  • func (m *NetworkMessage) GetErrDesc() string
  • func (m *NetworkMessage) GetFromPeerID() string
  • func (m *NetworkMessage) GetModuleName() string
  • func (m *NetworkMessage) GetProtocolID() string
  • func (m *NetworkMessage) GetTargetPeerIDs() []string
  • func (m *NetworkMessage) Marshal() (dAtA []byte, err error)
  • func (m *NetworkMessage) MarshalTo(dAtA []byte) (int, error)
  • func (m *NetworkMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*NetworkMessage) ProtoMessage()
  • func (m *NetworkMessage) Reset()
  • func (m *NetworkMessage) Size() (n int)
  • func (m *NetworkMessage) String() string
  • func (m *NetworkMessage) Unmarshal(dAtA []byte) error
  • func (m *NetworkMessage) XXX_DiscardUnknown()
  • func (m *NetworkMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *NetworkMessage) XXX_Merge(src proto.Message)
  • func (m *NetworkMessage) XXX_Size() int
  • func (m *NetworkMessage) XXX_Unmarshal(b []byte) error
• type NetworkPubSubMessage
  • func (*NetworkPubSubMessage) Descriptor() ([]byte, []int)
  • func (m *NetworkPubSubMessage) GetData() []byte
  • func (m *NetworkPubSubMessage) GetErrDesc() string
  • func (m *NetworkPubSubMessage) GetFromPeerID() string
  • func (m *NetworkPubSubMessage) GetModuleNames() []string
  • func (m *NetworkPubSubMessage) GetTopic() string
  • func (m *NetworkPubSubMessage) Marshal() (dAtA []byte, err error)
  • func (m *NetworkPubSubMessage) MarshalTo(dAtA []byte) (int, error)
  • func (m *NetworkPubSubMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*NetworkPubSubMessage) ProtoMessage()
  • func (m *NetworkPubSubMessage) Reset()
  • func (m *NetworkPubSubMessage) Size() (n int)
  • func (m *NetworkPubSubMessage) String() string
  • func (m *NetworkPubSubMessage) Unmarshal(dAtA []byte) error
  • func (m *NetworkPubSubMessage) XXX_DiscardUnknown()
  • func (m *NetworkPubSubMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *NetworkPubSubMessage) XXX_Merge(src proto.Message)
  • func (m *NetworkPubSubMessage) XXX_Size() int
  • func (m *NetworkPubSubMessage) XXX_Unmarshal(b []byte) error
• type PubSubMessageValidator
• type ResponseData
• type SendResponse
• type ValidationResult

Constants

const (
	ValidationAccept = ValidationResult(0)
	ValidationReject = ValidationResult(1)
	ValidationIgnore = ValidationResult(2)
)

Variables

var (
	ErrInvalidLengthMessageNetwork        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessageNetwork          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessageNetwork = fmt.Errorf("proto: unexpected end of group")
)

Functions

func ParseSendResp

func ParseSendResp(respList []SendResponse) (remoteNodes []string, respBytes [][]byte, respErrs []string)

func TopicValidator

func TopicValidator(localPeer peer.ID, log tplog.Logger, validators ...PubSubMessageValidator) pubsub.ValidatorEx

Types

type NetworkMessage

type NetworkMessage struct {
	FromPeerID           string   `protobuf:"bytes,1,opt,name=FromPeerID,proto3" json:"fromPeerID"`
	TargetPeerIDs        []string `protobuf:"bytes,2,rep,name=TargetPeerIDs,proto3" json:"targetPeerIDs"`
	ProtocolID           string   `protobuf:"bytes,3,opt,name=ProtocolID,proto3" json:"protocolID"`
	ModuleName           string   `protobuf:"bytes,4,opt,name=ModuleName,proto3" json:"moduleName"`
	ErrDesc              string   `protobuf:"bytes,5,opt,name=ErrDesc,proto3" json:"errDesc"`
	Data                 []byte   `protobuf:"bytes,6,opt,name=Data,proto3" json:"data"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NetworkMessage) Descriptor

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

func (*NetworkMessage) GetData

func (m *NetworkMessage) GetData() []byte

func (*NetworkMessage) GetErrDesc

func (m *NetworkMessage) GetErrDesc() string

func (*NetworkMessage) GetFromPeerID

func (m *NetworkMessage) GetFromPeerID() string

func (*NetworkMessage) GetModuleName

func (m *NetworkMessage) GetModuleName() string

func (*NetworkMessage) GetProtocolID

func (m *NetworkMessage) GetProtocolID() string

func (*NetworkMessage) GetTargetPeerIDs

func (m *NetworkMessage) GetTargetPeerIDs() []string

func (*NetworkMessage) Marshal

func (m *NetworkMessage) Marshal() (dAtA []byte, err error)

func (*NetworkMessage) MarshalTo

func (m *NetworkMessage) MarshalTo(dAtA []byte) (int, error)

func (*NetworkMessage) MarshalToSizedBuffer

func (m *NetworkMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NetworkMessage) ProtoMessage

func (*NetworkMessage) ProtoMessage()

func (*NetworkMessage) Reset

func (m *NetworkMessage) Reset()

func (*NetworkMessage) Size

func (m *NetworkMessage) Size() (n int)

func (*NetworkMessage) String

func (m *NetworkMessage) String() string

func (*NetworkMessage) Unmarshal

func (m *NetworkMessage) Unmarshal(dAtA []byte) error

func (*NetworkMessage) XXX_DiscardUnknown

func (m *NetworkMessage) XXX_DiscardUnknown()

func (*NetworkMessage) XXX_Marshal

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

func (*NetworkMessage) XXX_Merge

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

func (*NetworkMessage) XXX_Size

func (m *NetworkMessage) XXX_Size() int

func (*NetworkMessage) XXX_Unmarshal

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

type NetworkPubSubMessage

type NetworkPubSubMessage struct {
	FromPeerID           string   `protobuf:"bytes,1,opt,name=FromPeerID,proto3" json:"fromPeerID"`
	Topic                string   `protobuf:"bytes,2,opt,name=Topic,proto3" json:"topic"`
	ModuleNames          []string `protobuf:"bytes,3,rep,name=ModuleNames,proto3" json:"moduleNames"`
	ErrDesc              string   `protobuf:"bytes,4,opt,name=ErrDesc,proto3" json:"errDesc"`
	Data                 []byte   `protobuf:"bytes,5,opt,name=Data,proto3" json:"data"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NetworkPubSubMessage) Descriptor

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

func (*NetworkPubSubMessage) GetData

func (m *NetworkPubSubMessage) GetData() []byte

func (*NetworkPubSubMessage) GetErrDesc

func (m *NetworkPubSubMessage) GetErrDesc() string

func (*NetworkPubSubMessage) GetFromPeerID

func (m *NetworkPubSubMessage) GetFromPeerID() string

func (*NetworkPubSubMessage) GetModuleNames

func (m *NetworkPubSubMessage) GetModuleNames() []string

func (*NetworkPubSubMessage) GetTopic

func (m *NetworkPubSubMessage) GetTopic() string

func (*NetworkPubSubMessage) Marshal

func (m *NetworkPubSubMessage) Marshal() (dAtA []byte, err error)

func (*NetworkPubSubMessage) MarshalTo

func (m *NetworkPubSubMessage) MarshalTo(dAtA []byte) (int, error)

func (*NetworkPubSubMessage) MarshalToSizedBuffer

func (m *NetworkPubSubMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NetworkPubSubMessage) ProtoMessage

func (*NetworkPubSubMessage) ProtoMessage()

func (*NetworkPubSubMessage) Reset

func (m *NetworkPubSubMessage) Reset()

func (*NetworkPubSubMessage) Size

func (m *NetworkPubSubMessage) Size() (n int)

func (*NetworkPubSubMessage) String

func (m *NetworkPubSubMessage) String() string

func (*NetworkPubSubMessage) Unmarshal

func (m *NetworkPubSubMessage) Unmarshal(dAtA []byte) error

func (*NetworkPubSubMessage) XXX_DiscardUnknown

func (m *NetworkPubSubMessage) XXX_DiscardUnknown()

func (*NetworkPubSubMessage) XXX_Marshal

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

func (*NetworkPubSubMessage) XXX_Merge

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

func (*NetworkPubSubMessage) XXX_Size

func (m *NetworkPubSubMessage) XXX_Size() int

func (*NetworkPubSubMessage) XXX_Unmarshal

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

type PubSubMessageValidator

type PubSubMessageValidator func(ctx context.Context, isLocal bool, data []byte) ValidationResult

type ResponseData

type ResponseData struct {
	Data   []byte
	ErrMsg string
}

type SendResponse

type SendResponse struct {
	NodeID   string
	RespData []byte
	Err      error
}

type ValidationResult

type ValidationResult int