network

Sep 8, 2021

Changes in this version

+ const DataForwardEnvelopeType

+ const DataForwardRequestType

+ const DataForwardResponseType

+ func WithPeerKey(k crypto.PrivateKey) func(*network)

type Network

+ Close func() error

+ GetAddresses func() []string

+ GetConnectionInfo func() *peer.ConnectionInfo

+ GetPeerKey func() crypto.PrivateKey

+ GetRelays func() []*peer.ConnectionInfo

+ RegisterAddresses func(...string)

+ RegisterRelays func(...*peer.ConnectionInfo)

+ SubscribeOnce func(ctx context.Context, filters ...EnvelopeFilter) (*Envelope, error)

+ type StringSyncList struct

+ func (m *StringSyncList) Delete(k string)

+ func (m *StringSyncList) Exists(k string) bool

+ func (m *StringSyncList) List() []string

+ func (m *StringSyncList) Put(k string)

+ func (m *StringSyncList) Range(i func(k string) bool)

Mar 28, 2021

Changes in this version

type DataForwardEnvelope

+ func (e *DataForwardEnvelope) MarshalMap() (object.Map, error)

+ func (e *DataForwardEnvelope) MarshalObject() (*object.Object, error)

+ func (e *DataForwardEnvelope) UnmarshalMap(m object.Map) error

+ func (e *DataForwardEnvelope) UnmarshalObject(o *object.Object) error

type DataForwardRequest

+ func (e *DataForwardRequest) MarshalMap() (object.Map, error)

+ func (e *DataForwardRequest) MarshalObject() (*object.Object, error)

+ func (e *DataForwardRequest) UnmarshalMap(m object.Map) error

+ func (e *DataForwardRequest) UnmarshalObject(o *object.Object) error

type DataForwardResponse

+ func (e *DataForwardResponse) MarshalMap() (object.Map, error)

+ func (e *DataForwardResponse) MarshalObject() (*object.Object, error)

+ func (e *DataForwardResponse) UnmarshalMap(m object.Map) error

+ func (e *DataForwardResponse) UnmarshalObject(o *object.Object) error

Feb 21, 2021

Changes in this version

type EnvelopeFilter

+ func FilterByObjectCID(objectCIDs ...object.CID) EnvelopeFilter

Jan 23, 2021

Changes in this version

+ var ErrUnableToUnmarshalIntoResponse = errors.Error(...)

+ var ErrWaitingForResponseTimedOut = errors.Error("time out waiting for response")

+ func SendWithConnectionInfo(c *peer.ConnectionInfo) func(*sendOptions)

+ func SendWithResponse(v interface{ ... }, t time.Duration) func(*sendOptions)

type Network

+ RegisterResolver func(resolver Resolver)

+ type Resolver interface

+ LookupPeer func(ctx context.Context, publicKey crypto.PublicKey) (*peer.ConnectionInfo, error)

+ type ResolverSyncList struct

+ func (m *ResolverSyncList) Delete(k Resolver)

+ func (m *ResolverSyncList) Exists(k Resolver) bool

+ func (m *ResolverSyncList) List() []Resolver

+ func (m *ResolverSyncList) Put(k Resolver)

+ func (m *ResolverSyncList) Range(i func(k Resolver) bool)

+ type SendOption func(*sendOptions)

Nov 28, 2020

Changes in this version

+ type DataForwardEnvelope struct

+ Data []byte

+ Metadata object.Metadata

+ Sender crypto.PublicKey

+ func (e *DataForwardEnvelope) FromObject(o *object.Object) error

+ func (e *DataForwardEnvelope) Type() string

+ func (e DataForwardEnvelope) ToObject() *object.Object

+ func (e DataForwardEnvelope) ToObjectMap() map[string]interface{}

+ type DataForwardRequest struct

+ Metadata object.Metadata

+ Payload *object.Object

+ Recipient crypto.PublicKey

+ RequestID string

+ func (e *DataForwardRequest) FromObject(o *object.Object) error

+ func (e *DataForwardRequest) Type() string

+ func (e DataForwardRequest) ToObject() *object.Object

+ func (e DataForwardRequest) ToObjectMap() map[string]interface{}

