shared

package

Go to main page

Versions in this module

v0

v0.4.3

Apr 29, 2016

Changes in this version

+ const MetricGoVersion

+ const MetricMemoryAllocated

+ const MetricMemoryGCEnabled

+ const MetricMemoryNumObjects

v0.4.3-patch

Jul 13, 2016

v0.4.2

Feb 16, 2016

Changes in this version

+ func EscapeJSON(text string) string

v0.4.1

Nov 10, 2015

Changes in this version

+ const SpinPrioritySuspend

+ const SpinTimeHigh

+ const SpinTimeLow

+ const SpinTimeMedium

+ const SpinTimeSuspend

+ func SplitAddress(addressString string, defaultProtocol string) (protocol, host, port string, err error)

type ByteStream

+ func (stream *ByteStream) ResetRead()

type Expect

+ func (e Expect) NonBlocking(t time.Duration, routine func()) bool

+ type Fuse struct

+ func NewFuse() *Fuse

+ func (fuse *Fuse) Activate()

+ func (fuse *Fuse) Burn()

+ func (fuse Fuse) IsBurned() bool

+ func (fuse Fuse) Wait()

+ type Mutex struct

+ func NewMutex(priority SpinPriority) *Mutex

+ func (m *Mutex) IsLocked() bool

+ func (m *Mutex) Lock()

+ func (m *Mutex) Unlock()

v0.4.0

Aug 28, 2015

Changes in this version

+ const MetricGoRoutines

+ const SpinPriorityHigh

+ const SpinPriorityLow

+ const SpinPriorityMedium

+ const SpinPriorityRealtime

+ func DontPanic(callback func())

+ func IndexN(s, sep string, n int) int

+ func IsDisconnectedError(err error) bool

+ func LastIndexN(s, sep string, n int) int

+ func ListFilesByDateMatching(directory string, pattern string) ([]os.FileInfo, error)

+ func Max3I(a, b, c int) int

+ func MaxI(a, b int) int

+ func Min3I(a, b, c int) int

+ func MinI(a, b int) int

+ func SplitPath(filePath string) (dir string, base string, ext string)

type Expect

+ func (e Expect) NotExecuted()

+ type FilesByDate []os.FileInfo

+ func (files FilesByDate) Len() int

+ func (files FilesByDate) Less(a, b int) bool

+ func (files FilesByDate) Swap(a, b int)

+ type SpinPriority uint32

+ type Spinner struct

+ func NewSpinner(priority SpinPriority) Spinner

+ func (spin *Spinner) Reset()

+ func (spin *Spinner) Yield()

+ type WaitGroup struct

+ func (wg *WaitGroup) Active() bool

+ func (wg *WaitGroup) Add(delta int)

+ func (wg *WaitGroup) Done()

+ func (wg *WaitGroup) Inc()

+ func (wg *WaitGroup) IncWhenDone()

+ func (wg *WaitGroup) Reset()

+ func (wg *WaitGroup) Wait()

+ func (wg *WaitGroup) WaitFor(timeout time.Duration) bool

v0.3.2

Jun 22, 2015

Changes in this version

+ const BufferedReaderFlagBigEndian

+ const BufferedReaderFlagDelimiter

+ const BufferedReaderFlagEverything

+ const BufferedReaderFlagMLE

+ const BufferedReaderFlagMLE16

+ const BufferedReaderFlagMLE32

+ const BufferedReaderFlagMLE64

+ const BufferedReaderFlagMLE8

+ const BufferedReaderFlagMLEFixed

+ const BufferedReaderFlagMaskMLE

+ const MetricProcessStart

+ const ParserFlagAppend

+ const ParserFlagContinue

+ const ParserFlagInclude

+ const ParserFlagPop

+ const ParserFlagPush

+ const ParserStateStop

+ var BufferDataInvalid = bufferError("Invalid data")

+ var LowResolutionTimeNow = time.Now()

+ var Metric = metrics

+ var ProcessStartTime time.Time

+ var RuntimeType = TypeRegistry

+ func Btoi(buffer []byte) (uint64, int)

+ func GetMissingMethods(objType reflect.Type, ifaceType reflect.Type) (float32, []interface{})

+ func ItoLen(number uint64) int

+ func Itob(number uint64, buffer []byte) error

+ func Itobe(number uint64, buffer []byte) error

+ func ParseAddress(addr string) (address string, protocol string)

+ func RecoverShutdown()

+ func Unescape(text string) string

+ type BufferReadCallback func(msg []byte, sequence uint64)

+ type BufferedReader struct

+ func NewBufferedReader(bufferSize int, flags BufferedReaderFlags, offsetOrLength int, ...) *BufferedReader

+ func (buffer *BufferedReader) ReadAll(reader io.Reader, callback BufferReadCallback) error

+ func (buffer *BufferedReader) ReadOne(reader io.Reader) (data []byte, seq uint64, more bool, err error)

+ func (buffer *BufferedReader) Reset(sequence uint64)

+ type BufferedReaderFlags byte

+ type ByteStream struct

+ func NewByteStream(capacity int) ByteStream

+ func NewByteStreamFrom(data []byte) ByteStream

+ func (stream *ByteStream) Read(target []byte) (int, error)

+ func (stream *ByteStream) Reset()

+ func (stream *ByteStream) SetCapacity(capacity int)

