bridge

package
v0.6.5 Latest Latest
Warning

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

Go to latest
Published: Aug 26, 2024 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Bridge

type Bridge struct {
	// contains filtered or unexported fields
}

func New

func New(
	bridges []*config.Bridge,
	triggerCfg *config.TriggerSync,
	log logger.Logger,
) *Bridge

func (*Bridge) BulkSync

func (b *Bridge) BulkSync(ctx context.Context, isContinue bool) error

func (*Bridge) Sync

func (b *Bridge) Sync(ctx context.Context) error

func (*Bridge) TriggerSync added in v0.6.0

func (b *Bridge) TriggerSync(ctx context.Context) error

type Queue added in v0.6.0

type Queue struct {
	// contains filtered or unexported fields
}

func (*Queue) Add added in v0.6.0

func (q *Queue) Add(item types.TriggerRequestBody)

func (*Queue) Process added in v0.6.0

func (q *Queue) Process(ctx context.Context, processFunc func(ctx context.Context, i types.TriggerRequestBody) (bool, error))

type Syncer added in v0.2.0

type Syncer interface {
	Name() string
	OnDemand(ctx context.Context)
	Bulk(ctx context.Context, isContinue bool)
	Trigger() http.HandlerFunc
}

Jump to

Keyboard shortcuts

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