apiserver

Documentation

Index

• Constants
• type DevToolServer
  • func NewDevToolServer() *DevToolServer
  • func (s *DevToolServer) DebugSwitch(ctx context.Context, r *pb.DebugSwitchRequest) (*pb.DebugSwitchResponse, error)
• type LogStreamAdminServer
  • func NewLogStreamAdminServer(getter RaftGroupGetter) *LogStreamAdminServer
  • func (l *LogStreamAdminServer) DeleteFile(ctx context.Context, r *pb.DeleteFileRequest) (*pb.DeleteFileResponse, error)
  • func (l *LogStreamAdminServer) GetDeletePermission(ctx context.Context, r *pb.GetDeletePermissionReq) (*pb.GetDeletePermissionResp, error)
  • func (l *LogStreamAdminServer) LeaderTransfer(ctx context.Context, r *pb.LogStreamLeaderTransferRequeset) (*pb.LogStreamLeaderTransferResponse, error)
  • func (l *LogStreamAdminServer) LogStreamDelete(context.Context, *pb.LogStreamDeleteRequest) (*pb.LogStreamDeleteResponse, error)
  • func (l *LogStreamAdminServer) LogStreamStart(ctx context.Context, r *pb.LogStreamStartRequest) (*pb.LogStreamStartResponse, error)
  • func (l *LogStreamAdminServer) LogStreamStop(ctx context.Context, r *pb.LogStreamStopRequest) (*pb.LogStreamStopResponse, error)
  • func (l *LogStreamAdminServer) SetDeletePermission(ctx context.Context, r *pb.SetDeletePermissionReq) (*pb.SetDeletePermissionResp, error)
• type MembershipAdminServer
  • func NewMembershipAdminServer(getter RaftGroupGetter) *MembershipAdminServer
  • func (ms *MembershipAdminServer) MemberAdd(ctx context.Context, r *pb.MemberAddRequest) (*pb.MemberAddResponse, error)
  • func (ms *MembershipAdminServer) MemberList(ctx context.Context, r *pb.MemberListRequest) (*pb.MemberListResponse, error)
  • func (ms *MembershipAdminServer) MemberRemove(ctx context.Context, r *pb.MemberRemoveRequest) (*pb.MemberRemoveResponse, error)
  • func (ms *MembershipAdminServer) MemberUpdate(ctx context.Context, r *pb.MemberUpdateRequest) (*pb.MemberUpdateResponse, error)
• type RaftGroupGetter
• type RateAdminServer
  • func NewRateAdminServer(getter RateInfoGetter) *RateAdminServer
  • func (ras *RateAdminServer) ListRateInfo(ctx context.Context, req *apipb.RateListRequest) (*apipb.RateListResponse, error)
  • func (ras *RateAdminServer) UpdateRateInfo(ctx context.Context, req *apipb.RateUpdateRequest) (*apipb.RateUpdateResponse, error)
• type RateInfoGetter
• type SnapshotAdminServer
  • func NewSnapshotAdminServer(getter RaftGroupGetter) *SnapshotAdminServer
  • func (s *SnapshotAdminServer) CreateSnapshotMeta(ctx context.Context, r *pb.SnapshotRequeest) (*pb.SnapshotResponse, error)
• type SnapshotMeta

Constants

const (
	DirPermission      = 0755
	MetaFilePermission = 0644
)

Types

type DevToolServer

type DevToolServer struct {
}

func NewDevToolServer

func NewDevToolServer() *DevToolServer

func (*DevToolServer) DebugSwitch

func (s *DevToolServer) DebugSwitch(ctx context.Context, r *pb.DebugSwitchRequest) (*pb.DebugSwitchResponse, error)

type LogStreamAdminServer

type LogStreamAdminServer struct {

	//key is raft group, ignore value
	DeleteForbid map[string]bool
	// contains filtered or unexported fields
}

This handler use to process 1) LogStream start 2) LogStream stop 3) LogStream delete

func NewLogStreamAdminServer

func NewLogStreamAdminServer(getter RaftGroupGetter) *LogStreamAdminServer

func (*LogStreamAdminServer) DeleteFile

func (l *LogStreamAdminServer) DeleteFile(ctx context.Context, r *pb.DeleteFileRequest) (*pb.DeleteFileResponse, error)

func (*LogStreamAdminServer) GetDeletePermission

func (l *LogStreamAdminServer) GetDeletePermission(ctx context.Context,
	r *pb.GetDeletePermissionReq) (*pb.GetDeletePermissionResp, error)

func (*LogStreamAdminServer) LeaderTransfer

func (l *LogStreamAdminServer) LeaderTransfer(ctx context.Context, r *pb.LogStreamLeaderTransferRequeset) (*pb.LogStreamLeaderTransferResponse, error)

rpc handler for leader transfer

func (*LogStreamAdminServer) LogStreamDelete

func (l *LogStreamAdminServer) LogStreamDelete(context.Context, *pb.LogStreamDeleteRequest) (*pb.LogStreamDeleteResponse, error)

func (*LogStreamAdminServer) LogStreamStart

func (l *LogStreamAdminServer) LogStreamStart(ctx context.Context, r *pb.LogStreamStartRequest) (*pb.LogStreamStartResponse, error)

func (*LogStreamAdminServer) LogStreamStop

func (l *LogStreamAdminServer) LogStreamStop(ctx context.Context, r *pb.LogStreamStopRequest) (*pb.LogStreamStopResponse, error)

func (*LogStreamAdminServer) SetDeletePermission

func (l *LogStreamAdminServer) SetDeletePermission(ctx context.Context,
	r *pb.SetDeletePermissionReq) (*pb.SetDeletePermissionResp, error)

type MembershipAdminServer

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

This handler use to process 1) query membership within raft group 2) add membership within raft group 3) delete membership within raft group 4) update membership within raft group

func NewMembershipAdminServer

func NewMembershipAdminServer(getter RaftGroupGetter) *MembershipAdminServer

func (*MembershipAdminServer) MemberAdd

func (ms *MembershipAdminServer) MemberAdd(ctx context.Context, r *pb.MemberAddRequest) (*pb.MemberAddResponse, error)

func (*MembershipAdminServer) MemberList

func (ms *MembershipAdminServer) MemberList(ctx context.Context, r *pb.MemberListRequest) (*pb.MemberListResponse, error)

func (*MembershipAdminServer) MemberRemove

func (ms *MembershipAdminServer) MemberRemove(ctx context.Context, r *pb.MemberRemoveRequest) (*pb.MemberRemoveResponse, error)

func (*MembershipAdminServer) MemberUpdate

func (ms *MembershipAdminServer) MemberUpdate(ctx context.Context, r *pb.MemberUpdateRequest) (*pb.MemberUpdateResponse, error)

type RaftGroupGetter

type RaftGroupGetter interface {
	GetRaftGroup(groupName string) (*raftgroup.RaftGroup, error)
}

type RateAdminServer

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

func NewRateAdminServer

func NewRateAdminServer(getter RateInfoGetter) *RateAdminServer

func (*RateAdminServer) ListRateInfo

func (ras *RateAdminServer) ListRateInfo(ctx context.Context, req *apipb.RateListRequest) (*apipb.RateListResponse, error)

this function use for rpc server handle list rate info

func (*RateAdminServer) UpdateRateInfo

func (ras *RateAdminServer) UpdateRateInfo(ctx context.Context, req *apipb.RateUpdateRequest) (*apipb.RateUpdateResponse, error)

this function use for rpc server handle update rate info

type RateInfoGetter

type RateInfoGetter interface {
	GetRuntimeConfig() *runtimeconfig.RuntimeConfig
	GetRuntimeConfigStore() *runtimeconfig.RuntimeConfigStore
}

type SnapshotAdminServer

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

func NewSnapshotAdminServer

func NewSnapshotAdminServer(getter RaftGroupGetter) *SnapshotAdminServer

func (*SnapshotAdminServer) CreateSnapshotMeta

func (s *SnapshotAdminServer) CreateSnapshotMeta(ctx context.Context, r *pb.SnapshotRequeest) (*pb.SnapshotResponse, error)

type SnapshotMeta

type SnapshotMeta struct {
	//RaftGroupName
	RaftGroupName string
	//ApplyIndex
	ApplyIndex uint64
	//VoteFor
	Vote raftgroup.PersistentVote
	//Membership
	Members  membership.MembershipMembers
	Segments []*logstream.SegmentFile
}