messages

package
v1.12.1 Latest Latest
Warning

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

 Go to latest Published: Jun 6, 2018 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ClientStats 

type ClientStats struct {
	// The timestamp of generating the report.
	Timestamp *Timestamp `protobuf:"bytes,1,opt,name=timestamp" json:"timestamp,omitempty"`
	// The total number of RPCs that started.
	NumCallsStarted int64 `protobuf:"varint,2,opt,name=num_calls_started,json=numCallsStarted" json:"num_calls_started,omitempty"`
	// The total number of RPCs that finished.
	NumCallsFinished int64 `protobuf:"varint,3,opt,name=num_calls_finished,json=numCallsFinished" json:"num_calls_finished,omitempty"`
	// The total number of RPCs that were dropped by the client because of rate
	// limiting.
	NumCallsFinishedWithDropForRateLimiting int64 `` /* 184-byte string literal not displayed */
	// The total number of RPCs that were dropped by the client because of load
	// balancing.
	NumCallsFinishedWithDropForLoadBalancing int64 `` /* 187-byte string literal not displayed */
	// The total number of RPCs that failed to reach a server except dropped RPCs.
	NumCallsFinishedWithClientFailedToSend int64 `` /* 181-byte string literal not displayed */
	// The total number of RPCs that finished and are known to have been received
	// by a server.
	NumCallsFinishedKnownReceived int64    `` /* 148-byte string literal not displayed */
	XXX_NoUnkeyedLiteral          struct{} `json:"-"`
	XXX_unrecognized              []byte   `json:"-"`
	XXX_sizecache                 int32    `json:"-"`
}

Contains client level statistics that are useful to load balancing. Each count except the timestamp should be reset to zero after reporting the stats.

func (*ClientStats) Descriptor 

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

func (*ClientStats) GetNumCallsFinished 

func (m *ClientStats) GetNumCallsFinished() int64

func (*ClientStats) GetNumCallsFinishedKnownReceived 

func (m *ClientStats) GetNumCallsFinishedKnownReceived() int64

func (*ClientStats) GetNumCallsFinishedWithClientFailedToSend 

func (m *ClientStats) GetNumCallsFinishedWithClientFailedToSend() int64

func (*ClientStats) GetNumCallsFinishedWithDropForLoadBalancing 

func (m *ClientStats) GetNumCallsFinishedWithDropForLoadBalancing() int64

func (*ClientStats) GetNumCallsFinishedWithDropForRateLimiting 

func (m *ClientStats) GetNumCallsFinishedWithDropForRateLimiting() int64

func (*ClientStats) GetNumCallsStarted 

func (m *ClientStats) GetNumCallsStarted() int64

func (*ClientStats) GetTimestamp 

func (m *ClientStats) GetTimestamp() *Timestamp

func (*ClientStats) ProtoMessage 

func (*ClientStats) ProtoMessage()

func (*ClientStats) Reset 

func (m *ClientStats) Reset()

func (*ClientStats) String 

func (m *ClientStats) String() string

func (*ClientStats) XXX_DiscardUnknown added in v1.12.0 

func (m *ClientStats) XXX_DiscardUnknown()

func (*ClientStats) XXX_Marshal added in v1.12.0 

func (m *ClientStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientStats) XXX_Merge added in v1.12.0 

func (dst *ClientStats) XXX_Merge(src proto.Message)

func (*ClientStats) XXX_Size added in v1.12.0 

func (m *ClientStats) XXX_Size() int

func (*ClientStats) XXX_Unmarshal added in v1.12.0 

func (m *ClientStats) XXX_Unmarshal(b []byte) error

type Duration 

