events

Documentation

Index

• Constants
• type Event
• type FragmentMigrationEvent
  • func (f *FragmentMigrationEvent) Encode() (string, error)
• type FragmentReceivedEvent
  • func (f *FragmentReceivedEvent) Encode() (string, error)
• type NodeJoinEvent
  • func (n *NodeJoinEvent) Encode() (string, error)
• type NodeLeftEvent
  • func (n *NodeLeftEvent) Encode() (string, error)

Constants

const (
	ClusterEventsChannel       = "cluster.events"
	KindNodeJoinEvent          = "node-join-event"
	KindNodeLeftEvent          = "node-left-event"
	KindFragmentMigrationEvent = "fragment-migration-event"
	KindFragmentReceivedEvent  = "fragment-received-event"
)

Types

type Event

type Event interface {
	Encode() (string, error)
}

type FragmentMigrationEvent

type FragmentMigrationEvent struct {
	Kind          string `json:"kind"`
	Source        string `json:"source"`
	Target        string `json:"target"`
	Identifier    string `json:"identifier"`
	PartitionID   uint64 `json:"partition_id"`
	DataStructure string `json:"data_structure"`
	Length        int    `json:"length"`
	IsBackup      bool   `json:"is_backup"`
	Timestamp     int64  `json:"timestamp"`
}

func (*FragmentMigrationEvent) Encode

func (f *FragmentMigrationEvent) Encode() (string, error)

type FragmentReceivedEvent

type FragmentReceivedEvent struct {
	Kind          string `json:"kind"`
	Source        string `json:"source"`
	Identifier    string `json:"identifier"`
	PartitionID   uint64 `json:"partition_id"`
	DataStructure string `json:"data_structure"`
	Length        int    `json:"length"`
	IsBackup      bool   `json:"is_backup"`
	Timestamp     int64  `json:"timestamp"`
}

func (*FragmentReceivedEvent) Encode

func (f *FragmentReceivedEvent) Encode() (string, error)

type NodeJoinEvent

type NodeJoinEvent struct {
	Kind      string `json:"kind"`
	Source    string `json:"source"`
	NodeJoin  string `json:"node_join"`
	Timestamp int64  `json:"timestamp"`
}

func (*NodeJoinEvent) Encode

func (n *NodeJoinEvent) Encode() (string, error)

type NodeLeftEvent

type NodeLeftEvent struct {
	Kind      string `json:"kind"`
	Source    string `json:"source"`
	NodeLeft  string `json:"node_left"`
	Timestamp int64  `json:"timestamp"`
}

func (*NodeLeftEvent) Encode

func (n *NodeLeftEvent) Encode() (string, error)