rpc

package

v0.0.0-...-432d548 Latest Latest Go to latest Published: Feb 27, 2024 License: Apache-2.0 Imports: 33 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

Repository

github.com/alibaba/kube-sharding

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func NewRemoteClient(resolver EndpointResolver, serializer runtime.NegotiatedSerializer, ...) client.Client
type CalcShardIDFunc
type EndpointResolver
type FakeResolver
type NodeInfo
- func (n *NodeInfo) String() string
type RemoteClientOpts
type ResourceRequest
- func (r ResourceRequest) URL() string
type Service
- func NewService(client client.Client, resourceScheme *mem.ResourceScheme, ...) Service
type ServiceOptions
type SingleNodeInvoker
- func NewSingleNodeInvoker(src, cluster, pathFormat string, rpcNode *NodeInfo, ...) *SingleNodeInvoker

Constants ¶

View Source

const (
	// MetricRPCReadTime read data in rpc time
	// labels: [cluster, namespace, resource]
	MetricRPCReadTime = "rpc_read_time"

	// MetricRPCUnmarshalTime unmarshal time in rpc
	// labels: [cluster, namespace, resource]
	MetricRPCUnmarshalTime = "rpc_unmarshal_time"

	// MetricListRemoteTime list remote data time in rpc
	// labels: [cluster, namespace, resource]
	MetricListRemoteTime = "rpc_list_remote_time"

	// MetricRPCWriteTime write data in rpc time
	// labels: [cluster, namespace, resource, method, success]
	MetricRPCWriteTime = "rpc_write_time"
)

Variables ¶

View Source

var Metrics = monitor.NewMetricFactory()

Metrics is a metric factory.

Functions ¶

func NewRemoteClient ¶

func NewRemoteClient(resolver EndpointResolver, serializer runtime.NegotiatedSerializer, opts *RemoteClientOpts) client.Client

NewRemoteClient new remote client

Types ¶

type CalcShardIDFunc ¶

type CalcShardIDFunc func(obj interface{}) (string, error)

CalcShardIDFunc calc shardID func

type EndpointResolver ¶

type EndpointResolver interface {
	// RegisterCalcShardIDFunc  register calc shardID func
	RegisterCalcShardIDFunc(f CalcShardIDFunc)
	Resolve(namespace string, obj interface{}) (*NodeInfo, error)
	ResolveAll(namespace string) ([]*NodeInfo, error)
}

EndpointResolver resolve server address.

type FakeResolver ¶

type FakeResolver struct {
}

FakeResolver resolve server address.

func (*FakeResolver) RegisterCalcShardIDFunc ¶

func (f *FakeResolver) RegisterCalcShardIDFunc(cf CalcShardIDFunc)

RegisterCalcShardIDFunc register calc shardID func

func (*FakeResolver) Resolve ¶

func (f *FakeResolver) Resolve(namespace string, obj interface{}) (*NodeInfo, error)

Resolve resolve config

func (*FakeResolver) ResolveAll ¶

func (f *FakeResolver) ResolveAll(namespace string) ([]*NodeInfo, error)

ResolveAll resolve config

type NodeInfo ¶

type NodeInfo struct {
	IP   string
	Port string
}

NodeInfo contains ip and port

func (*NodeInfo) String ¶

func (n *NodeInfo) String() string

type RemoteClientOpts ¶

type RemoteClientOpts struct {
	Timeout int // in second
	Src     string
	Cluster string
	Group   string
	Version string
	// set Accept http header, <resource, accept-header>
	Accepts map[string]string
}

RemoteClientOpts remote client opts

type ResourceRequest ¶

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

ResourceRequest contains restful.Request

func (ResourceRequest) URL ¶

func (r ResourceRequest) URL() string

type Service ¶

type Service interface {
	GetHandlerService() *restful.WebService
}

Service represents a rpc server to serve mem kube resources.

func NewService ¶

func NewService(client client.Client, resourceScheme *mem.ResourceScheme, ns runtime.NegotiatedSerializer, opts *ServiceOptions) Service

NewService create a new rpc service. If we use http, we may pass a http container here, e.g: NewService(webContainer, ...)

type ServiceOptions ¶

type ServiceOptions struct {
}

ServiceOptions represents rpc service options, e.g, listen port.

type SingleNodeInvoker ¶

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

SingleNodeInvoker single node

func NewSingleNodeInvoker ¶

func NewSingleNodeInvoker(src, cluster, pathFormat string, rpcNode *NodeInfo, httpclient *utils.LiteHTTPClient) *SingleNodeInvoker

NewSingleNodeInvoker create new single node http invoker

func (*SingleNodeInvoker) Create ¶

func (h *SingleNodeInvoker) Create(resource, ns string, object runtime.Object) (runtime.Object, error)

Create create resource

func (*SingleNodeInvoker) Delete ¶

func (h *SingleNodeInvoker) Delete(resource, ns, name string, opts *metav1.DeleteOptions) error

Delete delete resource

func (*SingleNodeInvoker) Get ¶

func (h *SingleNodeInvoker) Get(resource, ns, name string, opts *metav1.GetOptions, into runtime.Object) (runtime.Object, error)

Get get resource

func (*SingleNodeInvoker) List ¶

func (h *SingleNodeInvoker) List(resource, ns string, opts *metav1.ListOptions, into runtime.Object) error

List query list resource

func (*SingleNodeInvoker) SetAccepts ¶

func (h *SingleNodeInvoker) SetAccepts(accepts string)

SetAccepts set http accepts header

func (*SingleNodeInvoker) Update ¶

func (h *SingleNodeInvoker) Update(resource, ns, name string, object runtime.Object) (runtime.Object, error)

Update update resource

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
resolver

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL