transaction

package

v0.0.4 Latest Latest Go to latest Published: Nov 6, 2019 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/brunotm/replicant

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func Register(typ string, supplier Supplier) (err error)
type CallBackConfig
type Config
type Result
- func (r *Result) MarshalJSON() (data []byte, err error)
- func (r *Result) UnmarshalJSON(data []byte) error
type Supplier
type Transaction
- func New(config Config) (tx Transaction, err error)

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	// ErrInvalidType invalid transaction type
	ErrInvalidType = errors.New("invalid transaction type")
	// ErrTransactionNotFound transaction not found
	ErrTransactionNotFound = errors.New("transaction not found")
)

Functions ¶

func Register ¶

func Register(typ string, supplier Supplier) (err error)

Register suppliers for transaction types

Types ¶

type CallBackConfig ¶

type CallBackConfig struct {
	Type   string `json:"type" yaml:"type"`
	Script string `json:"script" yaml:"script"`
}

CallBackConfig configuration for receiving async transaction responses

type Config ¶

type Config struct {
	Name       string                 `json:"name" yaml:"name"`
	Type       string                 `json:"type" yaml:"type"`
	Schedule   string                 `json:"schedule" yaml:"schedule"`
	Timeout    string                 `json:"timeout" yaml:"timeout"`
	RetryCount int                    `json:"retry_count" yaml:"retry_count"`
	Script     string                 `json:"script" yaml:"script"`
	CallBack   *CallBackConfig        `json:"callback" yaml:"callback"`
	Inputs     map[string]interface{} `json:"inputs" yaml:"inputs"`
	Metadata   map[string]string      `json:"metadata" yaml:"metadata"`
}

Config is a synthetic test definition

type Result ¶

type Result struct {
	Name            string            `json:"name" yaml:"name"`
	Type            string            `json:"type" yaml:"type"`
	Failed          bool              `json:"failed" yaml:"failed"`
	Message         string            `json:"message" yaml:"message"`
	Data            string            `json:"data" yaml:"data"`
	Time            time.Time         `json:"time" yaml:"time"`
	Error           error             `json:"-" yaml:"-"`
	Metadata        map[string]string `json:"metadata" yaml:"metadata"`
	RetryCount      int               `json:"retry_count" yaml:"retry_count"`
	WithCallback    bool              `json:"with_callback" yaml:"with_callback"`
	DurationSeconds float64           `json:"duration_seconds" yaml:"duration_seconds"`
}

Result represents a transaction execution result

func (*Result) MarshalJSON ¶ added in v0.0.2

func (r *Result) MarshalJSON() (data []byte, err error)

MarshalJSON is custom marshaler for result

func (*Result) UnmarshalJSON ¶ added in v0.0.2

func (r *Result) UnmarshalJSON(data []byte) error

UnmarshalJSON is custom unmarshaler for result

type Supplier ¶

type Supplier func(Config) (Transaction, error)

Supplier is a Transaction Supplier

type Transaction ¶

type Transaction interface {
	Run(ctx context.Context) (result Result)
	Config() (config Config)
}

Transaction is a test executor. It can be run many times.

func New ¶

func New(config Config) (tx Transaction, err error)

New creates a transaction from a config

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
callback
manager

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL