storerecord

Documentation

Index

• func CreateEventEntityFromRecord(record StoreRecord) *storage.Entity
• func CreateValidKey(key string) string
• func IsDataEntity(e *storage.Entity) bool
• func IsEventEntity(e *storage.Entity) bool
• func IsRowEntity(e *storage.Entity) bool
• func RevToString(rev int64) string
• func StringToRev(revString string) int64
• func ValidKeyToKey(key string) string
• type StoreRecord
  • func NewForDeleted(rev int64, old StoreRecord) (StoreRecord, error)
  • func NewForUpdate(rev int64, newVal []byte, old StoreRecord, lease int64) (StoreRecord, error)
  • func NewFromEntities(entities []*storage.Entity, ignoreDataRows bool) (StoreRecord, error)
  • func NewFromRowAndDataEntities(rowEntity *storage.Entity, dataEntities []*storage.Entity) (StoreRecord, error)
  • func NewRecord(key string, rev int64, lease int64, value []byte) (StoreRecord, error)

Functions

func CreateEventEntityFromRecord

func CreateEventEntityFromRecord(record StoreRecord) *storage.Entity

func CreateValidKey

func CreateValidKey(key string) string

azure storage table partition key has to be valid e.g. no /

func IsDataEntity

func IsDataEntity(e *storage.Entity) bool

func IsEventEntity

func IsEventEntity(e *storage.Entity) bool

func IsRowEntity

func IsRowEntity(e *storage.Entity) bool

func RevToString

func RevToString(rev int64) string

azure storage partitionkey and row key fields are string. in order for < > operation to work revisions needs to be padded

func StringToRev

func StringToRev(revString string) int64

func ValidKeyToKey

func ValidKeyToKey(key string) string

Types

type StoreRecord

type StoreRecord interface {
	types.Record
	RowEntity() *storage.Entity
	DataEntities() []*storage.Entity
}

func NewForDeleted

func NewForDeleted(rev int64, old StoreRecord) (StoreRecord, error)

create a deleted record based on existing record

func NewForUpdate

func NewForUpdate(rev int64, newVal []byte, old StoreRecord, lease int64) (StoreRecord, error)

creates a new record for update and modify old record accordingly

func NewFromEntities

func NewFromEntities(entities []*storage.Entity, ignoreDataRows bool) (StoreRecord, error)

func NewFromRowAndDataEntities

func NewFromRowAndDataEntities(rowEntity *storage.Entity, dataEntities []*storage.Entity) (StoreRecord, error)

creates a new record from a row and data entities

func NewRecord

func NewRecord(key string, rev int64, lease int64, value []byte) (StoreRecord, error)

create a new record for Insert