doorman

package
v0.0.0-...-e2b69e1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 2, 2016 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package doorman is a generated protocol buffer package.

It is generated from these files: 

doorman.proto

It has these top-level messages: 

Lease
ResourceRequest
GetCapacityRequest
ResourceResponse
Mastership
GetCapacityResponse
PriorityBandAggregate
ServerCapacityResourceRequest
GetServerCapacityRequest
ServerCapacityResourceResponse
GetServerCapacityResponse
ReleaseCapacityRequest
ReleaseCapacityResponse
NamedParameter
Algorithm
ResourceTemplate
ResourceRepository
DiscoveryRequest
DiscoveryResponse

Index

Constants

This section is empty.

Variables

View Source 
var Algorithm_Kind_name = map[int32]string{
	0: "NO_ALGORITHM",
	1: "STATIC",
	2: "PROPORTIONAL_SHARE",
	3: "FAIR_SHARE",
}
View Source 
var Algorithm_Kind_value = map[string]int32{
	"NO_ALGORITHM":       0,
	"STATIC":             1,
	"PROPORTIONAL_SHARE": 2,
	"FAIR_SHARE":         3,
}

Functions

func RegisterCapacityServer 

func RegisterCapacityServer(s *grpc.Server, srv CapacityServer)

Types

type Algorithm 

type Algorithm struct {
	Kind *Algorithm_Kind `protobuf:"varint,1,req,name=kind,enum=doorman.Algorithm_Kind" json:"kind,omitempty"`
	// How long should the lease be, in seconds.
	LeaseLength *int64 `protobuf:"varint,2,req,name=lease_length" json:"lease_length,omitempty"`
	// How many seconds should the client wait until refreshing its
	// lease.
	RefreshInterval *int64            `protobuf:"varint,3,req,name=refresh_interval" json:"refresh_interval,omitempty"`
	Parameters      []*NamedParameter `protobuf:"bytes,4,rep,name=parameters" json:"parameters,omitempty"`
	// By default the learning mode duration is the lease length,
	// however if you want to live dangerously, and assume that
	// clients are living up to their responsibility to contact
	// the server every refresh_interval, you can specify a shorter
	// learning mode here. You can also specify a longer learning
	// mode duration (longer than the lease length), but then you
	// are a muppet (or you do not trust the clients, in which case
	// you need to fix the client implementation).
	LearningModeDuration *int64 `protobuf:"varint,5,opt,name=learning_mode_duration" json:"learning_mode_duration,omitempty"`
	XXX_unrecognized     []byte `json:"-"`
}

func (*Algorithm) Descriptor 

func (*Algorithm) Descriptor() ([]byte, []int)

func (*Algorithm) GetKind 

func (m *Algorithm) GetKind() Algorithm_Kind

func (*Algorithm) GetLearningModeDuration 

func (m *Algorithm) GetLearningModeDuration() int64

func (*Algorithm) GetLeaseLength 

func (m *Algorithm) GetLeaseLength() int64

func (*Algorithm) GetParameters 

func (m *Algorithm) GetParameters() []*NamedParameter

func (*Algorithm) GetRefreshInterval 

func (m *Algorithm) GetRefreshInterval() int64

func (*Algorithm) ProtoMessage 

func (*Algorithm) ProtoMessage()

func (*Algorithm) Reset 

func (m *Algorithm) Reset()

func (*Algorithm) String 

func (m *Algorithm) String() string

type Algorithm_Kind 

type Algorithm_Kind int32
const (
	Algorithm_NO_ALGORITHM       Algorithm_Kind = 0
	Algorithm_STATIC             Algorithm_Kind = 1
	Algorithm_PROPORTIONAL_SHARE Algorithm_Kind = 2
	Algorithm_FAIR_SHARE         Algorithm_Kind = 3
)

func (Algorithm_Kind) Enum 

func (x Algorithm_Kind) Enum() *Algorithm_Kind

func (Algorithm_Kind) EnumDescriptor 

func (Algorithm_Kind) EnumDescriptor() ([]byte, []int)

func (Algorithm_Kind) String 

func (x Algorithm_Kind) String() string

func (*Algorithm_Kind) UnmarshalJSON 

func (x *Algorithm_Kind) UnmarshalJSON(data []byte) error

type CapacityClient 