type Duration struct {
	// Signed seconds of the span of time. Must be from -315,576,000,000
	// to +315,576,000,000 inclusive.
	Seconds int64 `protobuf:"varint,1,opt,name=seconds" json:"seconds,omitempty"`
	// Signed fractions of a second at nanosecond resolution of the span
	// of time. Durations less than one second are represented with a 0
	// `seconds` field and a positive or negative `nanos` field. For durations
	// of one second or more, a non-zero value for the `nanos` field must be
	// of the same sign as the `seconds` field. Must be from -999,999,999
	// to +999,999,999 inclusive.
	Nanos                int32    `protobuf:"varint,2,opt,name=nanos" json:"nanos,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Duration) Descriptor 

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

func (*Duration) GetNanos 

func (m *Duration) GetNanos() int32

func (*Duration) GetSeconds 

func (m *Duration) GetSeconds() int64

func (*Duration) ProtoMessage 

func (*Duration) ProtoMessage()

func (*Duration) Reset 

func (m *Duration) Reset()

func (*Duration) String 

func (m *Duration) String() string

func (*Duration) XXX_DiscardUnknown added in v1.12.0 

func (m *Duration) XXX_DiscardUnknown()

func (*Duration) XXX_Marshal added in v1.12.0 

func (m *Duration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Duration) XXX_Merge added in v1.12.0 

func (dst *Duration) XXX_Merge(src proto.Message)

func (*Duration) XXX_Size added in v1.12.0 

func (m *Duration) XXX_Size() int

func (*Duration) XXX_Unmarshal added in v1.12.0 

func (m *Duration) XXX_Unmarshal(b []byte) error

type InitialLoadBalanceRequest 

type InitialLoadBalanceRequest struct {
	// Name of load balanced service (IE, balancer.service.com)
	// length should be less than 256 bytes.
	Name                 string   `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InitialLoadBalanceRequest) Descriptor 

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

func (*InitialLoadBalanceRequest) GetName 

func (m *InitialLoadBalanceRequest) GetName() string

func (*InitialLoadBalanceRequest) ProtoMessage 

func (*InitialLoadBalanceRequest) ProtoMessage()

func (*InitialLoadBalanceRequest) Reset 

func (m *InitialLoadBalanceRequest) Reset()

func (*InitialLoadBalanceRequest) String 

func (m *InitialLoadBalanceRequest) String() string

func (*InitialLoadBalanceRequest) XXX_DiscardUnknown added in v1.12.0 

func (m *InitialLoadBalanceRequest) XXX_DiscardUnknown()

func (*InitialLoadBalanceRequest) XXX_Marshal added in v1.12.0 

func (m *InitialLoadBalanceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InitialLoadBalanceRequest) XXX_Merge added in v1.12.0 

func (dst *InitialLoadBalanceRequest) XXX_Merge(src proto.Message)

func (*InitialLoadBalanceRequest) XXX_Size added in v1.12.0 

func (m *InitialLoadBalanceRequest) XXX_Size() int

func (*InitialLoadBalanceRequest) XXX_Unmarshal added in v1.12.0 

func (m *InitialLoadBalanceRequest) XXX_Unmarshal(b []byte) error

type InitialLoadBalanceResponse 

type InitialLoadBalanceResponse struct {
	// This is an application layer redirect that indicates the client should use
	// the specified server for load balancing. When this field is non-empty in
	// the response, the client should open a separate connection to the
	// load_balancer_delegate and call the BalanceLoad method. Its length should
	// be less than 64 bytes.
	LoadBalancerDelegate string `protobuf:"bytes,1,opt,name=load_balancer_delegate,json=loadBalancerDelegate" json:"load_balancer_delegate,omitempty"`
	// This interval defines how often the client should send the client stats
	// to the load balancer. Stats should only be reported when the duration is
	// positive.
	ClientStatsReportInterval *Duration `` /* 133-byte string literal not displayed */
	XXX_NoUnkeyedLiteral      struct{}  `json:"-"`
	XXX_unrecognized          []byte    `json:"-"`
	XXX_sizecache             int32     `json:"-"`
}

func (*InitialLoadBalanceResponse) Descriptor 

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

func (*InitialLoadBalanceResponse) GetClientStatsReportInterval 

func (m *InitialLoadBalanceResponse) GetClientStatsReportInterval() *Duration

func (*InitialLoadBalanceResponse) GetLoadBalancerDelegate 

func (m *InitialLoadBalanceResponse) GetLoadBalancerDelegate() string

func (*InitialLoadBalanceResponse) ProtoMessage 

func (*InitialLoadBalanceResponse) ProtoMessage()

