partition_server

Documentation

Index

• type PartitionServer
  • func NewPartitionServer(smURLs []string, etcdURLs []string, PSID uint64, advertiseURL string, ...) *PartitionServer
  • func (ps *PartitionServer) Batch(ctx context.Context, req *pspb.BatchRequest) (*pspb.BatchResponse, error)
  • 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) Init()
  • 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() error
  • func (ps *PartitionServer) Shutdown()
  • func (ps *PartitionServer) SplitPart(ctx context.Context, req *pspb.SplitPartRequest) (*pspb.SplitPartResponse, error)
• type PartitionServerConfig

Types

type PartitionServer

type PartitionServer struct {
	utils.SafeMutex //protect rangePartitions

	PSID uint64
	// contains filtered or unexported fields
}

func NewPartitionServer

func NewPartitionServer(smURLs []string, etcdURLs []string, PSID uint64, advertiseURL string, listenURL string, mustSync bool) *PartitionServer

func (*PartitionServer) Batch

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

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) Init

func (ps *PartitionServer) Init()

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() error

func (*PartitionServer) Shutdown

func (ps *PartitionServer) Shutdown()

func (*PartitionServer) SplitPart

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

type PartitionServerConfig

type PartitionServerConfig struct {
	ListenURL string
	SmURLs    []string
	EtcdURLs  []string
	MustSync  bool
	// contains filtered or unexported fields
}