data

package
v1.1.33 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 1, 2021 License: GPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthAuthMessage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAuthMessage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAuthMessage = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTopicMessage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTopicMessage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTopicMessage = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type AuthMessage 

type AuthMessage struct {
	AuthMessagePb
}

AuthMessage represents the authentication message used in the handshake process of 2 peers

func (*AuthMessage) IsInterfaceNil 

func (am *AuthMessage) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

type AuthMessagePb 

type AuthMessagePb struct {
	Message   []byte `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"`
	Sig       []byte `protobuf:"bytes,2,opt,name=Sig,proto3" json:"Sig,omitempty"`
	Pubkey    []byte `protobuf:"bytes,3,opt,name=Pubkey,proto3" json:"Pubkey,omitempty"`
	Timestamp int64  `protobuf:"varint,4,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
}

func (*AuthMessagePb) Descriptor 

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

func (*AuthMessagePb) Equal 

func (this *AuthMessagePb) Equal(that interface{}) bool

func (*AuthMessagePb) GetMessage 

func (m *AuthMessagePb) GetMessage() []byte

func (*AuthMessagePb) GetPubkey 

func (m *AuthMessagePb) GetPubkey() []byte

func (*AuthMessagePb) GetSig 

func (m *AuthMessagePb) GetSig() []byte

func (*AuthMessagePb) GetTimestamp 

func (m *AuthMessagePb) GetTimestamp() int64

func (*AuthMessagePb) GoString 

func (this *AuthMessagePb) GoString() string

func (*AuthMessagePb) Marshal 

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

func (*AuthMessagePb) MarshalTo 

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

func (*AuthMessagePb) MarshalToSizedBuffer 

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

func (*AuthMessagePb) ProtoMessage 

func (*AuthMessagePb) ProtoMessage()

func (*AuthMessagePb) Reset 

func (m *AuthMessagePb) Reset()

func (*AuthMessagePb) Size 

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

func (*AuthMessagePb) String 

func (this *AuthMessagePb) String() string

func (*AuthMessagePb) Unmarshal 

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

func (*AuthMessagePb) XXX_DiscardUnknown 

func (m *AuthMessagePb) XXX_DiscardUnknown()

func (*AuthMessagePb) XXX_Marshal 

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

func (*AuthMessagePb) XXX_Merge 

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

func (*AuthMessagePb) XXX_Size 

func (m *AuthMessagePb) XXX_Size() int

func (*AuthMessagePb) XXX_Unmarshal 

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

type TopicMessage added in v1.0.133 

type TopicMessage struct {
	Version        uint32 `protobuf:"varint,1,opt,name=Version,proto3" json:"Version,omitempty"`
	Payload        []byte `protobuf:"bytes,2,opt,name=Payload,proto3" json:"Payload,omitempty"`
	Timestamp      int64  `protobuf:"varint,3,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	Pk             []byte `protobuf:"bytes,4,opt,name=Pk,proto3" json:"Pk,omitempty"`
	SignatureOnPid []byte `protobuf:"bytes,5,opt,name=SignatureOnPid,proto3" json:"SignatureOnPid,omitempty"`
}

func (*TopicMessage) Descriptor added in v1.0.133 

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

func (*TopicMessage) Equal added in v1.0.133 

func (this *TopicMessage) Equal(that interface{}) bool

func (*TopicMessage) GetPayload added in v1.0.133 

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

func (*TopicMessage) GetPk added in v1.0.149 

func (m *TopicMessage) GetPk() []byte

func (*TopicMessage) GetSignatureOnPid added in v1.0.149 

func (m *TopicMessage) GetSignatureOnPid() []byte

func (*TopicMessage) GetTimestamp added in v1.0.133 

func (m *TopicMessage) GetTimestamp() int64

func (*TopicMessage) GetVersion added in v1.0.149 

func (m *TopicMessage) GetVersion() uint32

func (*TopicMessage) GoString added in v1.0.133 

func (this *TopicMessage) GoString() string

func (*TopicMessage) Marshal added in v1.0.133 

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

func (*TopicMessage) MarshalTo added in v1.0.133 

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

func (*TopicMessage) MarshalToSizedBuffer added in v1.0.133 

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

func (*TopicMessage) ProtoMessage added in v1.0.133 

func (*TopicMessage) ProtoMessage()

func (*TopicMessage) Reset added in v1.0.133 

func (m *TopicMessage) Reset()

func (*TopicMessage) Size added in v1.0.133 

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

func (*TopicMessage) String added in v1.0.133 

func (this *TopicMessage) String() string

func (*TopicMessage) Unmarshal added in v1.0.133 

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

func (*TopicMessage) XXX_DiscardUnknown added in v1.0.133 

func (m *TopicMessage) XXX_DiscardUnknown()

func (*TopicMessage) XXX_Marshal added in v1.0.133 

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

func (*TopicMessage) XXX_Merge added in v1.0.133 

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

func (*TopicMessage) XXX_Size added in v1.0.133 

func (m *TopicMessage) XXX_Size() int

func (*TopicMessage) XXX_Unmarshal added in v1.0.133 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.