envoy_service_status_v2

package
v1.5.0 Latest Latest
Warning

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

Go to latest
Published: May 28, 2020 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthCsds        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCsds          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCsds = fmt.Errorf("proto: unexpected end of group")
)
View Source
var ConfigStatus_name = map[int32]string{
	0: "UNKNOWN",
	1: "SYNCED",
	2: "NOT_SENT",
	3: "STALE",
	4: "ERROR",
}
View Source
var ConfigStatus_value = map[string]int32{
	"UNKNOWN":  0,
	"SYNCED":   1,
	"NOT_SENT": 2,
	"STALE":    3,
	"ERROR":    4,
}

Functions

func RegisterClientStatusDiscoveryServiceServer

func RegisterClientStatusDiscoveryServiceServer(s *grpc.Server, srv ClientStatusDiscoveryServiceServer)

Types

type ClientConfig

type ClientConfig struct {
	// Node for a particular client.
	Node                 *core.Node      `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	XdsConfig            []*PerXdsConfig `protobuf:"bytes,2,rep,name=xds_config,json=xdsConfig,proto3" json:"xds_config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

All xds configs for a particular client.

func (*ClientConfig) Descriptor

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

func (*ClientConfig) GetNode

func (m *ClientConfig) GetNode() *core.Node

func (*ClientConfig) GetXdsConfig

func (m *ClientConfig) GetXdsConfig() []*PerXdsConfig

func (*ClientConfig) Marshal

func (m *ClientConfig) Marshal() (dAtA []byte, err error)

func (*ClientConfig) MarshalTo

func (m *ClientConfig) MarshalTo(dAtA []byte) (int, error)

func (*ClientConfig) MarshalToSizedBuffer

func (m *ClientConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientConfig) ProtoMessage

func (*ClientConfig) ProtoMessage()

func (*ClientConfig) Reset

func (m *ClientConfig) Reset()

func (*ClientConfig) Size

func (m *ClientConfig) Size() (n int)

func (*ClientConfig) String

func (m *ClientConfig) String() string

func (*ClientConfig) Unmarshal

func (m *ClientConfig) Unmarshal(dAtA []byte) error

func (*ClientConfig) Validate

func (m *ClientConfig) Validate() error

Validate checks the field values on ClientConfig with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ClientConfig) XXX_DiscardUnknown

func (m *ClientConfig) XXX_DiscardUnknown()

func (*ClientConfig) XXX_Marshal

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

func (*ClientConfig) XXX_Merge

func (m *ClientConfig) XXX_Merge(src proto.Message)

func (*ClientConfig) XXX_Size

func (m *ClientConfig) XXX_Size() int

func (*ClientConfig) XXX_Unmarshal

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

type ClientConfigValidationError

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

ClientConfigValidationError is the validation error returned by ClientConfig.Validate if the designated constraints aren't met.

func (ClientConfigValidationError) Cause

Cause function returns cause value.

func (ClientConfigValidationError) Error

Error satisfies the builtin error interface

func (ClientConfigValidationError) ErrorName

func (e ClientConfigValidationError) ErrorName() string

ErrorName returns error name.

func (ClientConfigValidationError) Field

Field function returns field value.

func (ClientConfigValidationError) Key

Key function returns key value.

func (ClientConfigValidationError) Reason

Reason function returns reason value.

type ClientStatusDiscoveryServiceClient

type ClientStatusDiscoveryServiceClient interface {
	StreamClientStatus(ctx context.Context, opts ...grpc.CallOption) (ClientStatusDiscoveryService_StreamClientStatusClient, error)
	FetchClientStatus(ctx context.Context, in *ClientStatusRequest, opts ...grpc.CallOption) (*ClientStatusResponse, error)
}

ClientStatusDiscoveryServiceClient is the client API for ClientStatusDiscoveryService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewClientStatusDiscoveryServiceClient

func NewClientStatusDiscoveryServiceClient(cc *grpc.ClientConn) ClientStatusDiscoveryServiceClient

type ClientStatusDiscoveryServiceServer

type ClientStatusDiscoveryServiceServer interface {
	StreamClientStatus(ClientStatusDiscoveryService_StreamClientStatusServer) error
	FetchClientStatus(context.Context, *ClientStatusRequest) (*ClientStatusResponse, error)
}

ClientStatusDiscoveryServiceServer is the server API for ClientStatusDiscoveryService service.

type ClientStatusDiscoveryService_StreamClientStatusClient

