server

package

v0.1.0 Latest Latest Go to latest Published: Jun 15, 2023 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var SetUpRestHandler = func(srv *Service) (http.Handler, apiutil.APIServiceGroup) {
	return dummyRestService{}, apiutil.APIServiceGroup{}
}

SetUpRestHandler is a hook to sets up the REST service.

func NewService[T ClusterIDProvider](svr bs.Server) registry.RegistrableService

NewService creates a new meta storage service.

type ClusterIDProvider interface {
	ClusterID() uint64
}

ClusterIDProvider is used to get cluster ID from the given `bs.server`

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

Manager is the manager of resource group.

func NewManager[T ClusterIDProvider](srv bs.Server) *Manager

NewManager returns a new Manager.

func (m *Manager) ClusterID() uint64

ClusterID returns the cluster ID.

func (m *Manager) GetClient() *clientv3.Client

GetClient returns the client of etcd.

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

Service is the gRPC service for meta storage.

func (s *Service) Get(ctx context.Context, req *meta_storagepb.GetRequest) (*meta_storagepb.GetResponse, error)

Get gets the key-value pair with a given key.

func (s *Service) Put(ctx context.Context, req *meta_storagepb.PutRequest) (*meta_storagepb.PutResponse, error)

Put puts the key-value pair into meta storage.

func (s *Service) RegisterGRPCService(g *grpc.Server)

RegisterGRPCService registers the service to gRPC server.

func (s *Service) RegisterRESTHandler(userDefineHandlers map[string]http.Handler)

RegisterRESTHandler registers the service to REST server.

func (s *Service) Watch(req *meta_storagepb.WatchRequest, server meta_storagepb.MetaStorage_WatchServer) error

Watch watches the key with a given prefix and revision.

Path	Synopsis
install