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 ICreateHandler
  • func NewCreateHandler(namespace string, handler IRaftServiceHandler) ICreateHandler
• type IRaftServiceHandler
• type IService
• type Service
  • func NewService() *Service
  • func (s *Service) CommitHandler(data []byte) error
  • func (s *Service) GetInit() ([]byte, error)
  • func (s *Service) GetSnapshot() ([]byte, error)
  • func (s *Service) ProcessDataHandler(inBody []byte) (object interface{}, data []byte, err error)
  • func (s *Service) ProcessHandler(namespace string, command string, processData []byte) (interface{}, []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)

Constants

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

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 ICreateHandler

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

func NewCreateHandler

func NewCreateHandler(namespace string, handler IRaftServiceHandler) ICreateHandler

type IRaftServiceHandler

type IRaftServiceHandler interface {
	// ResetHandler  初始化日志操作
	ResetHandler(data []byte) error
	// CommitHandler 节点commit信息前的处理
	CommitHandler(cmd string, data []byte) error
	// Snapshot 获取快照
	Snapshot() []byte
	// ProcessHandler 节点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) CommitHandler

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

func (*Service) GetInit

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

func (*Service) GetSnapshot

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

func (*Service) ProcessDataHandler

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

func (*Service) ProcessHandler

func (s *Service) ProcessHandler(namespace string, command string, processData []byte) (interface{}, []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)