db

type Connection struct {
	Server   string
	Username string
	Password string
	Bucket   string
	// number of times to try when initially connecting to the database
	NumRetries int
	// the time duration to add when creating TTLs for history documents
	Timeout time.Duration
	// contains filtered or unexported fields
}

type Event struct {
	// the id for the event
	//
	// required: true
	ID string `json:"id"`

	// the time this event was found
	//
	// required: true
	Time int64 `json:"time"`

	// the source of this event
	//
	// required: true
	Source string `json:"src"`

	// the destination of this event
	//
	// required: true
	Destination string `json:"dest"`

	// the partners related to this device
	//
	// required: true
	PartnerIDs []string `json:"partner_ids"`

	// the transaction id for this event
	//
	// required: true
	TransactionUUID string `json:"transaction_uuid,omitempty"`

	// payload
	//
	// required: false
	Payload []byte `json:"payload,omitempty"`

	// other metadata and details related to this state
	//
	// required: true
	Details map[string]interface{} `json:"details"`
}

type History struct {
	// the list of events from newest to oldest
	Events []Event `json:"events"`
}

type Interface interface {
	Initialize() error
	GetHistory(deviceID string) (History, error)
	GetTombstone(deviceID string) (map[string]Event, error)
	UpdateHistory(deviceID string, events []Event) error
	InsertEvent(deviceID string, event Event, tombstoneKey string) error
	RemoveAll() error
}