+ type DataForwardResponse struct

+ Metadata object.Metadata

+ RequestID string

+ Success bool

+ func (e *DataForwardResponse) FromObject(o *object.Object) error

+ func (e *DataForwardResponse) Type() string

+ func (e DataForwardResponse) ToObject() *object.Object

+ func (e DataForwardResponse) ToObjectMap() map[string]interface{}

type EnvelopeFilter

+ func FilterByRequestID(requestID string) EnvelopeFilter

type EnvelopeSubscription

+ Channel func() <-chan *Envelope

Nov 23, 2020

Changes in this version

type DataForward

+ func (e DataForward) ToObjectMap() map[string]interface{}

Oct 25, 2020

Changes in this version

type DataForward

+ func (e *DataForward) Type() string

Sep 14, 2020

Changes in this version

+ const ErrAlreadySentDuringContext

+ const ErrInvalidRequest

+ const ErrSendingTimedOut

+ var ErrCannotSendToSelf = errors.New("cannot send objects to ourself")

+ var ErrNotFound = errors.New("not found")

+ func HandleEnvelopeSubscription(sub EnvelopeSubscription, handler func(*Envelope) error)

+ func ListenOnExternalPort(c *listenConfig)

+ func ListenOnIPV6(c *listenConfig)

+ func ListenOnLocalIPs(c *listenConfig)

+ func ListenOnPrivateIPs(c *listenConfig)

+ func WithLocalPeer(k localpeer.LocalPeer) func(*network)

+ type DataForward struct

+ Data []byte

+ Ephermeral crypto.PublicKey

+ Metadata object.Metadata

+ Recipient crypto.PublicKey

+ func (e *DataForward) FromObject(o object.Object) error

+ func (e DataForward) GetSchema() *object.SchemaObject

+ func (e DataForward) GetType() string

+ func (e DataForward) IsStreamRoot() bool

+ func (e DataForward) ToObject() object.Object

+ type Envelope struct

+ Payload object.Object

+ Sender crypto.PublicKey

+ type EnvelopeFilter func(*Envelope) bool

+ func FilterByNonce(nonce string) EnvelopeFilter

+ func FilterByObjectHash(objectHashes ...object.Hash) EnvelopeFilter

+ func FilterByObjectType(typePatterns ...string) EnvelopeFilter

+ func FilterBySender(keys ...crypto.PublicKey) EnvelopeFilter

+ type EnvelopePubSub interface

+ Publish func(*Envelope)

+ Subscribe func(...EnvelopeFilter) EnvelopeSubscription

+ func NewEnvelopePubSub() EnvelopePubSub

+ type EnvelopeSubscription interface

+ Cancel func()

+ Next func() (*Envelope, error)

+ type ListenOption func(c *listenConfig)

+ type MockEnvelopeSubscription struct

+ func (s *MockEnvelopeSubscription) AddNext(env *Envelope, err error)

+ func (s *MockEnvelopeSubscription) Cancel()

+ func (s *MockEnvelopeSubscription) Next() (*Envelope, error)

+ type Network interface

+ Listen func(ctx context.Context, bindAddress string, options ...ListenOption) (net.Listener, error)

+ LocalPeer func() localpeer.LocalPeer

+ Send func(ctx context.Context, object object.Object, recipient *peer.Peer) error

+ Subscribe func(filters ...EnvelopeFilter) EnvelopeSubscription

+ func New(ctx context.Context, opts ...Option) Network

+ type Option func(*network)

+ type OutboxesMap struct

+ func NewOutboxesMap() *OutboxesMap

+ func (m *OutboxesMap) Delete(k crypto.PublicKey)

+ func (m *OutboxesMap) Get(k crypto.PublicKey) (*outbox, bool)

+ func (m *OutboxesMap) GetOrPut(k crypto.PublicKey, v *outbox) (*outbox, bool)

+ func (m *OutboxesMap) ListKeys() []crypto.PublicKey

+ func (m *OutboxesMap) ListValues() []*outbox

+ func (m *OutboxesMap) Put(k crypto.PublicKey, v *outbox)

+ func (m *OutboxesMap) Range(i func(k crypto.PublicKey, v *outbox) bool)