type CapacityClient interface {
	// Used by clients to discover the master Doorman server.
	Discovery(ctx context.Context, in *DiscoveryRequest, opts ...grpc.CallOption) (*DiscoveryResponse, error)
	// Used by clients to obtain capacity from Doorman.
	GetCapacity(ctx context.Context, in *GetCapacityRequest, opts ...grpc.CallOption) (*GetCapacityResponse, error)
	// Used by Doorman servers to get capacity on behalf of their clients from
	// lower level Doorman servers.
	GetServerCapacity(ctx context.Context, in *GetServerCapacityRequest, opts ...grpc.CallOption) (*GetServerCapacityResponse, error)
	// Used by clients to release any capacity they have for one or more
	// resources.
	ReleaseCapacity(ctx context.Context, in *ReleaseCapacityRequest, opts ...grpc.CallOption) (*ReleaseCapacityResponse, error)
}

func NewCapacityClient 

func NewCapacityClient(cc *grpc.ClientConn) CapacityClient

type CapacityServer 

type CapacityServer interface {
	// Used by clients to discover the master Doorman server.
	Discovery(context.Context, *DiscoveryRequest) (*DiscoveryResponse, error)
	// Used by clients to obtain capacity from Doorman.
	GetCapacity(context.Context, *GetCapacityRequest) (*GetCapacityResponse, error)
	// Used by Doorman servers to get capacity on behalf of their clients from
	// lower level Doorman servers.
	GetServerCapacity(context.Context, *GetServerCapacityRequest) (*GetServerCapacityResponse, error)
	// Used by clients to release any capacity they have for one or more
	// resources.
	ReleaseCapacity(context.Context, *ReleaseCapacityRequest) (*ReleaseCapacityResponse, error)
}

type DiscoveryRequest 

type DiscoveryRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

The request to obtain the master's address.

func (*DiscoveryRequest) Descriptor 

func (*DiscoveryRequest) Descriptor() ([]byte, []int)

func (*DiscoveryRequest) ProtoMessage 

func (*DiscoveryRequest) ProtoMessage()

func (*DiscoveryRequest) Reset 

func (m *DiscoveryRequest) Reset()

func (*DiscoveryRequest) String 

func (m *DiscoveryRequest) String() string

type DiscoveryResponse 

