raft_app

Documentation

Index

• func OpenHss(path string) raft.Hss
• func OpenLog(path string) raft.Log
• type App
  • func NewApp(raftCfg raft.RaftConfig, loopCfg raft.LoopConfig, addr map[raft.NodeId]string) App
• type Auth
  • func CreateAuth(key string) (Auth, error)
  • func OpenAuth(path string) (Auth, error)

Functions

func OpenHss

func OpenHss(path string) raft.Hss

func OpenLog

func OpenLog(path string) raft.Log

Types

type App

type App interface {
	ListenAndServe() error
	Propose(ctx context.Context, command raft.Command) error
	WithTransportAuth(tag string, auth Auth) App
	OnCommit(func(...raft.Entry)) App
	gin.IRoutes
}

func NewApp

func NewApp(raftCfg raft.RaftConfig, loopCfg raft.LoopConfig, addr map[raft.NodeId]string) App

type Auth

type Auth interface {
	Generate(tokenTime time.Time) (token string)
	Verify(token string, now time.Time) (ok bool)
	Save(path string) error
}

func CreateAuth

func CreateAuth(key string) (Auth, error)

func OpenAuth

func OpenAuth(path string) (Auth, error)