core

package

Go to main page

Versions in this module

v1

v1.1.0

Dec 22, 2022

Changes in this version

+ const CodeUnknown

+ var BridgeDB BridgeDatabase

+ var BridgeMG BridgeManager

+ var Discover DiscoveryAddressResolver

+ var Intercom IntercomService

type Bridge

+ Close func() error

+ type BridgeCreateParams struct

+ Request *http.Request

+ ResponseHeaders http.Header

+ Writer http.ResponseWriter

+ type BridgeDatabase interface

+ DeleteBridgeForNode func(ctx context.Context, bridgeID string, nodeAddr string) error

+ DeleteBridgesForNode func(ctx context.Context, bridgeIDs []string, nodeAddr string) error

+ GetBridgesByClientIDs func(ctx context.Context, clientIDs []string) ([]*BridgeDoc, error)

+ InsertBridge func(ctx context.Context, doc *BridgeDoc) error

+ type BridgeDoc struct

+ BridgeID string

+ ClientID string

+ ConnectedAt time.Time

+ NodeAddr string

+ type BridgeIdentityInfo struct

+ BridgeID string

+ ClientID string

+ type BridgeManager interface

+ CreateBridge func(ctx context.Context, params *BridgeCreateParams) (Bridge, error)

+ DeleteBridgeByID func(ctx context.Context, bridgeID string)

+ GetBridgeByID func(ctx context.Context, bridgeID string) Bridge

+ GetBridgesByClientID func(ctx context.Context, clientID string) []Bridge

type CodeAndReason

+ func (c *CodeAndReason) Error() string

+ type DiscoveryAddressResolver interface

+ Read func(ctx context.Context) (string, error)

+ type IntercomService interface

+ SendMessageInternal func(ctx context.Context, nodeAddr string, request *OutgoingMessageInternalReq) (*OutgoingMessageInternalRes, error)

+ type OutgoingMessageInternalReq struct

+ BridgeIIs []*BridgeIdentityInfo

+ Message string

+ SenderID string

+ type OutgoingMessageInternalRes struct

+ Report []*BridgeStatus

+ func SendMessageInternal(ctx context.Context, req *OutgoingMessageInternalReq) (*OutgoingMessageInternalRes, error)

type OutgoingMessageReq

+ SenderID string

type OutgoingMessageRes

+ Report map[string][]*BridgeStatus

+ func SendMessage(ctx context.Context, request *OutgoingMessageReq) (*OutgoingMessageRes, error)

v1.0.1

Jul 5, 2022

v1.0.0

Jul 5, 2022

Changes in this version

+ const CodeBridgeNotFound

+ const CodeOK

+ const CodeOffline

+ const MessageErrorRes

+ const MessageIncomingReq

+ const MessageOutgoingReq

+ const MessageOutgoingRes

+ const PersistFalse

+ const PersistIfError

+ const PersistTrue

+ var DM = &dependencyManager

+ type Bridge interface

+ Identify func() *BridgeIdentity

+ SendMessage func(ctx context.Context, message *BridgeMessage) error

+ SetCloseHandler func(handler func(err error))

+ SetErrorHandler func(handler func(err error))

+ SetMessageHandler func(handler func(message *BridgeMessage))

+ func CreateBridge(ctx context.Context, params *CreateBridgeParams) (Bridge, error)

+ type BridgeDatabaseDoc struct

+ BridgeID string

+ ClientID string

+ ConnectedAt int64

+ NodeAddr string

+ type BridgeIdentity struct

+ BridgeID string

+ ClientID string

+ type BridgeManagerCreateParams struct

+ BridgeLimitPerClient *int

+ BridgeLimitTotal *int

+ Request *http.Request

+ Writer http.ResponseWriter

+ type BridgeMessage struct

+ Body interface{}

+ RequestID string

+ Type string

+ type BridgeStatus struct

+ type CodeAndReason struct

+ Code string

+ Reason string

+ type CreateBridgeParams struct

+ BridgeLimitPerClient *int

+ BridgeLimitTotal *int

+ ClientID string

+ Request *http.Request

+ Writer http.ResponseWriter

+ type GetPersistedMessagesParams struct

+ ClientID string

+ Limit int

+ Skip int

+ type IncomingMessageReq struct

+ Message string

+ Persist string

+ SenderID string

+ type MessageDatabaseDoc struct

+ CreatedAt int64

+ Message string

+ Persist string

+ ReceiverIDs []string

+ RequestID string

+ func GetPersistedMessages(ctx context.Context, params *GetPersistedMessagesParams) ([]*MessageDatabaseDoc, int, error)

+ type OutgoingMessageReq struct

+ Message string

+ Persist string

+ ReceiverIDs []string

+ type OutgoingMessageRes struct

+ Bridges []*BridgeStatus

+ Persistence *CodeAndReason

+ func PostMessage(ctx context.Context, params *PostMessageParams) (*OutgoingMessageRes, error)

+ func PostMessageInternal(ctx context.Context, params *PostMessageInternalParams) (*OutgoingMessageRes, error)

+ type PostMessageInternalParams struct

+ Bridges []*BridgeIdentity

+ ClientID string

+ Message string

+ Persist string

+ RequestID string

+ type PostMessageParams struct

+ ClientID string

+ RequestID string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL