transaction

Documentation

Index

• type Operation
  • func NewOperation(colName string, content interface{}, key, val []byte, del, cleanHistory bool) *Operation
• type Transaction
  • func New(ctx context.Context) *Transaction
  • func NewWithOperation(ctx context.Context, op *Operation) *Transaction
  • func (t *Transaction) AddOperation(op *Operation)
  • func (t *Transaction) GetWriteSize() (ret int)

Types

type Operation

type Operation struct {
	CollectionID string
	Content      interface{}

	DBKey, Value         []byte
	Delete, CleanHistory bool
}

Operation defines the real writes to be done

func NewOperation

func NewOperation(colName string, content interface{}, key, val []byte, del, cleanHistory bool) *Operation

NewOperation returns a new operation pointer

type Transaction

type Transaction struct {
	Ctx context.Context

	Operations []*Operation

	ResponseChan chan error
}

Transaction defines the struct to manage sequential writes

func New

func New(ctx context.Context) *Transaction

New builds a new write transaction struct with it's chanel

func NewWithOperation

func NewWithOperation(ctx context.Context, op *Operation) *Transaction

NewWithOperation build a new transaction based on an Operation pointer

func (*Transaction) AddOperation

func (t *Transaction) AddOperation(op *Operation)

AddOperation add a new operation to the given transaction

func (*Transaction) GetWriteSize

func (t *Transaction) GetWriteSize() (ret int)

GetWriteSize returns the length of bytes this transaction wants to write