type DiscoveryResponse struct {
	Mastership       *Mastership `protobuf:"bytes,1,req,name=mastership" json:"mastership,omitempty"`
	IsMaster         *bool       `protobuf:"varint,2,req,name=is_master" json:"is_master,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

The response containing the master's address.

func (*DiscoveryResponse) Descriptor 

func (*DiscoveryResponse) Descriptor() ([]byte, []int)

func (*DiscoveryResponse) GetIsMaster 

func (m *DiscoveryResponse) GetIsMaster() bool

func (*DiscoveryResponse) GetMastership 

func (m *DiscoveryResponse) GetMastership() *Mastership

func (*DiscoveryResponse) ProtoMessage 

func (*DiscoveryResponse) ProtoMessage()

func (*DiscoveryResponse) Reset 

func (m *DiscoveryResponse) Reset()

func (*DiscoveryResponse) String 

func (m *DiscoveryResponse) String() string

type GetCapacityRequest 

type GetCapacityRequest struct {
	ClientId         *string            `protobuf:"bytes,1,req,name=client_id" json:"client_id,omitempty"`
	Resource         []*ResourceRequest `protobuf:"bytes,2,rep,name=resource" json:"resource,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

The GetCapacityRequest contains the identifier of the client making the request and a list of single resource capacity request protocol buffers.

func (*GetCapacityRequest) Descriptor 

func (*GetCapacityRequest) Descriptor() ([]byte, []int)

func (*GetCapacityRequest) GetClientId 

func (m *GetCapacityRequest) GetClientId() string

func (*GetCapacityRequest) GetResource 

func (m *GetCapacityRequest) GetResource() []*ResourceRequest

func (*GetCapacityRequest) ProtoMessage 

func (*GetCapacityRequest) ProtoMessage()

func (*GetCapacityRequest) Reset 

func (m *GetCapacityRequest) Reset()

func (*GetCapacityRequest) String 

func (m *GetCapacityRequest) String() string

type GetCapacityResponse 

type GetCapacityResponse struct {
	Response         []*ResourceResponse `protobuf:"bytes,1,rep,name=response" json:"response,omitempty"`
	Mastership       *Mastership         `protobuf:"bytes,2,opt,name=mastership" json:"mastership,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

The response to a GetCapacity request is a list of protocol buffers specifying the capacity for a single resource. If the mastership field is there the server is telling us that it is not the master. The new master is in the mastership message, unless the server does not know who the master is, in which case the mastership field will be there, but the master_address field in it will be empty.

func (*GetCapacityResponse) Descriptor 

func (*GetCapacityResponse) Descriptor() ([]byte, []int)

func (*GetCapacityResponse) GetMastership 

func (m *GetCapacityResponse) GetMastership() *Mastership

func (*GetCapacityResponse) GetResponse 

func (m *GetCapacityResponse) GetResponse() []*ResourceResponse

func (*GetCapacityResponse) ProtoMessage 

func (*GetCapacityResponse) ProtoMessage()

func (*GetCapacityResponse) Reset 

func (m *GetCapacityResponse) Reset()

func (*GetCapacityResponse) String 

func (m *GetCapacityResponse) String() string

type GetServerCapacityRequest 

type GetServerCapacityRequest struct {
	ServerId         *string                          `protobuf:"bytes,1,req,name=server_id" json:"server_id,omitempty"`
	Resource         []*ServerCapacityResourceRequest `protobuf:"bytes,2,rep,name=resource" json:"resource,omitempty"`
	XXX_unrecognized []byte                           `json:"-"`
}

func (*GetServerCapacityRequest) Descriptor 

func (*GetServerCapacityRequest) Descriptor() ([]byte, []int)

func (*GetServerCapacityRequest) GetResource 

func (m *GetServerCapacityRequest) GetResource() []*ServerCapacityResourceRequest

func (*GetServerCapacityRequest) GetServerId 

func (m *GetServerCapacityRequest) GetServerId() string

func (*GetServerCapacityRequest) ProtoMessage 

func (*GetServerCapacityRequest) ProtoMessage()

func (*GetServerCapacityRequest) Reset 

func (m *GetServerCapacityRequest) Reset()

func (*GetServerCapacityRequest) String 

func (m *GetServerCapacityRequest) String() string

type GetServerCapacityResponse 

type GetServerCapacityResponse struct {
	Response         []*ServerCapacityResourceResponse `protobuf:"bytes,1,rep,name=response" json:"response,omitempty"`
	Mastership       *Mastership                       `protobuf:"bytes,2,opt,name=mastership" json:"mastership,omitempty"`
	XXX_unrecognized []byte                            `json:"-"`
}

The response to a GetServerCapacity request is a list of protocol buffers specifying the capacity for a single resource. If the mastership field is there the server is telling us that it is not the master. The new master is in the mastership message, unless the server does not know who the master is, in which case the mastership field will be there, but the master_address field in it will be empty.

func (*GetServerCapacityResponse) Descriptor 

func (*GetServerCapacityResponse) Descriptor() ([]byte, []int)

func (*GetServerCapacityResponse) GetMastership 

func (m *GetServerCapacityResponse) GetMastership() *Mastership

func (*GetServerCapacityResponse) GetResponse 

func (m *GetServerCapacityResponse) GetResponse() []*ServerCapacityResourceResponse

func (*GetServerCapacityResponse) ProtoMessage 

func (*GetServerCapacityResponse) ProtoMessage()

func (*GetServerCapacityResponse) Reset 

func (m *GetServerCapacityResponse) Reset()

func (*GetServerCapacityResponse) String 

func (m *GetServerCapacityResponse) String() string

type Lease 

type Lease struct {
	ExpiryTime       *int64   `protobuf:"varint,1,req,name=expiry_time" json:"expiry_time,omitempty"`
	RefreshInterval  *int64   `protobuf:"varint,2,req,name=refresh_interval" json:"refresh_interval,omitempty"`
	Capacity         *float64 `protobuf:"fixed64,3,req,name=capacity" json:"capacity,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

Encapsulates a lease on capacity with a expiry_time in seconds since the epoch.

func (*Lease) Descriptor 

func (*Lease) Descriptor() ([]byte, []int)

func (*Lease) GetCapacity 

func (m *Lease) GetCapacity() float64

func (*Lease) GetExpiryTime 

func (m *Lease) GetExpiryTime() int64

func (*Lease) GetRefreshInterval 

func (m *Lease) GetRefreshInterval() int64

func (*Lease) ProtoMessage 

func (*Lease) ProtoMessage()

func (*Lease) Reset 

func (m *Lease) Reset()

func (*Lease) String 

func (m *Lease) String() string

type Mastership 

type Mastership struct {
	MasterAddress    *string `protobuf:"bytes,1,opt,name=master_address" json:"master_address,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

This message type is used when the server wants to convey the address of a master. If the the optional master_address field is not there that means that the server wants to tell us who the master is, but it doesn't know.

func (*Mastership) Descriptor 

func (*Mastership) Descriptor() ([]byte, []int)

func (*Mastership) GetMasterAddress 

func (m *Mastership) GetMasterAddress() string

func (*Mastership) ProtoMessage 

func (*Mastership) ProtoMessage()

func (*Mastership) Reset 

func (m *Mastership) Reset()

func (*Mastership) String 

func (m *Mastership) String() string

type NamedParameter 

type NamedParameter struct {
	Name             *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Value            *string `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

NamedParameter encapsulates a name/value pair which is used to configure an Algorithm (see below).

func (*NamedParameter) Descriptor 

func (*NamedParameter) Descriptor() ([]byte, []int)

func (*NamedParameter) GetName 

func (m *NamedParameter) GetName() string

func (*NamedParameter) GetValue 

func (m *NamedParameter) GetValue() string

func (*NamedParameter) ProtoMessage 

func (*NamedParameter) ProtoMessage()

func (*NamedParameter) Reset 

func (m *NamedParameter) Reset()

func (*NamedParameter) String 

func (m *NamedParameter) String() string

type PriorityBandAggregate 

type PriorityBandAggregate struct {
	Priority         *int64   `protobuf:"varint,1,req,name=priority" json:"priority,omitempty"`
	NumClients       *int64   `protobuf:"varint,2,req,name=num_clients" json:"num_clients,omitempty"`
	Wants            *float64 `protobuf:"fixed64,3,req,name=wants" json:"wants,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*PriorityBandAggregate) Descriptor 

func (*PriorityBandAggregate) Descriptor() ([]byte, []int)

func (*PriorityBandAggregate) GetNumClients 

func (m *PriorityBandAggregate) GetNumClients() int64

func (*PriorityBandAggregate) GetPriority 

func (m *PriorityBandAggregate) GetPriority() int64

func (*PriorityBandAggregate) GetWants 

func (m *PriorityBandAggregate) GetWants() float64

func (*PriorityBandAggregate) ProtoMessage 

func (*PriorityBandAggregate) ProtoMessage()

func (*PriorityBandAggregate) Reset 

func (m *PriorityBandAggregate) Reset()

func (*PriorityBandAggregate) String 

func (m *PriorityBandAggregate) String() string

type ReleaseCapacityRequest 

type ReleaseCapacityRequest struct {
	ClientId         *string  `protobuf:"bytes,1,req,name=client_id" json:"client_id,omitempty"`
	ResourceId       []string `protobuf:"bytes,2,rep,name=resource_id" json:"resource_id,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

The ReleaseCapacity RPC instructs the server to release all leases that this client has on one or more resources. The lease is expected to expire as part of this RPC, so the client should not use the resource anymore.

func (*ReleaseCapacityRequest) Descriptor 

func (*ReleaseCapacityRequest) Descriptor() ([]byte, []int)

func (*ReleaseCapacityRequest) GetClientId 

func (m *ReleaseCapacityRequest) GetClientId() string

func (*ReleaseCapacityRequest) GetResourceId 

func (m *ReleaseCapacityRequest) GetResourceId() []string

func (*ReleaseCapacityRequest) ProtoMessage 

func (*ReleaseCapacityRequest) ProtoMessage()

func (*ReleaseCapacityRequest) Reset 

func (m *ReleaseCapacityRequest) Reset()

func (*ReleaseCapacityRequest) String 

func (m *ReleaseCapacityRequest) String() string

type ReleaseCapacityResponse 

type ReleaseCapacityResponse struct {
	Mastership       *Mastership `protobuf:"bytes,1,opt,name=mastership" json:"mastership,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

A ReleaseCapacity RPC can only fail if the server we are talking to is not the master. In that case the mastership field indicates who the master is (if we know, if we don't know the mastership field will be there but the optional master_addres field inside mastership will not be there).

func (*ReleaseCapacityResponse) Descriptor 

func (*ReleaseCapacityResponse) Descriptor() ([]byte, []int)

func (*ReleaseCapacityResponse) GetMastership 

func (m *ReleaseCapacityResponse) GetMastership() *Mastership

func (*ReleaseCapacityResponse) ProtoMessage 

func (*ReleaseCapacityResponse) ProtoMessage()

func (*ReleaseCapacityResponse) Reset 

func (m *ReleaseCapacityResponse) Reset()

func (*ReleaseCapacityResponse) String 

func (m *ReleaseCapacityResponse) String() string

type ResourceRepository 

type ResourceRepository struct {
	// List of ResourceTemplates specifying available resources. Order
	// of elements in this list is significant: it will be used to match
	// incoming requests. A template for * should be the last element.
	Resources        []*ResourceTemplate `protobuf:"bytes,1,rep,name=resources" json:"resources,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

The resource configuration consists of a list of templates.

func (*ResourceRepository) Descriptor 

func (*ResourceRepository) Descriptor() ([]byte, []int)

func (*ResourceRepository) GetResources 

func (m *ResourceRepository) GetResources() []*ResourceTemplate

func (*ResourceRepository) ProtoMessage 

func (*ResourceRepository) ProtoMessage()

func (*ResourceRepository) Reset 

func (m *ResourceRepository) Reset()

func (*ResourceRepository) String 

func (m *ResourceRepository) String() string

type ResourceRequest 

type ResourceRequest struct {
	ResourceId       *string  `protobuf:"bytes,1,req,name=resource_id" json:"resource_id,omitempty"`
	Priority         *int64   `protobuf:"varint,2,req,name=priority" json:"priority,omitempty"`
	Has              *Lease   `protobuf:"bytes,3,opt,name=has" json:"has,omitempty"`
	Wants            *float64 `protobuf:"fixed64,4,req,name=wants" json:"wants,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

Encapsulates the information we need to send to get capacity for a single resource.

func (*ResourceRequest) Descriptor 

func (*ResourceRequest) Descriptor() ([]byte, []int)

func (*ResourceRequest) GetHas 

func (m *ResourceRequest) GetHas() *Lease

func (*ResourceRequest) GetPriority 

func (m *ResourceRequest) GetPriority() int64

func (*ResourceRequest) GetResourceId 

func (m *ResourceRequest) GetResourceId() string

func (*ResourceRequest) GetWants 

func (m *ResourceRequest) GetWants() float64

func (*ResourceRequest) ProtoMessage 

func (*ResourceRequest) ProtoMessage()

func (*ResourceRequest) Reset 

func (m *ResourceRequest) Reset()

func (*ResourceRequest) String 

func (m *ResourceRequest) String() string

type ResourceResponse 

type ResourceResponse struct {
	ResourceId       *string  `protobuf:"bytes,1,req,name=resource_id" json:"resource_id,omitempty"`
	Gets             *Lease   `protobuf:"bytes,2,req,name=gets" json:"gets,omitempty"`
	SafeCapacity     *float64 `protobuf:"fixed64,3,opt,name=safe_capacity" json:"safe_capacity,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

Contains the capacity allocated by the server for a single resource.

func (*ResourceResponse) Descriptor 

func (*ResourceResponse) Descriptor() ([]byte, []int)

func (*ResourceResponse) GetGets 

func (m *ResourceResponse) GetGets() *Lease

func (*ResourceResponse) GetResourceId 

func (m *ResourceResponse) GetResourceId() string

func (*ResourceResponse) GetSafeCapacity 

func (m *ResourceResponse) GetSafeCapacity() float64

func (*ResourceResponse) ProtoMessage 

func (*ResourceResponse) ProtoMessage()

func (*ResourceResponse) Reset 

func (m *ResourceResponse) Reset()

func (*ResourceResponse) String 

func (m *ResourceResponse) String() string

type ResourceTemplate 

type ResourceTemplate struct {
	// Glob used to match actual resources.
	IdentifierGlob *string `protobuf:"bytes,1,req,name=identifier_glob" json:"identifier_glob,omitempty"`
	// Capacity in service units
	Capacity *float64 `protobuf:"fixed64,2,req,name=capacity" json:"capacity,omitempty"`
	// Algorithm used to divide capacity between clients.
	Algorithm *Algorithm `protobuf:"bytes,3,req,name=algorithm" json:"algorithm,omitempty"`
	// Capacity to use in "safe" mode.
	// You can set this to a number and then the client will use that number
	// as the capacity in case it cannot refresh its lease.
	// If this field is absent the system returns a dynamic safe capacity in
	// the response, which is the available capacity divided by the number of
	// clients that the server knows about.
	SafeCapacity *float64 `protobuf:"fixed64,4,opt,name=safe_capacity" json:"safe_capacity,omitempty"`
	// Description of the resource.
	Description      *string `protobuf:"bytes,5,opt,name=description" json:"description,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

ResourceTemplate is used to instantiate the actual configuration for a resource based on a match with the identifier_glob glob.

func (*ResourceTemplate) Descriptor 

func (*ResourceTemplate) Descriptor() ([]byte, []int)

func (*ResourceTemplate) GetAlgorithm 

func (m *ResourceTemplate) GetAlgorithm() *Algorithm

func (*ResourceTemplate) GetCapacity 

func (m *ResourceTemplate) GetCapacity() float64

func (*ResourceTemplate) GetDescription 

func (m *ResourceTemplate) GetDescription() string

func (*ResourceTemplate) GetIdentifierGlob 

func (m *ResourceTemplate) GetIdentifierGlob() string

func (*ResourceTemplate) GetSafeCapacity 

func (m *ResourceTemplate) GetSafeCapacity() float64

func (*ResourceTemplate) ProtoMessage 

func (*ResourceTemplate) ProtoMessage()

func (*ResourceTemplate) Reset 

func (m *ResourceTemplate) Reset()

func (*ResourceTemplate) String 

func (m *ResourceTemplate) String() string

type ServerCapacityResourceRequest 

type ServerCapacityResourceRequest struct {
	ResourceId       *string                  `protobuf:"bytes,1,req,name=resource_id" json:"resource_id,omitempty"`
	Has              *Lease                   `protobuf:"bytes,2,opt,name=has" json:"has,omitempty"`
	Wants            []*PriorityBandAggregate `protobuf:"bytes,3,rep,name=wants" json:"wants,omitempty"`
	XXX_unrecognized []byte                   `json:"-"`
}

func (*ServerCapacityResourceRequest) Descriptor 

func (*ServerCapacityResourceRequest) Descriptor() ([]byte, []int)

func (*ServerCapacityResourceRequest) GetHas 

func (m *ServerCapacityResourceRequest) GetHas() *Lease

func (*ServerCapacityResourceRequest) GetResourceId 

func (m *ServerCapacityResourceRequest) GetResourceId() string

func (*ServerCapacityResourceRequest) GetWants 

func (m *ServerCapacityResourceRequest) GetWants() []*PriorityBandAggregate

func (*ServerCapacityResourceRequest) ProtoMessage 

func (*ServerCapacityResourceRequest) ProtoMessage()

func (*ServerCapacityResourceRequest) Reset 

func (m *ServerCapacityResourceRequest) Reset()

func (*ServerCapacityResourceRequest) String 

func (m *ServerCapacityResourceRequest) String() string

type ServerCapacityResourceResponse 

type ServerCapacityResourceResponse struct {
	ResourceId       *string    `protobuf:"bytes,1,req,name=resource_id" json:"resource_id,omitempty"`
	Gets             *Lease     `protobuf:"bytes,2,req,name=gets" json:"gets,omitempty"`
	Algorithm        *Algorithm `protobuf:"bytes,3,opt,name=algorithm" json:"algorithm,omitempty"`
	SafeCapacity     *float64   `protobuf:"fixed64,4,opt,name=safe_capacity" json:"safe_capacity,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*ServerCapacityResourceResponse) Descriptor 

func (*ServerCapacityResourceResponse) Descriptor() ([]byte, []int)

func (*ServerCapacityResourceResponse) GetAlgorithm 

func (m *ServerCapacityResourceResponse) GetAlgorithm() *Algorithm

func (*ServerCapacityResourceResponse) GetGets 

func (m *ServerCapacityResourceResponse) GetGets() *Lease

func (*ServerCapacityResourceResponse) GetResourceId 

func (m *ServerCapacityResourceResponse) GetResourceId() string

func (*ServerCapacityResourceResponse) GetSafeCapacity 

func (m *ServerCapacityResourceResponse) GetSafeCapacity() float64

func (*ServerCapacityResourceResponse) ProtoMessage 

func (*ServerCapacityResourceResponse) ProtoMessage()

func (*ServerCapacityResourceResponse) Reset 

func (m *ServerCapacityResourceResponse) Reset()

func (*ServerCapacityResourceResponse) String 

func (m *ServerCapacityResourceResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.