sync

Documentation

Overview

Package sync provides a way to synchronize items from a source to the server.

Index

• Constants
• Variables
• type ID
  • func NewSyncID() *ID
  • func ParseSyncID(id string) *ID
  • func (s *ID) Intercept(_ context.Context, req *http.Request) error
  • func (s *ID) String() string
• type Syncer
  • func NewSyncer(id *ID, sourcer sourcer.Sourcer, c *api.ClientWithResponses, l *slog.Logger, ...) (*Syncer, error)
  • func (s *Syncer) Sync(ctx context.Context, livemode bool) error

Constants

const (
	MetadataKeySyncID     = "sync_id"
	MetadataKeySyncSource = "sync_source"
)

const (
	HeaderSyncID = "X-Sync-Id"
)

Variables

var (
	ErrUnexpectedStatusCode = errors.New("unexpected status code")
)

Types

type ID

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

func NewSyncID

func NewSyncID() *ID

func ParseSyncID

func ParseSyncID(id string) *ID

func (*ID) Intercept

func (s *ID) Intercept(_ context.Context, req *http.Request) error

Intercept will attach an X-Sync-Id header to the request and ensures that the sync ID is attached to the header.

func (*ID) String

func (s *ID) String() string

type Syncer

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

Syncer synchronizes items from a source to the server.

func NewSyncer

func NewSyncer(
	id *ID,
	sourcer sourcer.Sourcer,
	c *api.ClientWithResponses,
	l *slog.Logger,
	config *parser.Config,
) (*Syncer, error)

NewSyncer returns a new syncer.

func (*Syncer) Sync

func (s *Syncer) Sync(ctx context.Context, livemode bool) error

Sync synchronizes items from a source to the server.