types

Jan 28, 2019

Changes in this version

+ var ErrPluginNotFound = errors.New("plugin not found")

type DudMgr

+ func (f DudMgr) GetPlugin(name string) (interface{}, error)

Dec 5, 2018

Changes in this version

type Input

+ Connected func() bool

type Output

+ Connected func() bool

Nov 22, 2018

Changes in this version

type Part

+ IsEmpty func() bool

Oct 30, 2018

Changes in this version

type Cache

+ SetMulti func(items map[string][]byte) error

Sep 16, 2018

Changes in this version

+ var ErrInvalidRateLimitType = errors.New("rate_limit type was not recognised")

+ var ErrRateLimitNotFound = errors.New("rate limit not found")

type DudMgr

+ func (f DudMgr) GetRateLimit(name string) (RateLimit, error)

type Manager

+ GetRateLimit func(name string) (RateLimit, error)

+ type RateLimit interface

+ Access func() (time.Duration, error)

Aug 6, 2018

Changes in this version

type Message

+ Copy func() Message

+ type Metadata interface

+ Copy func() Metadata

+ Delete func(key string) Metadata

+ Get func(key string) string

+ Iter func(f func(k, v string) error) error

+ Set func(key, value string) Metadata

+ type Part interface

+ Copy func() Part

+ DeepCopy func() Part

+ Get func() []byte

+ JSON func() (interface{}, error)

+ Metadata func() Metadata

+ Set func(d []byte) Part

+ SetJSON func(doc interface{}) error

+ SetMetadata func(m Metadata) Part

Aug 2, 2018

Changes in this version

+ type Pipeline interface

+ type PipelineConstructorFunc func() (Pipeline, error)

+ type Processor interface

+ ProcessMessage func(Message) ([]Message, Response)

+ type ProcessorConstructorFunc func() (Processor, error)

Jul 30, 2018

Changes in this version

type Message

+ DeleteMetadata func(key string)

Jul 26, 2018

Changes in this version

type Message

+ GetMetadata func(key string) string

+ IterMetadata func(f func(k, v string) error) error

+ SetMetadata func(key, value string)

Jul 23, 2018

Changes in this version

type Consumer

+ Consume func(<-chan Transaction) error

type Producer

+ TransactionChan func() <-chan Transaction

Jul 4, 2018

Changes in this version

+ var ErrPipeNotFound = errors.New("pipe was not found")

type DudMgr

+ func (f DudMgr) GetPipe(name string) (<-chan Transaction, error)

+ func (f DudMgr) SetPipe(name string, t <-chan Transaction)

+ func (f DudMgr) UnsetPipe(name string, t <-chan Transaction)

type Manager

+ func NoopMgr() Manager

+ GetPipe func(name string) (<-chan Transaction, error)

+ SetPipe func(name string, t <-chan Transaction)

+ UnsetPipe func(name string, t <-chan Transaction)

Jun 28, 2018

Changes in this version

type Message

+ func LockMessage(msg Message, part int) Message

Jun 2, 2018

Changes in this version

type DudMgr

+ ID int

May 15, 2018

Changes in this version

+ type DudMgr struct

+ func (f DudMgr) GetCache(name string) (Cache, error)

+ func (f DudMgr) GetCondition(name string) (Condition, error)

+ func (f DudMgr) RegisterEndpoint(path, desc string, h http.HandlerFunc)

May 10, 2018

Changes in this version

type Message

+ CreatedAt func() time.Time

Mar 26, 2018

Changes in this version

type Message

+ LazyCondition func(label string, cond Condition) bool

Mar 21, 2018

Changes in this version

+ var ErrCacheNotFound = errors.New("cache not found")

+ var ErrConditionNotFound = errors.New("condition not found")

+ var ErrInvalidCacheType = errors.New("cache type was not recognised")

+ var ErrKeyAlreadyExists = errors.New("key already exists")

+ var ErrKeyNotFound = errors.New("key does not exist")

+ type Cache interface

+ Add func(key string, value []byte) error

+ Delete func(key string) error

+ Get func(key string) ([]byte, error)

+ Set func(key string, value []byte) error

+ type Condition interface

+ Check func(msg Message) bool

type Manager

+ GetCache func(name string) (Cache, error)

+ GetCondition func(name string) (Condition, error)

type Message

+ Append func(b ...[]byte) int

+ Get func(p int) []byte

