Versions in this module Expand all Collapse all v0 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{})
Go to main page