+ func (stream *ByteStream) Write(source []byte) (int, error)

+ func (stream *ByteStream) WriteByte(source byte) error

+ func (stream *ByteStream) WriteString(source string) (int, error)

+ func (stream ByteStream) Bytes() []byte

+ func (stream ByteStream) Cap() int

+ func (stream ByteStream) Len() int

+ func (stream ByteStream) String() string

+ type Expect struct

+ func NewExpect(t *testing.T) Expect

+ func (e Expect) Equal(val1, val2 interface{}) bool

+ func (e Expect) False(val bool) bool

+ func (e Expect) Geq(val1, val2 interface{}) bool

+ func (e Expect) Greater(val1, val2 interface{}) bool

+ func (e Expect) Leq(val1, val2 interface{}) bool

+ func (e Expect) Less(val1, val2 interface{}) bool

+ func (e Expect) MapEqual(data interface{}, key interface{}, value interface{}) bool

+ func (e Expect) MapGeq(data interface{}, key interface{}, value interface{}) bool

+ func (e Expect) MapGreater(data interface{}, key interface{}, value interface{}) bool

+ func (e Expect) MapLeq(data interface{}, key interface{}, value interface{}) bool

+ func (e Expect) MapLess(data interface{}, key interface{}, value interface{}) bool

+ func (e Expect) MapNeq(data interface{}, key interface{}, value interface{}) bool

+ func (e Expect) MapNotSet(data interface{}, key interface{}) bool

+ func (e Expect) MapSet(data interface{}, key interface{}) bool

+ func (e Expect) Neq(val1, val2 interface{}) bool

+ func (e Expect) Nil(val interface{}) bool

+ func (e Expect) NoError(err error) bool

+ func (e Expect) NotNil(val interface{}) bool

+ func (e Expect) True(val bool) bool

+ type MarshalMap map[string]interface

+ func (mmap MarshalMap) Array(key string) ([]interface{}, error)

+ func (mmap MarshalMap) Bool(key string) (bool, error)

+ func (mmap MarshalMap) Float64(key string) (float64, error)

+ func (mmap MarshalMap) Int(key string) (int, error)

+ func (mmap MarshalMap) Int64(key string) (int64, error)

+ func (mmap MarshalMap) Map(key string) (map[interface{}]interface{}, error)

+ func (mmap MarshalMap) MarshalMap(key string) (MarshalMap, error)

+ func (mmap MarshalMap) Path(key string) (interface{}, bool)

+ func (mmap MarshalMap) String(key string) (string, error)

+ func (mmap MarshalMap) StringArray(key string) ([]string, error)

+ func (mmap MarshalMap) StringArrayMap(key string) (map[string][]string, error)

+ func (mmap MarshalMap) StringMap(key string) (map[string]string, error)

+ func (mmap MarshalMap) Uint64(key string) (uint64, error)

+ func NewMarshalMap() MarshalMap

+ type MetricServer struct

+ func NewMetricServer() *MetricServer

+ func (server *MetricServer) Start(port int)

+ func (server *MetricServer) Stop()

+ type ParsedFunc func([]byte, ParserStateID)

+ type ParserFlag int

+ type ParserStateID uint32

+ type StopListener struct

+ func NewStopListener(address string) (*StopListener, error)

+ func (listen *StopListener) Accept() (net.Conn, error)

+ func (listen *StopListener) Close() error

+ type StopRequestError struct

+ func (err StopRequestError) Error() string

+ type Transition struct

+ func NewTransition(nextState ParserStateID, flags ParserFlag, callback ParsedFunc) Transition

+ type TransitionDirective struct

+ Callback ParsedFunc

+ Flags ParserFlag

+ NextState string

+ State string

+ Token string

+ func ParseTransitionDirective(config string, callbacks map[string]ParsedFunc) (TransitionDirective, error)

+ type TransitionParser struct

+ func NewTransitionParser() TransitionParser

+ func (parser *TransitionParser) Add(stateName string, token string, nextStateName string, flags ParserFlag, ...)

+ func (parser *TransitionParser) AddDirectives(directives []TransitionDirective)

+ func (parser *TransitionParser) AddTransition(stateName string, newTrans Transition, token string)

+ func (parser *TransitionParser) GetStateID(stateName string) ParserStateID

+ func (parser *TransitionParser) GetStateName(id ParserStateID) string

+ func (parser *TransitionParser) Parse(data []byte, state string) ([]byte, ParserStateID)

+ func (parser *TransitionParser) Stop(stateName string, token string, flags ParserFlag, callback ParsedFunc)

+ type TrieNode struct

+ PathLen int

+ Payload interface{}

+ func NewTrie(data []byte, payload interface{}) *TrieNode

+ func (node *TrieNode) Add(data []byte, payload interface{}) *TrieNode

+ func (node *TrieNode) ForEach(callback func(*TrieNode))

+ func (node *TrieNode) Match(data []byte) *TrieNode

+ func (node *TrieNode) MatchStart(data []byte) *TrieNode

+ type TypeRegistry struct

+ func (registry TypeRegistry) GetRegistered(packageName string) []string

+ func (registry TypeRegistry) GetTypeOf(typeName string) reflect.Type

+ func (registry TypeRegistry) New(typeName string) (interface{}, error)

+ func (registry TypeRegistry) Register(typeInstance interface{})

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