pyrecordbase

README

crecordbase

Documentation

Index

• Variables
• type Entry
• type FileInfo
• type Instance
  • func Connect(endpoint, token string, timeoutMillis int) (*Instance, error)
  • func (t *Instance) Close()
  • func (t *Instance) Get(tenant, primaryKey string, timeoutMillis int) (string, error)
  • func (t *Instance) Merge(msgEntry string, timeoutMillis int) error
  • func (t *Instance) Replace(msgEntry string, timeoutMillis int) error

Variables

var (
	EnvPrefix = "$"
	TLSPrefix = "tls://"
)

Types

type Entry

type Entry struct {
	Tenant     string              `json:"tenant,omitempty"`
	PrimaryKey string              `json:"primary_key,omitempty"`
	Version    int64               `json:"version,omitempty"`
	CreatedAt  int64               `json:"created_at,omitempty"`
	UpdatedAt  int64               `json:"updated_at,omitempty"`
	DeletedAt  int64               `json:"deleted_at,omitempty"`
	Attributes map[string]string   `json:"attributes,omitempty"`
	Tags       []string            `json:"tags,omitempty"`
	Bins       map[string][]byte   `json:"columns,omitempty"`
	Files      map[string]FileInfo `json:"files,omitempty"`
}

type FileInfo

type FileInfo struct {
	Name      string `json:"name,omitempty"` // could be a path
	Data      []byte `json:"data,omitempty"`
	Size      int32  `json:"size,omitempty"`
	CreatedAt int64  `json:"created_at,omitempty"`
	UpdatedAt int64  `json:"updated_at,omitempty"`
	DeletedAt int64  `json:"deleted_at,omitempty"`
}

type Instance

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

func Connect

func Connect(endpoint, token string, timeoutMillis int) (*Instance, error)

func (*Instance) Close

func (t *Instance) Close()

func (*Instance) Get

func (t *Instance) Get(tenant, primaryKey string, timeoutMillis int) (string, error)

func (*Instance) Merge

func (t *Instance) Merge(msgEntry string, timeoutMillis int) error

func (*Instance) Replace

func (t *Instance) Replace(msgEntry string, timeoutMillis int) error