func (*InitialLoadBalanceResponse) Reset 

func (m *InitialLoadBalanceResponse) Reset()

func (*InitialLoadBalanceResponse) String 

func (m *InitialLoadBalanceResponse) String() string

func (*InitialLoadBalanceResponse) XXX_DiscardUnknown added in v1.12.0 

func (m *InitialLoadBalanceResponse) XXX_DiscardUnknown()

func (*InitialLoadBalanceResponse) XXX_Marshal added in v1.12.0 

func (m *InitialLoadBalanceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InitialLoadBalanceResponse) XXX_Merge added in v1.12.0 

func (dst *InitialLoadBalanceResponse) XXX_Merge(src proto.Message)

func (*InitialLoadBalanceResponse) XXX_Size added in v1.12.0 

func (m *InitialLoadBalanceResponse) XXX_Size() int

func (*InitialLoadBalanceResponse) XXX_Unmarshal added in v1.12.0 

func (m *InitialLoadBalanceResponse) XXX_Unmarshal(b []byte) error

type LoadBalanceRequest 

type LoadBalanceRequest struct {
	// Types that are valid to be assigned to LoadBalanceRequestType:
	//	*LoadBalanceRequest_InitialRequest
	//	*LoadBalanceRequest_ClientStats
	LoadBalanceRequestType isLoadBalanceRequest_LoadBalanceRequestType `protobuf_oneof:"load_balance_request_type"`
	XXX_NoUnkeyedLiteral   struct{}                                    `json:"-"`
	XXX_unrecognized       []byte                                      `json:"-"`
	XXX_sizecache          int32                                       `json:"-"`
}

func (*LoadBalanceRequest) Descriptor 

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

func (*LoadBalanceRequest) GetClientStats 

func (m *LoadBalanceRequest) GetClientStats() *ClientStats

func (*LoadBalanceRequest) GetInitialRequest 

func (m *LoadBalanceRequest) GetInitialRequest() *InitialLoadBalanceRequest

func (*LoadBalanceRequest) GetLoadBalanceRequestType 

func (m *LoadBalanceRequest) GetLoadBalanceRequestType() isLoadBalanceRequest_LoadBalanceRequestType

func (*LoadBalanceRequest) ProtoMessage 

func (*LoadBalanceRequest) ProtoMessage()

func (*LoadBalanceRequest) Reset 

func (m *LoadBalanceRequest) Reset()

func (*LoadBalanceRequest) String 

func (m *LoadBalanceRequest) String() string

func (*LoadBalanceRequest) XXX_DiscardUnknown added in v1.12.0 

func (m *LoadBalanceRequest) XXX_DiscardUnknown()

func (*LoadBalanceRequest) XXX_Marshal added in v1.12.0 

func (m *LoadBalanceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadBalanceRequest) XXX_Merge added in v1.12.0 

func (dst *LoadBalanceRequest) XXX_Merge(src proto.Message)

func (*LoadBalanceRequest) XXX_OneofFuncs 

func (*LoadBalanceRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*LoadBalanceRequest) XXX_Size added in v1.12.0 

func (m *LoadBalanceRequest) XXX_Size() int

func (*LoadBalanceRequest) XXX_Unmarshal added in v1.12.0 

func (m *LoadBalanceRequest) XXX_Unmarshal(b []byte) error

type LoadBalanceRequest_ClientStats 

type LoadBalanceRequest_ClientStats struct {
	ClientStats *ClientStats `protobuf:"bytes,2,opt,name=client_stats,json=clientStats,oneof"`
}

type LoadBalanceRequest_InitialRequest 

type LoadBalanceRequest_InitialRequest struct {
	InitialRequest *InitialLoadBalanceRequest `protobuf:"bytes,1,opt,name=initial_request,json=initialRequest,oneof"`
}

type LoadBalanceResponse 

