http

Documentation

Index

• Variables
• func Param(ctx context.Context, p string) string
• type API
  • func NewAPI(clusterManager cluster.Manager, serverStatus *status.ServerStatus, ...) *API
  • func (a *API) NewAPIRouter() *Router
• type AddMemberRequest
• type CreateClusterRequest
• type DropTableRequest
• type EtcdAPI
  • func NewEtcdAPI(etcdClient *clientv3.Client, forwardClient *ForwardClient) EtcdAPI
• type ForwardClient
  • func NewForwardClient(member *member.Member, port int) *ForwardClient
  • func (s *ForwardClient) GetLeaderAddr(ctx context.Context) (string, error)
• type GetShardTablesRequest
• type MoveLeaderRequest
• type NodeShardsRequest
• type PromoteLearnerRequest
• type RemoveMemberRequest
• type RouteRequest
• type Router
  • 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
  • func NewHTTPService(port int, readTimeout time.Duration, writeTimeout time.Duration, ...) *Service
  • func (s *Service) Start() error
  • func (s *Service) Stop() error
• type SplitRequest
• type TransferLeaderRequest
• type UpdateClusterRequest
• type UpdateFlowLimiterRequest
• type UpdateMemberRequest

Variables

var (
	ErrParseRequest      = coderr.NewCodeError(coderr.BadRequest, "parse request params")
	ErrDropTable         = coderr.NewCodeError(coderr.Internal, "drop table")
	ErrRouteTable        = coderr.NewCodeError(coderr.Internal, "route table")
	ErrGetNodeShards     = coderr.NewCodeError(coderr.Internal, "get node shards")
	ErrCreateProcedure   = coderr.NewCodeError(coderr.Internal, "create procedure")
	ErrSubmitProcedure   = coderr.NewCodeError(coderr.Internal, "submit procedure")
	ErrGetCluster        = coderr.NewCodeError(coderr.Internal, "get cluster")
	ErrAllocShardID      = coderr.NewCodeError(coderr.Internal, "alloc shard id")
	ErrForwardToLeader   = coderr.NewCodeError(coderr.Internal, "forward to leader")
	ErrParseLeaderAddr   = coderr.NewCodeError(coderr.Internal, "parse leader addr")
	ErrHealthCheck       = coderr.NewCodeError(coderr.Internal, "server health check")
	ErrParseTopology     = coderr.NewCodeError(coderr.Internal, "parse topology type")
	ErrUpdateFlowLimiter = coderr.NewCodeError(coderr.Internal, "update flow limiter")
	ErrAddLearner        = coderr.NewCodeError(coderr.Internal, "add member as learner")
	ErrListMembers       = coderr.NewCodeError(coderr.Internal, "get member list")
	ErrRemoveMembers     = coderr.NewCodeError(coderr.Internal, "remove member")
	ErrGetMember         = coderr.NewCodeError(coderr.Internal, "get member")
)

Functions

func Param

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

Param returns param p for the context, or the empty string when param does not exist in context.

Types

type API

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

func NewAPI

func NewAPI(clusterManager cluster.Manager, serverStatus *status.ServerStatus, forwardClient *ForwardClient, flowLimiter *limiter.FlowLimiter, etcdClient *clientv3.Client) *API

func (*API) NewAPIRouter

func (a *API) NewAPIRouter() *Router

type AddMemberRequest

type AddMemberRequest struct {
	MemberAddrs []string `json:"memberAddrs"`
}

type CreateClusterRequest

type CreateClusterRequest struct {
	Name           string `json:"Name"`
	NodeCount      uint32 `json:"NodeCount"`
	ShardTotal     uint32 `json:"ShardTotal"`
	EnableSchedule bool   `json:"enableSchedule"`
	TopologyType   string `json:"topologyType"`
}

type DropTableRequest

type DropTableRequest struct {
	ClusterName string `json:"clusterName"`
	SchemaName  string `json:"schemaName"`
	Table       string `json:"table"`
}

type EtcdAPI

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

func NewEtcdAPI

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

type ForwardClient

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

func NewForwardClient

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

func (*ForwardClient) GetLeaderAddr

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

type GetShardTablesRequest

type GetShardTablesRequest struct {
	ClusterName string   `json:"clusterName"`
	ShardIDs    []uint32 `json:"shardIDs"`
}

type MoveLeaderRequest

type MoveLeaderRequest struct {
	MemberName string `json:"memberName"`
}

type NodeShardsRequest

type NodeShardsRequest struct {
	ClusterName string `json:"clusterName"`
}

type PromoteLearnerRequest

type PromoteLearnerRequest struct {
	LearnerName string `json:"learnerName"`
}

type RemoveMemberRequest

type RemoveMemberRequest struct {
	MemberName string `json:"memberName"`
}

type RouteRequest

type RouteRequest struct {
	ClusterName string   `json:"clusterName"`
	SchemaName  string   `json:"schemaName"`
	Tables      []string `json:"table"`
}

type Router

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

Router wraps httprouter.Router and adds support for prefixed sub-routers, per-request context injections and instrumentation.

func New

func New() *Router

New returns a new Router.

func (*Router) Del

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

Del registers a new DELETE route.

func (*Router) Get

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

Get registers a new GET route.

func (*Router) Head

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

Head registers a new HEAD route.

func (*Router) Options

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

Options registers a new OPTIONS route.

func (*Router) Post

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

Post registers a new POST route.

func (*Router) Put

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

Put registers a new PUT route.

func (*Router) ServeHTTP

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

ServeHTTP implements http.Handler.

func (*Router) WithInstrumentation

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

WithInstrumentation returns a router with instrumentation support.

func (*Router) WithPrefix

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

WithPrefix returns a router that prefixes all registered routes with prefix.

type Service

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

Service is wrapper for http.Server

func NewHTTPService

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

func (*Service) Start

func (s *Service) Start() error

func (*Service) Stop

func (s *Service) Stop() error

type SplitRequest

type SplitRequest struct {
	ClusterName string   `json:"clusterName"`
	SchemaName  string   `json:"schemaName"`
	ShardID     uint32   `json:"shardID"`
	SplitTables []string `json:"splitTables"`
	NodeName    string   `json:"nodeName"`
}

type TransferLeaderRequest

type TransferLeaderRequest struct {
	ClusterName       string `json:"clusterName"`
	ShardID           uint32 `json:"shardID"`
	OldLeaderNodeName string `json:"OldLeaderNodeName"`
	NewLeaderNodeName string `json:"newLeaderNodeName"`
}

type UpdateClusterRequest

type UpdateClusterRequest struct {
	NodeCount                   uint32 `json:"nodeCount"`
	ShardTotal                  uint32 `json:"shardTotal"`
	EnableSchedule              bool   `json:"enableSchedule"`
	TopologyType                string `json:"topologyType"`
	ProcedureExecutingBatchSize uint32 `json:"procedureExecutingBatchSize"`
}

type UpdateFlowLimiterRequest

type UpdateFlowLimiterRequest struct {
	Limit  int  `json:"limit"`
	Burst  int  `json:"burst"`
	Enable bool `json:"enable"`
}

type UpdateMemberRequest

type UpdateMemberRequest struct {
	OldMemberName string   `json:"oldMemberName"`
	NewMemberAddr []string `json:"newMemberAddr"`
}