db

type DbConnection struct {
	Server     string
	Username   string
	Password   string
	Bucket     string
	NumRetries int
	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 Interface interface {
	Initialize() error
	GetHistory(deviceId string) ([]Event, error)
	GetTombstone(deviceId string) (map[string]Event, error)
	RemoveHistory(deviceId string, numToRemove int) error
	InsertEvent(deviceId string, event Event, tombstoneKey string) error
	RemoveAll() error
}

type Tombstone struct {
	Events map[string]Event `json:"events"`
}