type ClientStatusDiscoveryService_StreamClientStatusClient interface {
	Send(*ClientStatusRequest) error
	Recv() (*ClientStatusResponse, error)
	grpc.ClientStream
}

type ClientStatusDiscoveryService_StreamClientStatusServer

type ClientStatusDiscoveryService_StreamClientStatusServer interface {
	Send(*ClientStatusResponse) error
	Recv() (*ClientStatusRequest, error)
	grpc.ServerStream
}

type ClientStatusRequest

type ClientStatusRequest struct {
	// Management server can use these match criteria to identify clients.
	// The match follows OR semantics.
	NodeMatchers         []*matcher.NodeMatcher `protobuf:"bytes,1,rep,name=node_matchers,json=nodeMatchers,proto3" json:"node_matchers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

Request for client status of clients identified by a list of NodeMatchers.

func (*ClientStatusRequest) Descriptor

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

func (*ClientStatusRequest) GetNodeMatchers

func (m *ClientStatusRequest) GetNodeMatchers() []*matcher.NodeMatcher

func (*ClientStatusRequest) Marshal

func (m *ClientStatusRequest) Marshal() (dAtA []byte, err error)

func (*ClientStatusRequest) MarshalTo

func (m *ClientStatusRequest) MarshalTo(dAtA []byte) (int, error)

func (*ClientStatusRequest) MarshalToSizedBuffer

func (m *ClientStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientStatusRequest) ProtoMessage

func (*ClientStatusRequest) ProtoMessage()

func (*ClientStatusRequest) Reset

func (m *ClientStatusRequest) Reset()

func (*ClientStatusRequest) Size

func (m *ClientStatusRequest) Size() (n int)

func (*ClientStatusRequest) String

func (m *ClientStatusRequest) String() string

func (*ClientStatusRequest) Unmarshal

func (m *ClientStatusRequest) Unmarshal(dAtA []byte) error

func (*ClientStatusRequest) Validate

func (m *ClientStatusRequest) Validate() error

Validate checks the field values on ClientStatusRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ClientStatusRequest) XXX_DiscardUnknown

func (m *ClientStatusRequest) XXX_DiscardUnknown()

func (*ClientStatusRequest) XXX_Marshal

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

func (*ClientStatusRequest) XXX_Merge

func (m *ClientStatusRequest) XXX_Merge(src proto.Message)

func (*ClientStatusRequest) XXX_Size

func (m *ClientStatusRequest) XXX_Size() int

func (*ClientStatusRequest) XXX_Unmarshal

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

type ClientStatusRequestValidationError

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

ClientStatusRequestValidationError is the validation error returned by ClientStatusRequest.Validate if the designated constraints aren't met.

func (ClientStatusRequestValidationError) Cause

Cause function returns cause value.

func (ClientStatusRequestValidationError) Error

Error satisfies the builtin error interface

func (ClientStatusRequestValidationError) ErrorName

ErrorName returns error name.

func (ClientStatusRequestValidationError) Field

Field function returns field value.

func (ClientStatusRequestValidationError) Key

Key function returns key value.

func (ClientStatusRequestValidationError) Reason

Reason function returns reason value.

type ClientStatusResponse

type ClientStatusResponse struct {
	// Client configs for the clients specified in the ClientStatusRequest.
	Config               []*ClientConfig `protobuf:"bytes,1,rep,name=config,proto3" json:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ClientStatusResponse) Descriptor

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

func (*ClientStatusResponse) GetConfig

func (m *ClientStatusResponse) GetConfig() []*ClientConfig

func (*ClientStatusResponse) Marshal

func (m *ClientStatusResponse) Marshal() (dAtA []byte, err error)

func (*ClientStatusResponse) MarshalTo

func (m *ClientStatusResponse) MarshalTo(dAtA []byte) (int, error)

func (*ClientStatusResponse) MarshalToSizedBuffer

func (m *ClientStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientStatusResponse) ProtoMessage

func (*ClientStatusResponse) ProtoMessage()

func (*ClientStatusResponse) Reset

func (m *ClientStatusResponse) Reset()

func (*ClientStatusResponse) Size

func (m *ClientStatusResponse) Size() (n int)

func (*ClientStatusResponse) String

func (m *ClientStatusResponse) String() string

func (*ClientStatusResponse) Unmarshal

func (m *ClientStatusResponse) Unmarshal(dAtA []byte) error

func (*ClientStatusResponse) Validate

func (m *ClientStatusResponse) Validate() error

Validate checks the field values on ClientStatusResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ClientStatusResponse) XXX_DiscardUnknown

