events

package

v0.7.2 Latest Latest Go to latest Published: Nov 26, 2025 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/olric-data/olric

Links

Open Source Insights

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 ¶

View Source

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

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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)

Source Files ¶

View all Source files

cluster_events.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL