http

Oct 10, 2023

Changes in this version

+ var ErrAddAffinityRule = coderr.NewCodeError(coderr.Internal, "add affinity rule")

+ var ErrGetDeployMode = coderr.NewCodeError(coderr.Internal, "get deploy mode")

+ var ErrListAffinityRules = coderr.NewCodeError(coderr.Internal, "list affinity rules")

+ var ErrRemoveAffinityRule = coderr.NewCodeError(coderr.Internal, "remove affinity rule")

+ var ErrRoute = coderr.NewCodeError(coderr.Internal, "route table")

+ var ErrTable = coderr.NewCodeError(coderr.Internal, "table")

+ var ErrUpdateDeployMode = coderr.NewCodeError(coderr.Internal, "update deploy mode")

+ type DiagnoseShardResult struct

+ UnreadyShards map[storage.ShardID]DiagnoseShardStatus

+ UnregisteredShards []storage.ShardID

+ type DiagnoseShardStatus struct

+ NodeName string

+ Status string

+ type QueryTableRequest struct

+ ClusterName string

+ IDs []uint64

+ Names []string

+ SchemaName string

+ type RemoveShardAffinitiesRequest struct

+ ShardIDs []storage.ShardID

type Router

+ func (r *Router) GetWithoutPrefix(path string, h http.HandlerFunc)

+ func (r *Router) PutWithoutPrefix(path string, h http.HandlerFunc)

+ type UpdateDeployModeRequest struct

+ Enable bool

Jul 27, 2023

Changes in this version

+ var ErrAddLearner = coderr.NewCodeError(coderr.Internal, "add member as learner")

+ var ErrGetMember = coderr.NewCodeError(coderr.Internal, "get member")

+ var ErrListMembers = coderr.NewCodeError(coderr.Internal, "get member list")

+ var ErrRemoveMembers = coderr.NewCodeError(coderr.Internal, "remove member")

+ type AddMemberRequest struct

+ MemberAddrs []string

+ type EtcdAPI struct

+ func NewEtcdAPI(etcdClient *clientv3.Client, forwardClient *ForwardClient) EtcdAPI

+ type MoveLeaderRequest struct

+ MemberName string

+ type PromoteLearnerRequest struct

+ LearnerName string

+ type RemoveMemberRequest struct

+ MemberName string

+ type UpdateMemberRequest struct

+ NewMemberAddr []string

+ OldMemberName string

Jul 7, 2023

Changes in this version

type ForwardClient

+ func (s *ForwardClient) GetLeaderAddr(ctx context.Context) (string, error)

+ type GetShardTablesRequest struct

+ ClusterName string

+ ShardIDs []uint32

type UpdateClusterRequest

+ ProcedureExecutingBatchSize uint32

May 31, 2023

Changes in this version

type UpdateFlowLimiterRequest

+ Burst int

+ Limit int

May 29, 2023

Changes in this version

+ var ErrParseTopology = coderr.NewCodeError(coderr.Internal, "parse topology type")

+ var ErrUpdateFlowLimiter = coderr.NewCodeError(coderr.Internal, "update flow limiter")

+ func Param(ctx context.Context, p string) string

+ type CreateClusterRequest struct

+ EnableSchedule bool

+ Name string

+ NodeCount uint32

+ ShardTotal uint32

+ TopologyType string

+ type UpdateClusterRequest struct

+ EnableSchedule bool

+ NodeCount uint32

+ ShardTotal uint32

+ TopologyType string

+ type UpdateFlowLimiterRequest struct

+ Enable bool

+ TokenBucketBurstEventCapacity int

+ TokenBucketFillRate int

May 6, 2023

Changes in this version

+ var ErrHealthCheck = coderr.NewCodeError(coderr.Internal, "server health check fail")

+ type UpdateEnableScheduleRequest struct

+ ClusterName string

+ EnableSchedule bool

Feb 22, 2023

Changes in this version

+ var ErrAllocShardID = coderr.NewCodeError(coderr.Internal, "alloc shard id")

+ var ErrCreateProcedure = coderr.NewCodeError(coderr.Internal, "create procedure")

+ var ErrDropTable = coderr.NewCodeError(coderr.Internal, "drop table")

+ var ErrForwardToLeader = coderr.NewCodeError(coderr.Internal, "forward to leader")

+ var ErrGetCluster = coderr.NewCodeError(coderr.Internal, "get cluster")

+ var ErrGetNodeShards = coderr.NewCodeError(coderr.Internal, "get node shards")

+ var ErrParseLeaderAddr = coderr.NewCodeError(coderr.Internal, "parse leader addr")

+ var ErrParseRequest = coderr.NewCodeError(coderr.BadRequest, "parse request params")

+ var ErrRouteTable = coderr.NewCodeError(coderr.Internal, "route table")

+ var ErrSubmitProcedure = coderr.NewCodeError(coderr.Internal, "submit procedure")

+ type API struct

+ func NewAPI(procedureManager procedure.Manager, procedureFactory *coordinator.Factory, ...) *API

+ func (a *API) NewAPIRouter() *Router

+ type DropTableRequest struct

+ ClusterName string

+ SchemaName string

+ Table string

+ type ForwardClient struct

+ func NewForwardClient(member *member.Member, port int) *ForwardClient

+ type GetShardTables struct

+ ClusterName string

+ NodeName string

+ ShardIDs []uint32

+ type NodeShardsRequest struct

+ ClusterName string

+ type RouteRequest struct

+ ClusterName string

+ SchemaName string

+ Tables []string

+ type Router struct

+ func New() *Router

+ func (r *Router) Del(path string, h http.HandlerFunc)

+ func (r *Router) Get(path string, h http.HandlerFunc)

+ func (r *Router) Head(path string, h http.HandlerFunc)

+ func (r *Router) Options(path string, h http.HandlerFunc)

+ func (r *Router) Post(path string, h http.HandlerFunc)

+ func (r *Router) Put(path string, h http.HandlerFunc)

+ func (r *Router) ServeHTTP(w http.ResponseWriter, req *http.Request)

+ func (r *Router) WithInstrumentation(instrh func(handlerName string, handler http.HandlerFunc) http.HandlerFunc) *Router

+ func (r *Router) WithPrefix(prefix string) *Router

+ type Service struct

+ func NewHTTPService(port int, readTimeout time.Duration, writeTimeout time.Duration, ...) *Service

+ func (s *Service) Start() error

+ func (s *Service) Stop() error

+ type SplitRequest struct

+ ClusterName string

+ NodeName string

+ SchemaName string

+ ShardID uint32

+ SplitTables []string

+ type TransferLeaderRequest struct

+ ClusterName string

+ NewLeaderNodeName string

+ OldLeaderNodeName string

+ ShardID uint32