Documentation
¶
Index ¶
- type MemNetTransport
- func (t *MemNetTransport) AddCore(c *brahms.Core)
- func (t *MemNetTransport) Emit(ctx context.Context, c chan<- brahms.NID, id brahms.NID, msg []byte, ...)
- func (t *MemNetTransport) Probe(ctx context.Context, cc chan<- brahms.NID, id brahms.NID, n brahms.Node)
- func (t *MemNetTransport) Pull(ctx context.Context, cc chan<- brahms.View, from brahms.Node)
- func (t *MemNetTransport) Push(ctx context.Context, self brahms.Node, to brahms.Node)
- type MockTransport
- func (t *MockTransport) DidPush(id brahms.NID) (ok bool)
- func (t *MockTransport) Emit(ctx context.Context, c chan<- brahms.NID, id brahms.NID, msg []byte, ...)
- func (t *MockTransport) Probe(ctx context.Context, c chan<- brahms.NID, id brahms.NID, n brahms.Node)
- func (t *MockTransport) Pull(ctx context.Context, c chan<- brahms.View, from brahms.Node)
- func (t *MockTransport) Push(ctx context.Context, self brahms.Node, to brahms.Node)
- func (t *MockTransport) SetPull(id brahms.NID, v brahms.View)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MemNetTransport ¶
type MemNetTransport struct {
// contains filtered or unexported fields
}
MemNetTransport is an in-memory transport that allows cores to directly call each others handlers
func NewMemNetTransport ¶
func NewMemNetTransport() *MemNetTransport
NewMemNetTransport inits the new mem transport
func (*MemNetTransport) AddCore ¶
func (t *MemNetTransport) AddCore(c *brahms.Core)
AddCore adds a core to the network
func (*MemNetTransport) Emit ¶
func (t *MemNetTransport) Emit(ctx context.Context, c chan<- brahms.NID, id brahms.NID, msg []byte, to brahms.Node)
Emit implements the message emit
func (*MemNetTransport) Probe ¶
func (t *MemNetTransport) Probe(ctx context.Context, cc chan<- brahms.NID, id brahms.NID, n brahms.Node)
Probe implements probe
type MockTransport ¶
type MockTransport struct {
// contains filtered or unexported fields
}
MockTransport allows mocking of other peers
func (*MockTransport) DidPush ¶
func (t *MockTransport) DidPush(id brahms.NID) (ok bool)
DidPush returns whether a peer pushed
func (*MockTransport) Emit ¶
func (t *MockTransport) Emit(ctx context.Context, c chan<- brahms.NID, id brahms.NID, msg []byte, to brahms.Node)
Emit implements custom message emit
func (*MockTransport) Probe ¶
func (t *MockTransport) Probe(ctx context.Context, c chan<- brahms.NID, id brahms.NID, n brahms.Node)
Probe implements probe
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.