sync

Documentation

Index

• Constants
• type Task
  • func NewTask(domain, project, action, resourceType string, resource interface{}) (*Task, error)
• type Tombstone
  • func NewTombstone(domain, project, resourceType, resourceID string) *Tombstone

Constants

const (
	PendingStatus = "pending"
	DoneStatus    = "done"
)

const (
	CreateAction = "create"
	UpdateAction = "update"
	DeleteAction = "delete"

	Default = "default"
)

Types

type Task

type Task struct {
	ID           string            `json:"id" bson:"id"`
	Domain       string            `json:"domain" bson:"domain"`
	Project      string            `json:"project" bson:"project"`
	ResourceType string            `json:"resource_type" bson:"resource_type"`
	Resource     []byte            `json:"resource" bson:"resource"`
	Opts         map[string]string `json:"opts" bson:"opts"`
	Action       string            `json:"action" bson:"action"`
	Timestamp    int64             `json:"timestamp" bson:"timestamp"`
	Status       string            `json:"status" bson:"status"`
}

Task is db struct to store sync task

func NewTask

func NewTask(domain, project, action, resourceType string, resource interface{}) (*Task, error)

NewTask return task with domain, project , action , resourceType and resource

type Tombstone

type Tombstone struct {
	ResourceID   string `json:"resource_id" bson:"resource_id"`
	ResourceType string `json:"resource_type" bson:"resource_type"`
	Domain       string `json:"domain" bson:"domain"`
	Project      string `json:"project" bson:"project"`
	Timestamp    int64  `json:"timestamp" bson:"timestamp"`
}

Tombstone is db struct to store the deleted resource information

func NewTombstone

func NewTombstone(domain, project, resourceType, resourceID string) *Tombstone

NewTombstone return tombstone with resourceID,resourceType ,domain and project