func (m *ClientStatusResponse) XXX_DiscardUnknown()

func (*ClientStatusResponse) XXX_Marshal

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

func (*ClientStatusResponse) XXX_Merge

func (m *ClientStatusResponse) XXX_Merge(src proto.Message)

func (*ClientStatusResponse) XXX_Size

func (m *ClientStatusResponse) XXX_Size() int

func (*ClientStatusResponse) XXX_Unmarshal

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

type ClientStatusResponseValidationError

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

ClientStatusResponseValidationError is the validation error returned by ClientStatusResponse.Validate if the designated constraints aren't met.

func (ClientStatusResponseValidationError) Cause

Cause function returns cause value.

func (ClientStatusResponseValidationError) Error

Error satisfies the builtin error interface

func (ClientStatusResponseValidationError) ErrorName

ErrorName returns error name.

func (ClientStatusResponseValidationError) Field

Field function returns field value.

func (ClientStatusResponseValidationError) Key

Key function returns key value.

func (ClientStatusResponseValidationError) Reason

Reason function returns reason value.

type ConfigStatus

type ConfigStatus int32

Status of a config.

const (
	// Status info is not available/unknown.
	ConfigStatus_UNKNOWN ConfigStatus = 0
	// Management server has sent the config to client and received ACK.
	ConfigStatus_SYNCED ConfigStatus = 1
	// Config is not sent.
	ConfigStatus_NOT_SENT ConfigStatus = 2
	// Management server has sent the config to client but hasn’t received
	// ACK/NACK.
	ConfigStatus_STALE ConfigStatus = 3
	// Management server has sent the config to client but received NACK.
	ConfigStatus_ERROR ConfigStatus = 4
)

func (ConfigStatus) EnumDescriptor

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

func (ConfigStatus) String

func (x ConfigStatus) String() string

type PerXdsConfig

