fbcontext

type Context ¶

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

Context is the default implementation of a firebolt context.

func (c *Context) AckMessage(msg Message) error

func (c *Context) ConfigureLeader(leader func() bool)

func (c *Context) ConfigureMessaging(send MessageFunc, ack MessageFunc)

func (c *Context) InstanceID() string

func (c *Context) IsLeader() bool

func (c *Context) SendMessage(msg Message) error

type ContextAware ¶

type ContextAware struct {
	ID string

	Ctx FBContext
	// contains filtered or unexported fields
}

ContextAware is intended to be embedded in Node types to provide the node's application code with access to execution context.

func (c *ContextAware) AcceptsMessage(messageType string) bool

func (c *ContextAware) Init(id string, ctx FBContext)

func (c *ContextAware) Subscribe(messageTypes []string)

type FBContext ¶

type FBContext interface {
	ConfigureMessaging(send MessageFunc, ack MessageFunc)
	ConfigureLeader(leader func() bool)
	SendMessage(msg Message) error
	AckMessage(msg Message) error
	IsLeader() bool
	InstanceID() string
}

FBContext is a firebolt context. It provides a source/node with access to inter-node or global operations. Currently it supports sending messages to other source/nodes (across the cluster) and acknowledging receipt of those messages. After any changes, regenerate the mock with:

mockery -name FBContext -inpkg .

func NewFBContext(instanceID func() string) FBContext

type Message ¶

type Message struct {
	MessageType string
	Key         string `json:"key"`
	Payload     []byte `json:"payload"`
}

Message is the context representation of a 'message.Message'. Message depends on node.kafkaconsumer, so node must not depend on message.

type MessageFunc ¶

type MessageFunc func(msg Message) error

MessageFunc is a function supplied by Executor, which uses them to relay messages to the target source/node

type MockFBContext ¶

type MockFBContext struct {
	mock.Mock
}

MockFBContext is an autogenerated mock type for the FBContext type

func (_m *MockFBContext) AckMessage(msg Message) error

func (_m *MockFBContext) ConfigureLeader(leader func() bool)

func (_m *MockFBContext) ConfigureMessaging(send MessageFunc, ack MessageFunc)

func (_m *MockFBContext) InstanceID() string

func (_m *MockFBContext) IsLeader() bool

func (_m *MockFBContext) SendMessage(msg Message) error