sngecomm

Documentation

Overview

Package sngecomm provides common functionality used in the stompngo_examples project.

Package sngecomm provides common functionality used in the stompngo_examples project.

Index

• Constants
• Variables
• func AckMode() string
• func CommonConnect(exampid, tag string, l *log.Logger) (net.Conn, *stompngo.Connection, error)
• func CommonDisconnect(n net.Conn, conn *stompngo.Connection, exampid, tag string, l *log.Logger) error
• func CommonTLSConnect(exampid, tag string, l *log.Logger, c *tls.Config) (net.Conn, *stompngo.Connection, error)
• func ConnectHeaders() stompngo.Headers
• func Cpuprof() string
• func CustomCiphers() []uint16
• func Dest() string
• func DumpTLSConfig(exampid string, c *tls.Config, n *tls.Conn)
• func Gorsleep() string
• func HandleAck(c *stompngo.Connection, h stompngo.Headers, id string)
• func HandleSubscribe(c *stompngo.Connection, d, i, a string) <-chan stompngo.MessageData
• func HandleUnsubscribe(c *stompngo.Connection, d, i string)
• func Logger() string
• func Mdml() int
• func Memprof() string
• func Ngors() int
• func Nqs() int
• func Partial() []byte
• func PartialSubstr(l int) []byte
• func Pbc() int
• func Pprof() bool
• func RecvFactor() float64
• func RecvWait() bool
• func SendFactor() float64
• func SendWait() bool
• func ServerIdent(c *stompngo.Connection) string
• func SetLogger(conn *stompngo.Connection)
• func SetMAXPROCS() bool
• func ShowRunParms(exampid string)
• func ShowStats(exampid, tag string, conn *stompngo.Connection)
• func UseCustomCiphers() bool
• func UseEOF() bool
• func ValueBetween(min, max int64, fact float64) int64

Constants

const (
	// EOFMsg is the EOF message body
	EOFMsg = "STOMP_EOF"
)

Variables

var (
	Lcs = "NotAvailable"
)

Functions

func AckMode

func AckMode() string

AckMode returns an ACK mode value for those examples that use it.

func CommonConnect

func CommonConnect(exampid, tag string, l *log.Logger) (net.Conn,
	*stompngo.Connection,
	error)

Common example connect logic

func CommonDisconnect

func CommonDisconnect(n net.Conn, conn *stompngo.Connection,
	exampid, tag string,
	l *log.Logger) error

Common example disconnect logic

func CommonTLSConnect

func CommonTLSConnect(exampid, tag string, l *log.Logger,
	c *tls.Config) (net.Conn, *stompngo.Connection, error)

Common example TLS connect logic

func ConnectHeaders

func ConnectHeaders() stompngo.Headers

Provide connect headers

func Cpuprof

func Cpuprof() string

Cpuprof returns the CPU profile file name

func CustomCiphers

func CustomCiphers() []uint16

CustomCiphers returns a slice of custom ciphers

func Dest

func Dest() string

Example destination

func DumpTLSConfig

func DumpTLSConfig(exampid string, c *tls.Config, n *tls.Conn)

Dump a TLS Configuration Struct

func Gorsleep

func Gorsleep() string

Gorsleep returns an indication of whether go routines will sleep or not

func HandleAck

func HandleAck(c *stompngo.Connection, h stompngo.Headers, id string)

Handle ACKs for the different protocol levels.

func HandleSubscribe

func HandleSubscribe(c *stompngo.Connection, d, i, a string) <-chan stompngo.MessageData

Handle a subscribe for the different protocol levels.

func HandleUnsubscribe

func HandleUnsubscribe(c *stompngo.Connection, d, i string)

Handle a unsubscribe for the different protocol levels.

func Logger

func Logger() string

Logger returns an indication of whether to do logging

func Mdml

func Mdml() int

Mdml sets the Max Data Message Length

func Memprof

func Memprof() string

Memprof returns the memory profile file name

func Ngors

func Ngors() int

Ngors sets the number of go routines

func Nqs

func Nqs() int

Nqs sets the number of queues

func Partial

func Partial() []byte

Partial returns the partial byte slice for logging, random length

func PartialSubstr

func PartialSubstr(l int) []byte

PartialSubstr returns the partial string for logging, fixed length

func Pbc

func Pbc() int

Pbc returns the byte count to log

func Pprof

func Pprof() bool

Pprof indicates whether to use profiling or not

func RecvFactor

func RecvFactor() float64

RecvFactor returns the recv sleep factor

func RecvWait

func RecvWait() bool

RecvWait indicates whether to wait in receives to simulate message processing

func SendFactor

func SendFactor() float64

SendFactor returns the send sleep factor

func SendWait

func SendWait() bool

SendWait indicates whether to wait in sends to simulate message processing

func ServerIdent

func ServerIdent(c *stompngo.Connection) string

Return broker identity

func SetLogger

func SetLogger(conn *stompngo.Connection)

Set Logger

func SetMAXPROCS

func SetMAXPROCS() bool

SetMAXPROCS returns true if max procs are to be set

func ShowRunParms

func ShowRunParms(exampid string)

func ShowStats

func ShowStats(exampid, tag string, conn *stompngo.Connection)

Show connection metrics.

func UseCustomCiphers

func UseCustomCiphers() bool

UseCustomCiphers returns true if custom ciphers are to be used

func UseEOF

func UseEOF() bool

UseEOF returns true if en EOF message is to be used.

func ValueBetween

func ValueBetween(min, max int64, fact float64) int64

Get a value between min amd max