type PerXdsConfig struct {
	Status ConfigStatus `protobuf:"varint,1,opt,name=status,proto3,enum=envoy.service.status.v2.ConfigStatus" json:"status,omitempty"`
	// Types that are valid to be assigned to PerXdsConfig:
	//	*PerXdsConfig_ListenerConfig
	//	*PerXdsConfig_ClusterConfig
	//	*PerXdsConfig_RouteConfig
	//	*PerXdsConfig_ScopedRouteConfig
	PerXdsConfig         isPerXdsConfig_PerXdsConfig `protobuf_oneof:"per_xds_config"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

Detailed config (per xDS) with status. [#next-free-field: 6]

func (*PerXdsConfig) Descriptor

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

func (*PerXdsConfig) GetClusterConfig

func (m *PerXdsConfig) GetClusterConfig() *v2alpha.ClustersConfigDump

func (*PerXdsConfig) GetListenerConfig

func (m *PerXdsConfig) GetListenerConfig() *v2alpha.ListenersConfigDump

func (*PerXdsConfig) GetPerXdsConfig

func (m *PerXdsConfig) GetPerXdsConfig() isPerXdsConfig_PerXdsConfig

func (*PerXdsConfig) GetRouteConfig

func (m *PerXdsConfig) GetRouteConfig() *v2alpha.RoutesConfigDump

func (*PerXdsConfig) GetScopedRouteConfig

func (m *PerXdsConfig) GetScopedRouteConfig() *v2alpha.ScopedRoutesConfigDump

func (*PerXdsConfig) GetStatus

func (m *PerXdsConfig) GetStatus() ConfigStatus

func (*PerXdsConfig) Marshal

func (m *PerXdsConfig) Marshal() (dAtA []byte, err error)

func (*PerXdsConfig) MarshalTo

func (m *PerXdsConfig) MarshalTo(dAtA []byte) (int, error)

func (*PerXdsConfig) MarshalToSizedBuffer

func (m *PerXdsConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PerXdsConfig) ProtoMessage

func (*PerXdsConfig) ProtoMessage()

func (*PerXdsConfig) Reset

func (m *PerXdsConfig) Reset()

func (*PerXdsConfig) Size

func (m *PerXdsConfig) Size() (n int)

func (*PerXdsConfig) String

func (m *PerXdsConfig) String() string

func (*PerXdsConfig) Unmarshal

func (m *PerXdsConfig) Unmarshal(dAtA []byte) error

func (*PerXdsConfig) Validate

func (m *PerXdsConfig) Validate() error

Validate checks the field values on PerXdsConfig with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*PerXdsConfig) XXX_DiscardUnknown

func (m *PerXdsConfig) XXX_DiscardUnknown()

func (*PerXdsConfig) XXX_Marshal

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

func (*PerXdsConfig) XXX_Merge

func (m *PerXdsConfig) XXX_Merge(src proto.Message)

func (*PerXdsConfig) XXX_OneofWrappers

func (*PerXdsConfig) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*PerXdsConfig) XXX_Size

func (m *PerXdsConfig) XXX_Size() int

func (*PerXdsConfig) XXX_Unmarshal

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

type PerXdsConfigValidationError

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

PerXdsConfigValidationError is the validation error returned by PerXdsConfig.Validate if the designated constraints aren't met.

func (PerXdsConfigValidationError) Cause

Cause function returns cause value.

func (PerXdsConfigValidationError) Error

Error satisfies the builtin error interface

func (PerXdsConfigValidationError) ErrorName

func (e PerXdsConfigValidationError) ErrorName() string

ErrorName returns error name.

func (PerXdsConfigValidationError) Field

Field function returns field value.

func (PerXdsConfigValidationError) Key

Key function returns key value.

func (PerXdsConfigValidationError) Reason

Reason function returns reason value.

type PerXdsConfig_ClusterConfig

type PerXdsConfig_ClusterConfig struct {
	ClusterConfig *v2alpha.ClustersConfigDump `protobuf:"bytes,3,opt,name=cluster_config,json=clusterConfig,proto3,oneof" json:"cluster_config,omitempty"`
}

func (*PerXdsConfig_ClusterConfig) MarshalTo

func (m *PerXdsConfig_ClusterConfig) MarshalTo(dAtA []byte) (int, error)

func (*PerXdsConfig_ClusterConfig) MarshalToSizedBuffer

func (m *PerXdsConfig_ClusterConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PerXdsConfig_ClusterConfig) Size

func (m *PerXdsConfig_ClusterConfig) Size() (n int)

type PerXdsConfig_ListenerConfig

type PerXdsConfig_ListenerConfig struct {
	ListenerConfig *v2alpha.ListenersConfigDump `protobuf:"bytes,2,opt,name=listener_config,json=listenerConfig,proto3,oneof" json:"listener_config,omitempty"`
}

func (*PerXdsConfig_ListenerConfig) MarshalTo

func (m *PerXdsConfig_ListenerConfig) MarshalTo(dAtA []byte) (int, error)

func (*PerXdsConfig_ListenerConfig) MarshalToSizedBuffer

func (m *PerXdsConfig_ListenerConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PerXdsConfig_ListenerConfig) Size

func (m *PerXdsConfig_ListenerConfig) Size() (n int)

type PerXdsConfig_RouteConfig

type PerXdsConfig_RouteConfig struct {
	RouteConfig *v2alpha.RoutesConfigDump `protobuf:"bytes,4,opt,name=route_config,json=routeConfig,proto3,oneof" json:"route_config,omitempty"`
}

func (*PerXdsConfig_RouteConfig) MarshalTo

func (m *PerXdsConfig_RouteConfig) MarshalTo(dAtA []byte) (int, error)

func (*PerXdsConfig_RouteConfig) MarshalToSizedBuffer

func (m *PerXdsConfig_RouteConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PerXdsConfig_RouteConfig) Size

func (m *PerXdsConfig_RouteConfig) Size() (n int)

type PerXdsConfig_ScopedRouteConfig

type PerXdsConfig_ScopedRouteConfig struct {
	ScopedRouteConfig *v2alpha.ScopedRoutesConfigDump `protobuf:"bytes,5,opt,name=scoped_route_config,json=scopedRouteConfig,proto3,oneof" json:"scoped_route_config,omitempty"`
}

func (*PerXdsConfig_ScopedRouteConfig) MarshalTo

func (m *PerXdsConfig_ScopedRouteConfig) MarshalTo(dAtA []byte) (int, error)

func (*PerXdsConfig_ScopedRouteConfig) MarshalToSizedBuffer

func (m *PerXdsConfig_ScopedRouteConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PerXdsConfig_ScopedRouteConfig) Size

func (m *PerXdsConfig_ScopedRouteConfig) Size() (n int)

type UnimplementedClientStatusDiscoveryServiceServer

type UnimplementedClientStatusDiscoveryServiceServer struct {
}

UnimplementedClientStatusDiscoveryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedClientStatusDiscoveryServiceServer) FetchClientStatus

func (*UnimplementedClientStatusDiscoveryServiceServer) StreamClientStatus

Jump to

Keyboard shortcuts

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