Documentation
¶
Index ¶
- type GokaMockContext
- func (g *GokaMockContext) Context() context.Context
- func (g *GokaMockContext) DeferCommit() func(error)
- func (g *GokaMockContext) Delete(options ...goka.ContextOption)
- func (g *GokaMockContext) Emit(topic goka.Stream, key string, value interface{}, ...)
- func (g *GokaMockContext) Fail(err error)
- func (g *GokaMockContext) GetAllEmits() map[goka.Stream][]KeyedMessage
- func (g *GokaMockContext) GetEmitForTopic(stream goka.Stream) []KeyedMessage
- func (g *GokaMockContext) Group() goka.Group
- func (g *GokaMockContext) Headers() goka.Headers
- func (g *GokaMockContext) Join(topic goka.Table) interface{}
- func (g *GokaMockContext) Key() string
- func (g *GokaMockContext) Lookup(topic goka.Table, key string) interface{}
- func (g *GokaMockContext) Loopback(key string, value interface{}, options ...goka.ContextOption)
- func (g *GokaMockContext) Offset() int64
- func (g *GokaMockContext) Partition() int32
- func (g *GokaMockContext) Reset()
- func (g *GokaMockContext) SetValue(value interface{}, options ...goka.ContextOption)
- func (g *GokaMockContext) Timestamp() time.Time
- func (g *GokaMockContext) Topic() goka.Stream
- func (g *GokaMockContext) Value() interface{}
- func (g *GokaMockContext) WithContext(ctx context.Context) *GokaMockContext
- func (g *GokaMockContext) WithHeaders(headers map[string][]byte) *GokaMockContext
- func (g *GokaMockContext) WithJoinValue(table goka.Table, value interface{}) *GokaMockContext
- func (g *GokaMockContext) WithKeyValue(key string, value interface{}) *GokaMockContext
- func (g *GokaMockContext) WithLookupValue(table goka.Table, key string, value interface{}) *GokaMockContext
- func (g *GokaMockContext) WithOffset(offset int64) *GokaMockContext
- func (g *GokaMockContext) WithPartition(partition int32) *GokaMockContext
- func (g *GokaMockContext) WithTimestamp(timestamp time.Time) *GokaMockContext
- func (g *GokaMockContext) WithTopic(topic goka.Stream) *GokaMockContext
- type KeyedMessage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GokaMockContext ¶
type GokaMockContext struct {
// contains filtered or unexported fields
}
func NewGokaMockContext ¶
func NewGokaMockContext(t *testing.T) *GokaMockContext
func (*GokaMockContext) Context ¶
func (g *GokaMockContext) Context() context.Context
func (*GokaMockContext) DeferCommit ¶
func (g *GokaMockContext) DeferCommit() func(error)
func (*GokaMockContext) Delete ¶
func (g *GokaMockContext) Delete(options ...goka.ContextOption)
func (*GokaMockContext) Emit ¶
func (g *GokaMockContext) Emit(topic goka.Stream, key string, value interface{}, options ...goka.ContextOption)
func (*GokaMockContext) Fail ¶
func (g *GokaMockContext) Fail(err error)
func (*GokaMockContext) GetAllEmits ¶
func (g *GokaMockContext) GetAllEmits() map[goka.Stream][]KeyedMessage
func (*GokaMockContext) GetEmitForTopic ¶
func (g *GokaMockContext) GetEmitForTopic(stream goka.Stream) []KeyedMessage
func (*GokaMockContext) Group ¶
func (g *GokaMockContext) Group() goka.Group
func (*GokaMockContext) Headers ¶
func (g *GokaMockContext) Headers() goka.Headers
func (*GokaMockContext) Join ¶
func (g *GokaMockContext) Join(topic goka.Table) interface{}
func (*GokaMockContext) Key ¶
func (g *GokaMockContext) Key() string
func (*GokaMockContext) Lookup ¶
func (g *GokaMockContext) Lookup(topic goka.Table, key string) interface{}
func (*GokaMockContext) Loopback ¶
func (g *GokaMockContext) Loopback(key string, value interface{}, options ...goka.ContextOption)
func (*GokaMockContext) Offset ¶
func (g *GokaMockContext) Offset() int64
func (*GokaMockContext) Partition ¶
func (g *GokaMockContext) Partition() int32
func (*GokaMockContext) Reset ¶
func (g *GokaMockContext) Reset()
func (*GokaMockContext) SetValue ¶
func (g *GokaMockContext) SetValue(value interface{}, options ...goka.ContextOption)
func (*GokaMockContext) Timestamp ¶
func (g *GokaMockContext) Timestamp() time.Time
func (*GokaMockContext) Topic ¶
func (g *GokaMockContext) Topic() goka.Stream
func (*GokaMockContext) Value ¶
func (g *GokaMockContext) Value() interface{}
func (*GokaMockContext) WithContext ¶
func (g *GokaMockContext) WithContext(ctx context.Context) *GokaMockContext
func (*GokaMockContext) WithHeaders ¶
func (g *GokaMockContext) WithHeaders(headers map[string][]byte) *GokaMockContext
func (*GokaMockContext) WithJoinValue ¶
func (g *GokaMockContext) WithJoinValue(table goka.Table, value interface{}) *GokaMockContext
func (*GokaMockContext) WithKeyValue ¶
func (g *GokaMockContext) WithKeyValue(key string, value interface{}) *GokaMockContext
func (*GokaMockContext) WithLookupValue ¶
func (g *GokaMockContext) WithLookupValue(table goka.Table, key string, value interface{}) *GokaMockContext
func (*GokaMockContext) WithOffset ¶
func (g *GokaMockContext) WithOffset(offset int64) *GokaMockContext
func (*GokaMockContext) WithPartition ¶
func (g *GokaMockContext) WithPartition(partition int32) *GokaMockContext
func (*GokaMockContext) WithTimestamp ¶
func (g *GokaMockContext) WithTimestamp(timestamp time.Time) *GokaMockContext
func (*GokaMockContext) WithTopic ¶
func (g *GokaMockContext) WithTopic(topic goka.Stream) *GokaMockContext
type KeyedMessage ¶
type KeyedMessage struct {
Key string
Value interface{}
}
Source Files
Click to show internal directories.
Click to hide internal directories.