community

package
v2.2.2-0...-90f574e Latest Latest
Warning

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

 Go to latest Published: Feb 17, 2020 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCommunity        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCommunity          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCommunity = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type Ack 

type Ack struct {
	Id        []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	To        []byte `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"`
	From      []byte `protobuf:"bytes,3,opt,name=from,proto3" json:"from,omitempty"`
	Signature []byte `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
}

func AckFromEnv 

func AckFromEnv(env *Envelope) *Ack

func (*Ack) Descriptor 

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

func (*Ack) GetFrom 

func (m *Ack) GetFrom() []byte

func (*Ack) GetId 

func (m *Ack) GetId() []byte

func (*Ack) GetSignature 

func (m *Ack) GetSignature() []byte

func (*Ack) GetTo 

func (m *Ack) GetTo() []byte

func (*Ack) Marshal 

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

func (*Ack) MarshalTo 

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

func (*Ack) MarshalToSizedBuffer 

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

func (*Ack) ProtoMessage 

func (*Ack) ProtoMessage()

func (*Ack) Reset 

func (m *Ack) Reset()

func (*Ack) Sign 

func (a *Ack) Sign(key *ecdsa.PrivateKey) ([]byte, error)

func (*Ack) Signable 

func (a *Ack) Signable() []byte

func (*Ack) Size 

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

func (*Ack) String 

func (m *Ack) String() string

func (*Ack) Unmarshal 

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

func (*Ack) XXX_DiscardUnknown 

func (m *Ack) XXX_DiscardUnknown()

func (*Ack) XXX_Marshal 

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

func (*Ack) XXX_Merge 

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

func (*Ack) XXX_Size 

func (m *Ack) XXX_Size() int

func (*Ack) XXX_Unmarshal 

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

type Envelope 

type Envelope struct {
	Id        []byte   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	To        []byte   `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"`
	From      []byte   `protobuf:"bytes,3,opt,name=from,proto3" json:"from,omitempty"`
	Payload   []byte   `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
	Sequence  uint64   `protobuf:"varint,5,opt,name=sequence,proto3" json:"sequence,omitempty"`
	Topics    [][]byte `protobuf:"bytes,6,rep,name=topics,proto3" json:"topics,omitempty"`
	Signature []byte   `protobuf:"bytes,7,opt,name=signature,proto3" json:"signature,omitempty"`
}

func (*Envelope) Descriptor 

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

func (*Envelope) GetFrom 

func (m *Envelope) GetFrom() []byte

func (*Envelope) GetId 

func (m *Envelope) GetId() []byte

func (*Envelope) GetPayload 

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

func (*Envelope) GetSequence 

func (m *Envelope) GetSequence() uint64

func (*Envelope) GetSignature 

func (m *Envelope) GetSignature() []byte

func (*Envelope) GetTo 

func (m *Envelope) GetTo() []byte

func (*Envelope) GetTopics 

func (m *Envelope) GetTopics() [][]byte

func (*Envelope) Marshal 

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

func (*Envelope) MarshalTo 

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

func (*Envelope) MarshalToSizedBuffer 

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

func (*Envelope) ProtoMessage 

func (*Envelope) ProtoMessage()

func (*Envelope) Reset 

func (m *Envelope) Reset()

func (*Envelope) SetID 

func (e *Envelope) SetID() []byte

func (*Envelope) Sign 

func (e *Envelope) Sign(key *ecdsa.PrivateKey) ([]byte, error)

func (*Envelope) Signable 

func (e *Envelope) Signable() []byte

func (*Envelope) Size 

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

func (*Envelope) String 

func (m *Envelope) String() string

func (*Envelope) Unmarshal 

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

func (*Envelope) XXX_DiscardUnknown 

func (m *Envelope) XXX_DiscardUnknown()

func (*Envelope) XXX_Marshal 

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

func (*Envelope) XXX_Merge 

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

func (*Envelope) XXX_Size 

func (m *Envelope) XXX_Size() int

func (*Envelope) XXX_Unmarshal 

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

type RequestMissing 

type RequestMissing struct {
	Sequence   uint64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
	Identifier []byte `protobuf:"bytes,2,opt,name=identifier,proto3" json:"identifier,omitempty"`
	Signature  []byte `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
}

func (*RequestMissing) Descriptor 

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

func (*RequestMissing) GetIdentifier 

func (m *RequestMissing) GetIdentifier() []byte

func (*RequestMissing) GetSequence 

func (m *RequestMissing) GetSequence() uint64

func (*RequestMissing) GetSignature 

func (m *RequestMissing) GetSignature() []byte

func (*RequestMissing) Marshal 

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

func (*RequestMissing) MarshalTo 

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

func (*RequestMissing) MarshalToSizedBuffer 

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

func (*RequestMissing) ProtoMessage 

func (*RequestMissing) ProtoMessage()

func (*RequestMissing) Reset 

func (m *RequestMissing) Reset()

func (*RequestMissing) Sign 

func (rm *RequestMissing) Sign(key *ecdsa.PrivateKey) ([]byte, error)

func (*RequestMissing) Signable 

func (rm *RequestMissing) Signable() []byte

func (*RequestMissing) Size 

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

func (*RequestMissing) String 

func (m *RequestMissing) String() string

func (*RequestMissing) Unmarshal 

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

func (*RequestMissing) XXX_DiscardUnknown 

func (m *RequestMissing) XXX_DiscardUnknown()

func (*RequestMissing) XXX_Marshal 

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

func (*RequestMissing) XXX_Merge 

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

func (*RequestMissing) XXX_Size 

func (m *RequestMissing) XXX_Size() int

func (*RequestMissing) XXX_Unmarshal 

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

type SavedMessages 

type SavedMessages struct {
	To        []byte      `protobuf:"bytes,1,opt,name=to,proto3" json:"to,omitempty"`
	Cid       []byte      `protobuf:"bytes,2,opt,name=cid,proto3" json:"cid,omitempty"`
	Provider  []byte      `protobuf:"bytes,3,opt,name=provider,proto3" json:"provider,omitempty"`
	Signature []byte      `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
	Messages  []*Envelope `protobuf:"bytes,5,rep,name=messages,proto3" json:"messages,omitempty"`
}

func (*SavedMessages) Descriptor 

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

func (*SavedMessages) GetCid 

func (m *SavedMessages) GetCid() []byte

func (*SavedMessages) GetMessages 

func (m *SavedMessages) GetMessages() []*Envelope

func (*SavedMessages) GetProvider 

func (m *SavedMessages) GetProvider() []byte

func (*SavedMessages) GetSignature 

func (m *SavedMessages) GetSignature() []byte

func (*SavedMessages) GetTo 

func (m *SavedMessages) GetTo() []byte

func (*SavedMessages) Marshal 

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

func (*SavedMessages) MarshalTo 

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

func (*SavedMessages) MarshalToSizedBuffer 

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

func (*SavedMessages) ProtoMessage 

func (*SavedMessages) ProtoMessage()

func (*SavedMessages) Reset 

func (m *SavedMessages) Reset()

func (*SavedMessages) Size 

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

func (*SavedMessages) String 

func (m *SavedMessages) String() string

func (*SavedMessages) Unmarshal 

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

func (*SavedMessages) XXX_DiscardUnknown 

func (m *SavedMessages) XXX_DiscardUnknown()

func (*SavedMessages) XXX_Marshal 

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

func (*SavedMessages) XXX_Merge 

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

func (*SavedMessages) XXX_Size 

func (m *SavedMessages) XXX_Size() int

func (*SavedMessages) XXX_Unmarshal 

func (m *SavedMessages) 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.