smpperf

README

smpperf

SMPP load testing and performance evaluation

smppclient

Simple client which accepts a message as a config.toml file.

go install cmd/smppclient.go

smppclient config.toml

This will read the config from the current directory and send the defined message.

Documentation

Index

• type ConcurrentIntMap
  • func NewConcurrentIntMap() *ConcurrentIntMap
  • func (m *ConcurrentIntMap) Create(key interface{})
  • func (m *ConcurrentIntMap) Get(key interface{}) (*SafeInt, bool)
  • func (m *ConcurrentIntMap) GetAll() map[interface{}]int
  • func (m *ConcurrentIntMap) Increment(key interface{})
  • func (m *ConcurrentIntMap) Keys() []interface{}
• type ConcurrentStringMap
  • func NewConcurrentStringMap() *ConcurrentStringMap
  • func (m *ConcurrentStringMap) Delete(key string)
  • func (m *ConcurrentStringMap) Get(key string) (string, bool)
  • func (m *ConcurrentStringMap) Keys() []string
  • func (m *ConcurrentStringMap) Set(key string, value string)
• type SMPPerf
  • func (s *SMPPerf) Purge()
  • func (s *SMPPerf) SendMessages()
• type SafeInt
  • func NewSafeInt(n int) *SafeInt
  • func (s *SafeInt) Increment()
  • func (s *SafeInt) Val() int
• type Semaphore
  • func NewSemaphore(n int) *Semaphore
  • func (s *Semaphore) Decrease()
  • func (s *Semaphore) Increase()
  • func (s *Semaphore) IncreaseN(n int)

Types

type ConcurrentIntMap

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

func NewConcurrentIntMap

func NewConcurrentIntMap() *ConcurrentIntMap

func (*ConcurrentIntMap) Create

func (m *ConcurrentIntMap) Create(key interface{})

func (*ConcurrentIntMap) Get

func (m *ConcurrentIntMap) Get(key interface{}) (*SafeInt, bool)

func (*ConcurrentIntMap) GetAll

func (m *ConcurrentIntMap) GetAll() map[interface{}]int

func (*ConcurrentIntMap) Increment

func (m *ConcurrentIntMap) Increment(key interface{})

func (*ConcurrentIntMap) Keys

func (m *ConcurrentIntMap) Keys() []interface{}

type ConcurrentStringMap

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

func NewConcurrentStringMap

func NewConcurrentStringMap() *ConcurrentStringMap

func (*ConcurrentStringMap) Delete

func (m *ConcurrentStringMap) Delete(key string)

func (*ConcurrentStringMap) Get

func (m *ConcurrentStringMap) Get(key string) (string, bool)

func (*ConcurrentStringMap) Keys

func (m *ConcurrentStringMap) Keys() []string

func (*ConcurrentStringMap) Set

func (m *ConcurrentStringMap) Set(key string, value string)

type SMPPerf

type SMPPerf struct {
	NumMessages int
	NumSessions int
	MessageRate int
	MessageText string
	Wait        int
	User        string
	Password    string
	Host        string
	Mode        string
	Dst         int
	Src         string
	Verbose     bool
	// contains filtered or unexported fields
}

func (*SMPPerf) Purge

func (s *SMPPerf) Purge()

func (*SMPPerf) SendMessages

func (s *SMPPerf) SendMessages()

type SafeInt

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

func NewSafeInt

func NewSafeInt(n int) *SafeInt

func (*SafeInt) Increment

func (s *SafeInt) Increment()

func (*SafeInt) Val

func (s *SafeInt) Val() int

type Semaphore

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

func NewSemaphore

func NewSemaphore(n int) *Semaphore

func (*Semaphore) Decrease

func (s *Semaphore) Decrease()

func (*Semaphore) Increase

func (s *Semaphore) Increase()

func (*Semaphore) IncreaseN

func (s *Semaphore) IncreaseN(n int)