tsm

Documentation

Index

• Constants
• type TSM
  • func New(size int) *TSM
  • func (t *TSM) ID(ctx context.Context) (int, error)
  • func (t *TSM) Put(id int) error
  • func (t *TSM) Receive(id int, timeout time.Duration) (interface{}, error)
  • func (t *TSM) Send(id int, b interface{}) error

Constants

const MaxTransaction = 255

MaxTransaction is the default max number of transactions that can occur concurrently

Types

type TSM

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

TSM is the transaction state manager. It handles passing data to other processes and keeping track of what transactions are currently processed

func New

func New(size int) *TSM

New creates a new transaction manager

func (*TSM) ID

func (t *TSM) ID(ctx context.Context) (int, error)

ID returns the invoke id that was used to save the state of this connection.

func (*TSM) Put

func (t *TSM) Put(id int) error

Put allows the id to be reused in the transaction manager

func (*TSM) Receive

func (t *TSM) Receive(id int, timeout time.Duration) (interface{}, error)

Receive attempts to receive a byte array from the invoked id. If a time out period has passed then an error is returned

func (*TSM) Send

func (t *TSM) Send(id int, b interface{}) error

Send data to invoked id