type LoadBalanceResponse struct {
	// Types that are valid to be assigned to LoadBalanceResponseType:
	//	*LoadBalanceResponse_InitialResponse
	//	*LoadBalanceResponse_ServerList
	LoadBalanceResponseType isLoadBalanceResponse_LoadBalanceResponseType `protobuf_oneof:"load_balance_response_type"`
	XXX_NoUnkeyedLiteral    struct{}                                      `json:"-"`
	XXX_unrecognized        []byte                                        `json:"-"`
	XXX_sizecache           int32                                         `json:"-"`
}

func (*LoadBalanceResponse) Descriptor 

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

func (*LoadBalanceResponse) GetInitialResponse 

func (m *LoadBalanceResponse) GetInitialResponse() *InitialLoadBalanceResponse

func (*LoadBalanceResponse) GetLoadBalanceResponseType 

func (m *LoadBalanceResponse) GetLoadBalanceResponseType() isLoadBalanceResponse_LoadBalanceResponseType

func (*LoadBalanceResponse) GetServerList 

func (m *LoadBalanceResponse) GetServerList() *ServerList

func (*LoadBalanceResponse) ProtoMessage 

func (*LoadBalanceResponse) ProtoMessage()

func (*LoadBalanceResponse) Reset 

func (m *LoadBalanceResponse) Reset()

func (*LoadBalanceResponse) String 

func (m *LoadBalanceResponse) String() string

func (*LoadBalanceResponse) XXX_DiscardUnknown added in v1.12.0 

func (m *LoadBalanceResponse) XXX_DiscardUnknown()

func (*LoadBalanceResponse) XXX_Marshal added in v1.12.0 

func (m *LoadBalanceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadBalanceResponse) XXX_Merge added in v1.12.0 

func (dst *LoadBalanceResponse) XXX_Merge(src proto.Message)

func (*LoadBalanceResponse) XXX_OneofFuncs 

func (*LoadBalanceResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*LoadBalanceResponse) XXX_Size added in v1.12.0 

func (m *LoadBalanceResponse) XXX_Size() int

func (*LoadBalanceResponse) XXX_Unmarshal added in v1.12.0 

func (m *LoadBalanceResponse) XXX_Unmarshal(b []byte) error

type LoadBalanceResponse_InitialResponse 

type LoadBalanceResponse_InitialResponse struct {
	InitialResponse *InitialLoadBalanceResponse `protobuf:"bytes,1,opt,name=initial_response,json=initialResponse,oneof"`
}

type LoadBalanceResponse_ServerList 

type LoadBalanceResponse_ServerList struct {
	ServerList *ServerList `protobuf:"bytes,2,opt,name=server_list,json=serverList,oneof"`
}

type Server 

