Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
var (
ErrSyncNotComplete = fmt.Errorf("sync exited without finishing")
)
Functions ¶
This section is empty.
Types ¶
type Action ¶
type Action struct { Op ActionOp `json:"operation,omitempty"` PageToken string `json:"page_token,omitempty"` ResourceTypeID string `json:"resource_type_id,omitempty"` ResourceID string `json:"resource_id,omitempty"` ParentResourceTypeID string `json:"parent_resource_type_id,omitempty"` ParentResourceID string `json:"parent_resource_id,omitempty"` }
Action stores the current operation, page token, and optional fields for which resource is being worked with.
type ActionOp ¶
type ActionOp uint8
ActionOp represents a sync operation.
func (*ActionOp) MarshalJSON ¶
MarshalJSON marshals the ActionOp insto a json string.
func (ActionOp) String ¶
String() returns the string representation for an ActionOp. This is used for marshalling the op.
func (*ActionOp) UnmarshalJSON ¶
UnmarshalJSON unmarshal's the input byte slice and updates this action op.
type Progress ¶ added in v0.0.25
type Progress struct { Action string ResourceTypeID string ResourceID string ParentResourceTypeID string ParentResourceID string Count uint32 }
func NewProgress ¶ added in v0.0.25
type State ¶
type State interface { PushAction(ctx context.Context, action Action) FinishAction(ctx context.Context) NextPage(ctx context.Context, pageToken string) error ResourceTypeID(ctx context.Context) string ResourceID(ctx context.Context) string ParentResourceID(ctx context.Context) string ParentResourceTypeID(ctx context.Context) string PageToken(ctx context.Context) string Current() *Action Marshal() (string, error) Unmarshal(input string) error }
type SyncOpt ¶
type SyncOpt func(s *syncer)
func WithC1ZPath ¶ added in v0.1.0
func WithConnectorStore ¶ added in v0.1.0
func WithConnectorStore(store connectorstore.Writer) SyncOpt
func WithProgressHandler ¶ added in v0.0.25
WithProgress sets a `progressHandler` for `NewSyncer` Options.
func WithRunDuration ¶
WithRunDuration sets a `time.Duration` for `NewSyncer` Options. `d` represents a duration. The elapsed time between two instants as an int64 nanosecond count.
func WithTransitionHandler ¶
WithTransitionHandler sets a `transitionHandler` for `NewSyncer` Options.