raft

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

type FSMOpts struct {
	Config                config.Config
	GetState              func() map[int]map[string]internal.KeyData
	GetCommand            func(command string) (internal.Command, error)
	SetValues             func(ctx context.Context, entries map[string]interface{}) error
	SetExpiry             func(ctx context.Context, key string, expire time.Time, touch bool)
	DeleteKey             func(ctx context.Context, key string) error
	StartSnapshot         func()
	FinishSnapshot        func()
	SetLatestSnapshotTime func(msec int64)
	GetHandlerFuncParams  func(ctx context.Context, cmd []string, conn *net.Conn) internal.HandlerFuncParams
}

type Opts struct {
	Config                config.Config
	SetValues             func(ctx context.Context, entries map[string]interface{}) error
	SetExpiry             func(ctx context.Context, key string, expire time.Time, touch bool)
	GetState              func() map[int]map[string]internal.KeyData
	GetCommand            func(command string) (internal.Command, error)
	DeleteKey             func(ctx context.Context, key string) error
	StartSnapshot         func()
	FinishSnapshot        func()
	SetLatestSnapshotTime func(msec int64)
	GetHandlerFuncParams  func(ctx context.Context, cmd []string, conn *net.Conn) internal.HandlerFuncParams
}

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

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

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