partition_server

Documentation

Index

• type Config
• type PartitionServer
  • func NewPartitionServer(config Config) *PartitionServer
  • func (ps *PartitionServer) Batch(ctx context.Context, req *pspb.BatchRequest) (*pspb.BatchResponse, error)
  • func (ps *PartitionServer) CronTaskCompact()
  • func (ps *PartitionServer) CronTaskGC()
  • func (ps *PartitionServer) Delete(ctx context.Context, req *pspb.DeleteRequest) (*pspb.DeleteResponse, error)
  • func (ps *PartitionServer) Get(ctx context.Context, req *pspb.GetRequest) (*pspb.GetResponse, error)
  • func (ps *PartitionServer) Head(ctx context.Context, req *pspb.HeadRequest) (*pspb.HeadResponse, error)
  • func (ps *PartitionServer) Init()
  • func (ps *PartitionServer) Maintenance(ctx context.Context, req *pspb.MaintenanceRequest) (*pspb.MaintenanceResponse, error)
  • func (ps *PartitionServer) Put(ctx context.Context, req *pspb.PutRequest) (*pspb.PutResponse, error)
  • func (ps *PartitionServer) Range(ctx context.Context, req *pspb.RangeRequest) (*pspb.RangeResponse, error)
  • func (ps *PartitionServer) ServeGRPC(traceSampler float64) error
  • func (ps *PartitionServer) Shutdown()
  • func (ps *PartitionServer) SplitPart(ctx context.Context, req *pspb.SplitPartRequest) (*pspb.SplitPartResponse, error)
  • func (ps *PartitionServer) StreamPut(stream pspb.PartitionKV_StreamPutServer) error

Types

type Config

type Config struct {
	PSID                 uint64
	AdvertiseURL         string
	ListenURL            string
	SmURLs               []string
	EtcdURLs             []string
	MustSync             bool
	CronTimeGC           string
	CronTimeMajorCompact string
	MaxExtentSize        uint32 //in the unit of Bytes
	MaxMetaExtentSize    uint32 //in the unit of Bytes
	SkipListSize         uint32 //in the unit of Bytes
	TraceSampler         float64
	Compression          string
	AssertKeys           bool //Check if all tables' keys are valid
	GatewayListenURL     string
	MaxUnCommitedLogSize uint64 //in the unit of Bytes
}

type PartitionServer

type PartitionServer struct {
	utils.SafeMutex //protect rangePartitions

	PSID uint64
	// contains filtered or unexported fields
}

func NewPartitionServer

func NewPartitionServer(config Config) *PartitionServer

func (*PartitionServer) Batch

func (ps *PartitionServer) Batch(ctx context.Context, req *pspb.BatchRequest) (*pspb.BatchResponse, error)

func (*PartitionServer) CronTaskCompact

func (ps *PartitionServer) CronTaskCompact()

func (*PartitionServer) CronTaskGC

func (ps *PartitionServer) CronTaskGC()

func (*PartitionServer) Delete

func (ps *PartitionServer) Delete(ctx context.Context, req *pspb.DeleteRequest) (*pspb.DeleteResponse, error)

func (*PartitionServer) Get

func (ps *PartitionServer) Get(ctx context.Context, req *pspb.GetRequest) (*pspb.GetResponse, error)

func (*PartitionServer) Head

func (ps *PartitionServer) Head(ctx context.Context, req *pspb.HeadRequest) (*pspb.HeadResponse, error)

func (*PartitionServer) Init

func (ps *PartitionServer) Init()

func (*PartitionServer) Maintenance

func (ps *PartitionServer) Maintenance(ctx context.Context, req *pspb.MaintenanceRequest) (*pspb.MaintenanceResponse, error)

func (*PartitionServer) Put

func (ps *PartitionServer) Put(ctx context.Context, req *pspb.PutRequest) (*pspb.PutResponse, error)

func (*PartitionServer) Range

func (ps *PartitionServer) Range(ctx context.Context, req *pspb.RangeRequest) (*pspb.RangeResponse, error)

func (*PartitionServer) ServeGRPC

func (ps *PartitionServer) ServeGRPC(traceSampler float64) error

func (*PartitionServer) Shutdown

func (ps *PartitionServer) Shutdown()

func (*PartitionServer) SplitPart

func (ps *PartitionServer) SplitPart(ctx context.Context, req *pspb.SplitPartRequest) (*pspb.SplitPartResponse, error)

func (*PartitionServer) StreamPut

func (ps *PartitionServer) StreamPut(stream pspb.PartitionKV_StreamPutServer) error