raft_service

Documentation

Index

• Constants
• Variables
• type Commend
  • func (*Commend) Descriptor() ([]byte, []int)
  • func (x *Commend) GetBody() []byte
  • func (x *Commend) GetCmd() string
  • func (x *Commend) GetNamespace() string
  • func (*Commend) ProtoMessage()
  • func (x *Commend) ProtoReflect() protoreflect.Message
  • func (x *Commend) Reset()
  • func (x *Commend) String() string
• type ICommitEventHandler
• type ICreateHandler
  • func NewCreateHandler(namespace string, handler IRaftServiceHandler) ICreateHandler
• type IRaftEventHandler
• type IRaftServiceHandler
• type IService
• type Service
  • func NewService() *Service
  • func (s *Service) AddCommitEventHandler(h ICommitEventHandler)
  • func (s *Service) AddEventHandler(h IRaftEventHandler)
  • func (s *Service) Append(cmd string, data []byte) error
  • func (s *Service) Commit(data []byte) error
  • func (s *Service) CommitHandler(cmd string, data []byte) error
  • func (s *Service) Complete() error
  • func (s *Service) GetInit() ([]byte, error)
  • func (s *Service) GetSnapshot() ([]byte, error)
  • func (s *Service) PreProcessData(inBody []byte) (object interface{}, data []byte, err error)
  • func (s *Service) ProcessHandler(cmd string, body []byte) ([]byte, interface{}, error)
  • func (s *Service) ResetHandler(data []byte) error
  • func (s *Service) ResetSnap(data []byte) error
  • func (s *Service) Send(namespace, cmd string, body []byte) (interface{}, error)
  • func (s *Service) SetHandler(namespace string, handler IRaftServiceHandler)
  • func (s *Service) SetHandlers(handlers ...ICreateHandler)
  • func (s *Service) SetRaft(raft raft.IRaftSender)
  • func (s *Service) Snapshot() []byte

Constants

const (
	CommandInit     = "init"
	SystemNamespace = "__system"

	EventReset    = "reset"
	EventComplete = "complete"
)

Variables

var (
	ErrInvalidNamespace     = errors.New("invalid namespace")
	ErrInvalidCommitHandler = errors.New("invalid commit handler")
	ErrInvalidCommand       = errors.New("invalid command")
)

var File_msg_proto protoreflect.FileDescriptor

Types

type Commend

type Commend struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Cmd       string `protobuf:"bytes,2,opt,name=cmd,proto3" json:"cmd,omitempty"`
	Body      []byte `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*Commend) Descriptor

func (*Commend) Descriptor() ([]byte, []int)

Deprecated: Use Commend.ProtoReflect.Descriptor instead.

func (*Commend) GetBody

func (x *Commend) GetBody() []byte

func (*Commend) GetCmd

func (x *Commend) GetCmd() string

func (*Commend) GetNamespace

func (x *Commend) GetNamespace() string

func (*Commend) ProtoMessage

func (*Commend) ProtoMessage()

func (*Commend) ProtoReflect

func (x *Commend) ProtoReflect() protoreflect.Message

func (*Commend) Reset

func (x *Commend) Reset()

func (*Commend) String

func (x *Commend) String() string

type ICommitEventHandler

type ICommitEventHandler func(namespace, cmd string)

type ICreateHandler

type ICreateHandler interface {
	Namespace() string
	Handler() IRaftServiceHandler
}

func NewCreateHandler

func NewCreateHandler(namespace string, handler IRaftServiceHandler) ICreateHandler

type IRaftEventHandler

type IRaftEventHandler func(event string)

type IRaftServiceHandler

type IRaftServiceHandler interface {
	// ResetHandler  初始化snapshot
	ResetHandler(data []byte) error
	// Append 追加需要初始化的日志
	Append(cmd string, data []byte) error
	// Complete 初始化完成
	Complete() error

	// CommitHandler 节点commit信息前的处理
	CommitHandler(cmd string, data []byte) error
	// Snapshot 获取快照
	Snapshot() []byte
	// ProcessHandler leader 节点propose信息前的处理
	ProcessHandler(cmd string, body []byte) ([]byte, interface{}, error)
}

type IService

type IService interface {
	Send(namespace, cmd string, body []byte) (interface{}, error)
}

type Service

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

func NewService

func NewService() *Service

func (*Service) AddCommitEventHandler

func (s *Service) AddCommitEventHandler(h ICommitEventHandler)

func (*Service) AddEventHandler

func (s *Service) AddEventHandler(h IRaftEventHandler)

func (*Service) Append

func (s *Service) Append(cmd string, data []byte) error

func (*Service) Commit

func (s *Service) Commit(data []byte) error

func (*Service) CommitHandler

func (s *Service) CommitHandler(cmd string, data []byte) error

func (*Service) Complete

func (s *Service) Complete() error

func (*Service) GetInit

func (s *Service) GetInit() ([]byte, error)

func (*Service) GetSnapshot

func (s *Service) GetSnapshot() ([]byte, error)

func (*Service) PreProcessData

func (s *Service) PreProcessData(inBody []byte) (object interface{}, data []byte, err error)

func (*Service) ProcessHandler

func (s *Service) ProcessHandler(cmd string, body []byte) ([]byte, interface{}, error)

func (*Service) ResetHandler

func (s *Service) ResetHandler(data []byte) error

func (*Service) ResetSnap

func (s *Service) ResetSnap(data []byte) error

func (*Service) Send

func (s *Service) Send(namespace, cmd string, body []byte) (interface{}, error)

func (*Service) SetHandler

func (s *Service) SetHandler(namespace string, handler IRaftServiceHandler)

func (*Service) SetHandlers

func (s *Service) SetHandlers(handlers ...ICreateHandler)

func (*Service) SetRaft

func (s *Service) SetRaft(raft raft.IRaftSender)

func (*Service) Snapshot

func (s *Service) Snapshot() []byte