type Server struct {
	// A resolved address for the server, serialized in network-byte-order. It may
	// either be an IPv4 or IPv6 address.
	IpAddress []byte `protobuf:"bytes,1,opt,name=ip_address,json=ipAddress,proto3" json:"ip_address,omitempty"`
	// A resolved port number for the server.
	Port int32 `protobuf:"varint,2,opt,name=port" json:"port,omitempty"`
	// An opaque but printable token given to the frontend for each pick. All
	// frontend requests for that pick must include the token in its initial
	// metadata. The token is used by the backend to verify the request and to
	// allow the backend to report load to the gRPC LB system.
	//
	// Its length is variable but less than 50 bytes.
	LoadBalanceToken string `protobuf:"bytes,3,opt,name=load_balance_token,json=loadBalanceToken" json:"load_balance_token,omitempty"`
	// Indicates whether this particular request should be dropped by the client
	// for rate limiting.
	DropForRateLimiting bool `protobuf:"varint,4,opt,name=drop_for_rate_limiting,json=dropForRateLimiting" json:"drop_for_rate_limiting,omitempty"`
	// Indicates whether this particular request should be dropped by the client
	// for load balancing.
	DropForLoadBalancing bool     `protobuf:"varint,5,opt,name=drop_for_load_balancing,json=dropForLoadBalancing" json:"drop_for_load_balancing,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Contains server information. When none of the [drop_for_*] fields are true, use the other fields. When drop_for_rate_limiting is true, ignore all other fields. Use drop_for_load_balancing only when it is true and drop_for_rate_limiting is false.

func (*Server) Descriptor 

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

func (*Server) GetDropForLoadBalancing 

func (m *Server) GetDropForLoadBalancing() bool

func (*Server) GetDropForRateLimiting 

func (m *Server) GetDropForRateLimiting() bool

func (*Server) GetIpAddress 

func (m *Server) GetIpAddress() []byte

func (*Server) GetLoadBalanceToken 

func (m *Server) GetLoadBalanceToken() string

func (*Server) GetPort 

func (m *Server) GetPort() int32

func (*Server) ProtoMessage 

func (*Server) ProtoMessage()

func (*Server) Reset 

func (m *Server) Reset()

func (*Server) String 

func (m *Server) String() string

func (*Server) XXX_DiscardUnknown added in v1.12.0 

func (m *Server) XXX_DiscardUnknown()

func (*Server) XXX_Marshal added in v1.12.0 

func (m *Server) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Server) XXX_Merge added in v1.12.0 

func (dst *Server) XXX_Merge(src proto.Message)

func (*Server) XXX_Size added in v1.12.0 

func (m *Server) XXX_Size() int

func (*Server) XXX_Unmarshal added in v1.12.0 

func (m *Server) XXX_Unmarshal(b []byte) error

type ServerList 

type ServerList struct {
	// Contains a list of servers selected by the load balancer. The list will
	// be updated when server resolutions change or as needed to balance load
	// across more servers. The client should consume the server list in order
	// unless instructed otherwise via the client_config.
	Servers              []*Server `protobuf:"bytes,1,rep,name=servers" json:"servers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ServerList) Descriptor 

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

func (*ServerList) GetServers 

func (m *ServerList) GetServers() []*Server

func (*ServerList) ProtoMessage 

func (*ServerList) ProtoMessage()

func (*ServerList) Reset 

func (m *ServerList) Reset()

func (*ServerList) String 

func (m *ServerList) String() string

func (*ServerList) XXX_DiscardUnknown added in v1.12.0 

func (m *ServerList) XXX_DiscardUnknown()

func (*ServerList) XXX_Marshal added in v1.12.0 

func (m *ServerList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServerList) XXX_Merge added in v1.12.0 

func (dst *ServerList) XXX_Merge(src proto.Message)

func (*ServerList) XXX_Size added in v1.12.0 

func (m *ServerList) XXX_Size() int

func (*ServerList) XXX_Unmarshal added in v1.12.0 

func (m *ServerList) XXX_Unmarshal(b []byte) error

type Timestamp 

type Timestamp struct {
	// Represents seconds of UTC time since Unix epoch
	// 1970-01-01T00:00:00Z. Must be from 0001-01-01T00:00:00Z to
	// 9999-12-31T23:59:59Z inclusive.
	Seconds int64 `protobuf:"varint,1,opt,name=seconds" json:"seconds,omitempty"`
	// Non-negative fractions of a second at nanosecond resolution. Negative
	// second values with fractions must still have non-negative nanos values
	// that count forward in time. Must be from 0 to 999,999,999
	// inclusive.
	Nanos                int32    `protobuf:"varint,2,opt,name=nanos" json:"nanos,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Timestamp) Descriptor 

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

func (*Timestamp) GetNanos 

func (m *Timestamp) GetNanos() int32

func (*Timestamp) GetSeconds 

func (m *Timestamp) GetSeconds() int64

func (*Timestamp) ProtoMessage 

func (*Timestamp) ProtoMessage()

func (*Timestamp) Reset 

func (m *Timestamp) Reset()

func (*Timestamp) String 

func (m *Timestamp) String() string

func (*Timestamp) XXX_DiscardUnknown added in v1.12.0 

func (m *Timestamp) XXX_DiscardUnknown()

func (*Timestamp) XXX_Marshal added in v1.12.0 

func (m *Timestamp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Timestamp) XXX_Merge added in v1.12.0 

func (dst *Timestamp) XXX_Merge(src proto.Message)

func (*Timestamp) XXX_Size added in v1.12.0 

func (m *Timestamp) XXX_Size() int

func (*Timestamp) XXX_Unmarshal added in v1.12.0 

func (m *Timestamp) XXX_Unmarshal(b []byte) error

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.