+ GetAll func() [][]byte

+ Iter func(f func(i int, b []byte))

+ Len func() int

+ Set func(p int, b []byte)

+ SetAll func(p [][]byte)

Mar 2, 2018

Changes in this version

+ var ErrInvalidConditionType = errors.New("condition type was not recognised")

type Message

+ func (m *Message) DeepCopy() Message

Mar 1, 2018

Changes in this version

+ type Input interface

+ type Output interface

+ type Transaction struct

+ Payload Message

+ ResponseChan chan<- Response

+ func NewTransaction(payload Message, resChan chan<- Response) Transaction

+ type TransactionReceiver interface

+ StartReceiving func(<-chan Transaction) error

+ type Transactor interface

+ TransactionChan func() <-chan Transaction

Feb 16, 2018

Changes in this version

+ type Manager interface

+ RegisterEndpoint func(path, desc string, h http.HandlerFunc)

Feb 7, 2018

Changes in this version

+ var ErrNotConnected = errors.New("not connected to target source or sink")

Feb 1, 2018

Changes in this version

type Message

+ func (m *Message) ShallowCopy() Message

Jan 26, 2018

Changes in this version

+ var ErrMessagePartNotExist = errors.New("target message part does not exist")

type Message

+ func (m *Message) GetJSON(part int) (interface{}, error)

+ func (m *Message) SetJSON(part int, jObj interface{}) error

Nov 17, 2017

Changes in this version

+ var ErrNoAck = errors.New("failed to receive acknowledgement")

Oct 17, 2017

Changes in this version

type Response

+ SkipAck func() bool

type SimpleResponse

+ func (o SimpleResponse) SkipAck() bool

+ type UnacknowledgedResponse struct

+ func NewUnacknowledgedResponse() UnacknowledgedResponse

+ func (u UnacknowledgedResponse) Error() error

+ func (u UnacknowledgedResponse) SkipAck() bool

Oct 10, 2017

Changes in this version

+ var ErrInvalidProcessorType = errors.New("processor type was not recognised")

Sep 14, 2016

Changes in this version

+ var ErrAlreadyStarted = errors.New("type has already been started")

+ var ErrBadMessageBytes = errors.New("serialised message bytes were in unexpected format")

+ var ErrBlockCorrupted = errors.New("serialised messages block was in unexpected format")

+ var ErrChanClosed = errors.New("channel was closed unexpectedly")

+ var ErrInvalidBufferType = errors.New("buffer type was not recognised")

+ var ErrInvalidInputType = errors.New("input type was not recognised")

+ var ErrInvalidOutputType = errors.New("output type was not recognised")

+ var ErrInvalidScaleProtoType = errors.New("invalid Scalability Protocols socket type")

+ var ErrInvalidZMQType = errors.New("invalid ZMQ socket type")

+ var ErrMessageTooLarge = errors.New("message body larger than buffer space")

+ var ErrTimeout = errors.New("action timed out")

+ var ErrTypeClosed = errors.New("type was closed")

+ type Closable interface

+ CloseAsync func()

+ WaitForClose func(timeout time.Duration) error

+ type Consumer interface

+ type ErrUnexpectedHTTPRes struct

+ Code int

+ S string

+ func (e ErrUnexpectedHTTPRes) Error() string

+ type HTTPMessage struct

+ Parts []string

+ type HTTPResponse struct

+ Error string

+ type MappedResponse struct

+ Errors map[int]error

+ func NewMappedResponse() *MappedResponse

+ func (b *MappedResponse) Error() error

+ func (b *MappedResponse) ErrorMap() map[int]error

+ type Message struct

+ Parts [][]byte

+ func FromBytes(b []byte) (Message, error)

+ func NewMessage() Message

+ func (m *Message) Bytes() []byte

+ type MessageReceiver interface

+ StartReceiving func(<-chan Message) error

+ type MessageSender interface

+ MessageChan func() <-chan Message

+ type Producer interface

+ type Responder interface

+ ResponseChan func() <-chan Response

+ type ResponderListener interface

+ StartListening func(<-chan Response) error

+ type Response interface

+ Error func() error

+ ErrorMap func() map[int]error

+ type SimpleResponse struct

+ func NewSimpleResponse(err error) *SimpleResponse

+ func (o *SimpleResponse) Error() error

+ func (o *SimpleResponse) ErrorMap() map[int]error