Versions in this module Expand all Collapse all v0 v0.0.1 May 19, 2021 Changes in this version + const CloseTimeout + const ConnectionStatusConnected + const ConnectionStatusDisconnected + const ConnectionStatusError + const ExplorerBinaryMessage + const ExplorerTextMessage + const SendBufferSize + var ErrReceiveTimeout = errors.New("timeout waiting for message") + func InsertSyncEventForJobRun(db *gorm.DB, run *models.JobRun) error + type ConnectionStatus string + type ExplorerClient interface + Close func() error + Receive func(context.Context, ...time.Duration) ([]byte, error) + Send func(context.Context, []byte, ...int) + Start func() error + Status func() ConnectionStatus + Url func() url.URL + func NewExplorerClient(url *url.URL, accessKey, secret string, loggingArgs ...bool) ExplorerClient + type NoopExplorerClient struct + func (NoopExplorerClient) Close() error + func (NoopExplorerClient) Receive(context.Context, ...time.Duration) ([]byte, error) + func (NoopExplorerClient) Send(context.Context, []byte, ...int) + func (NoopExplorerClient) Start() error + func (NoopExplorerClient) Status() ConnectionStatus + func (NoopExplorerClient) Url() url.URL + type NoopStatsPusher struct + func (NoopStatsPusher) AllSyncEvents(cb func(models.SyncEvent) error) error + func (NoopStatsPusher) Close() error + func (NoopStatsPusher) GetStatus() ConnectionStatus + func (NoopStatsPusher) GetURL() url.URL + func (NoopStatsPusher) PushNow() + func (NoopStatsPusher) Start() error + type StatsPusher interface + AllSyncEvents func(cb func(models.SyncEvent) error) error + Close func() error + GetStatus func() ConnectionStatus + GetURL func() url.URL + PushNow func() + Start func() error + func NewStatsPusher(db *gorm.DB, explorerClient ExplorerClient, afters ...utils.Afterer) StatsPusher + type SyncJobRunPresenter struct + func (p SyncJobRunPresenter) MarshalJSON() ([]byte, error) + type TxStatus string + const StatusFulfilledRunLog + const StatusNoFulfilledRunLog
Go to main page