visualizer

Documentation

Index

• type MessageStoreHelper
  • func NewMessageStoreHelper(store *types.MessageStore) *MessageStoreHelper
  • func (m *MessageStoreHelper) Add(message *types.Message)
  • func (m *MessageStoreHelper) GetDeliveredFrom(replica types.ReplicaID) (map[string]*types.Message, bool)
  • func (m *MessageStoreHelper) GetDeliveredTo(replica types.ReplicaID) (map[string]*types.Message, bool)
  • func (m *MessageStoreHelper) GetPendingFrom(replica types.ReplicaID) (map[string]*types.Message, bool)
  • func (m *MessageStoreHelper) GetPendingTo(replica types.ReplicaID) (map[string]*types.Message, bool)
  • func (m *MessageStoreHelper) MarkDelivered(messageID string) bool
• type Visualizer
  • func NewVisualizer(ctx *context.RootContext) *Visualizer
  • func (v *Visualizer) HandleMessagesGET(c *gin.Context)
  • func (v *Visualizer) HandleMessagesPOST(c *gin.Context)
  • func (v *Visualizer) SetupRouter(r *gin.RouterGroup)
  • func (v *Visualizer) Start()
  • func (v *Visualizer) Stop()

Types

type MessageStoreHelper

type MessageStoreHelper struct {
	*types.MessageStore
	// contains filtered or unexported fields
}

func NewMessageStoreHelper

func NewMessageStoreHelper(store *types.MessageStore) *MessageStoreHelper

func (*MessageStoreHelper) Add

func (m *MessageStoreHelper) Add(message *types.Message)

func (*MessageStoreHelper) GetDeliveredFrom

func (m *MessageStoreHelper) GetDeliveredFrom(replica types.ReplicaID) (map[string]*types.Message, bool)

func (*MessageStoreHelper) GetDeliveredTo

func (m *MessageStoreHelper) GetDeliveredTo(replica types.ReplicaID) (map[string]*types.Message, bool)

func (*MessageStoreHelper) GetPendingFrom

func (m *MessageStoreHelper) GetPendingFrom(replica types.ReplicaID) (map[string]*types.Message, bool)

func (*MessageStoreHelper) GetPendingTo

func (m *MessageStoreHelper) GetPendingTo(replica types.ReplicaID) (map[string]*types.Message, bool)

func (*MessageStoreHelper) MarkDelivered

func (m *MessageStoreHelper) MarkDelivered(messageID string) bool

type Visualizer

type Visualizer struct {
	*types.BaseService
	// contains filtered or unexported fields
}

Visualizer is one of the modes of executing the tool where the user can control the messages delivery order through an interactive dashboard

func NewVisualizer

func NewVisualizer(ctx *context.RootContext) *Visualizer

NewVisualizer instantiates a Visualizer

func (*Visualizer) HandleMessagesGET

func (v *Visualizer) HandleMessagesGET(c *gin.Context)

func (*Visualizer) HandleMessagesPOST

func (v *Visualizer) HandleMessagesPOST(c *gin.Context)

func (*Visualizer) SetupRouter

func (v *Visualizer) SetupRouter(r *gin.RouterGroup)

func (*Visualizer) Start

func (v *Visualizer) Start()

Start implements Service

func (*Visualizer) Stop

func (v *Visualizer) Stop()

Stop implements Service