python

package

v0.1.0 Latest Latest Go to latest Published: Apr 17, 2020 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/rh-messaging/qdr-shipshape

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type ClientBuilder
- func NewClientBuilder(name string, command PythonClientCmd, ctx framework.ContextData, url string) *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 ¶

View Source

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

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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"`
}

Source Files ¶

View all Source files

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