python

Documentation

Index

• Constants
• type ClientBuilder
  • func NewClientBuilder(name string, command PythonClientCmd, ctx framework.ContextData, url string) *ClientBuilder
  • func (s *ClientBuilder) Build() *PythonClient
  • func (s *ClientBuilder) EnableTracing() *ClientBuilder
  • func (s *ClientBuilder) EnvVar(variable, value string) *ClientBuilder
  • func (s *ClientBuilder) ImageCustom(image string) *ClientBuilder
  • func (s *ClientBuilder) Timeout(timeout int) *ClientBuilder
• type PythonClient
  • func DeployPythonClient(ctx *framework.ContextData, icName, clientName, address string, debug bool, ...) []*PythonClient
  • func (p *PythonClient) Result() amqp.ResultData
• type PythonClientCmd
• type PythonClientResult

Constants

const (
	PythonClientImage string          = "docker.io/qdrshipshape/clients-python:latest"
	BasicSender       PythonClientCmd = "basic.sender.py"
	BasicReceiver     PythonClientCmd = "basic.receiver.py"
)

Types

type ClientBuilder

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

func NewClientBuilder

func NewClientBuilder(name string, command PythonClientCmd, ctx framework.ContextData, url string) *ClientBuilder

func (*ClientBuilder) Build

func (s *ClientBuilder) Build() *PythonClient

func (*ClientBuilder) EnableTracing

func (s *ClientBuilder) EnableTracing() *ClientBuilder

func (*ClientBuilder) EnvVar

func (s *ClientBuilder) EnvVar(variable, value string) *ClientBuilder

func (*ClientBuilder) ImageCustom

func (s *ClientBuilder) ImageCustom(image string) *ClientBuilder

func (*ClientBuilder) Timeout

func (s *ClientBuilder) Timeout(timeout int) *ClientBuilder

type PythonClient

type PythonClient struct {
	amqp.AmqpClientCommon
}

func DeployPythonClient

func DeployPythonClient(ctx *framework.ContextData, icName, clientName, address string, debug bool, command PythonClientCmd, numberOfClients, msgCount, msgSize, timeout int) []*PythonClient

func (*PythonClient) Result

func (p *PythonClient) Result() amqp.ResultData

type PythonClientCmd

type PythonClientCmd string

type PythonClientResult

type PythonClientResult struct {
	Delivered int    `json:"delivered"`
	Released  int    `json:"released"`
	Rejected  int    `json:"rejected"`
	Modified  int    `json:"modified"`
	Accepted  int    `json:"accepted"`
	ErrorMsg  string `json:"errormsg"`
}