store

Documentation

Index

• type TableStore
  • func NewTableStore(objectStoreClient *client.ObjectStoreClient) *TableStore
  • func (s *TableStore) GetFileSubPath(owner *ent.Owner, kaskadaTable *ent.KaskadaTable, fileType string) string
  • func (s *TableStore) GetPrepareOutputURI(owner *ent.Owner, kaskadaTable *ent.KaskadaTable, KaskadaFile *ent.KaskadaFile, ...) string
  • func (s *TableStore) GetTableSubPath(owner *ent.Owner, kaskadaTable *ent.KaskadaTable) string

Types

type TableStore

type TableStore struct {
	// contains filtered or unexported fields
}

TableStore is a wrapper around the store

func NewTableStore

func NewTableStore(objectStoreClient *client.ObjectStoreClient) *TableStore

NewTableStore returns a new table store

func (*TableStore) GetFileSubPath

func (s *TableStore) GetFileSubPath(owner *ent.Owner, kaskadaTable *ent.KaskadaTable, fileType string) string

returns tables/<owner_id>/table-id/data/file-id.file-type

func (*TableStore) GetPrepareOutputURI

func (s *TableStore) GetPrepareOutputURI(owner *ent.Owner, kaskadaTable *ent.KaskadaTable, KaskadaFile *ent.KaskadaFile, prepareVersion int32, slicePlanHash []byte) string

returns the tables/<owner_id>/table-id/prepared/prepare-version/hash(slice_plan)/file_id/

func (*TableStore) GetTableSubPath

func (s *TableStore) GetTableSubPath(owner *ent.Owner, kaskadaTable *ent.KaskadaTable) string

returns tables/<owner_id>/table-id