go-control-plane: github.com/envoyproxy/go-control-plane/envoy/service/status/v2 Index | Files

package envoy_service_status_v2

import "github.com/envoyproxy/go-control-plane/envoy/service/status/v2"

Index

Package Files

csds.pb.go csds.pb.validate.go

Variables

var (
    ConfigStatus_name = map[int32]string{
        0:  "UNKNOWN",
        1:  "SYNCED",
        2:  "NOT_SENT",
        3:  "STALE",
        4:  "ERROR",
    }
    ConfigStatus_value = map[string]int32{
        "UNKNOWN":  0,
        "SYNCED":   1,
        "NOT_SENT": 2,
        "STALE":    3,
        "ERROR":    4,
    }
)

Enum value maps for ConfigStatus.

var File_envoy_service_status_v2_csds_proto protoreflect.FileDescriptor

func RegisterClientStatusDiscoveryServiceServer Uses

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

type ClientConfig Uses

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"`
    // contains filtered or unexported fields
}

All xds configs for a particular client.

func (*ClientConfig) Descriptor Uses

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

Deprecated: Use ClientConfig.ProtoReflect.Descriptor instead.

func (*ClientConfig) GetNode Uses

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

func (*ClientConfig) GetXdsConfig Uses

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

func (*ClientConfig) ProtoMessage Uses

func (*ClientConfig) ProtoMessage()

func (*ClientConfig) ProtoReflect Uses

func (x *ClientConfig) ProtoReflect() protoreflect.Message

func (*ClientConfig) Reset Uses

func (x *ClientConfig) Reset()

func (*ClientConfig) String Uses

func (x *ClientConfig) String() string

func (*ClientConfig) Validate Uses

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.

type ClientConfigValidationError Uses

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 Uses

func (e ClientConfigValidationError) Cause() error

Cause function returns cause value.

func (ClientConfigValidationError) Error Uses

func (e ClientConfigValidationError) Error() string

Error satisfies the builtin error interface

func (ClientConfigValidationError) ErrorName Uses

func (e ClientConfigValidationError) ErrorName() string

ErrorName returns error name.

func (ClientConfigValidationError) Field Uses

func (e ClientConfigValidationError) Field() string

Field function returns field value.

func (ClientConfigValidationError) Key Uses

func (e ClientConfigValidationError) Key() bool

Key function returns key value.

func (ClientConfigValidationError) Reason Uses

func (e ClientConfigValidationError) Reason() string

Reason function returns reason value.

type ClientStatusDiscoveryServiceClient Uses

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 Uses

func NewClientStatusDiscoveryServiceClient(cc grpc.ClientConnInterface) ClientStatusDiscoveryServiceClient

type ClientStatusDiscoveryServiceServer Uses

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

ClientStatusDiscoveryServiceServer is the server API for ClientStatusDiscoveryService service.

type ClientStatusDiscoveryService_StreamClientStatusClient Uses

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

type ClientStatusDiscoveryService_StreamClientStatusServer Uses

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

type ClientStatusRequest Uses

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"`
    // contains filtered or unexported fields
}

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

func (*ClientStatusRequest) Descriptor Uses

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

Deprecated: Use ClientStatusRequest.ProtoReflect.Descriptor instead.

func (*ClientStatusRequest) GetNodeMatchers Uses

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

func (*ClientStatusRequest) ProtoMessage Uses

func (*ClientStatusRequest) ProtoMessage()

func (*ClientStatusRequest) ProtoReflect Uses

func (x *ClientStatusRequest) ProtoReflect() protoreflect.Message

func (*ClientStatusRequest) Reset Uses

func (x *ClientStatusRequest) Reset()

func (*ClientStatusRequest) String Uses

func (x *ClientStatusRequest) String() string

func (*ClientStatusRequest) Validate Uses

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.

type ClientStatusRequestValidationError Uses

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 Uses

func (e ClientStatusRequestValidationError) Cause() error

Cause function returns cause value.

func (ClientStatusRequestValidationError) Error Uses

func (e ClientStatusRequestValidationError) Error() string

Error satisfies the builtin error interface

func (ClientStatusRequestValidationError) ErrorName Uses

func (e ClientStatusRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ClientStatusRequestValidationError) Field Uses

func (e ClientStatusRequestValidationError) Field() string

Field function returns field value.

func (ClientStatusRequestValidationError) Key Uses

func (e ClientStatusRequestValidationError) Key() bool

Key function returns key value.

func (ClientStatusRequestValidationError) Reason Uses

func (e ClientStatusRequestValidationError) Reason() string

Reason function returns reason value.

type ClientStatusResponse Uses

type ClientStatusResponse struct {

    // Client configs for the clients specified in the ClientStatusRequest.
    Config []*ClientConfig `protobuf:"bytes,1,rep,name=config,proto3" json:"config,omitempty"`
    // contains filtered or unexported fields
}

func (*ClientStatusResponse) Descriptor Uses

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

Deprecated: Use ClientStatusResponse.ProtoReflect.Descriptor instead.

func (*ClientStatusResponse) GetConfig Uses

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

func (*ClientStatusResponse) ProtoMessage Uses

func (*ClientStatusResponse) ProtoMessage()

func (*ClientStatusResponse) ProtoReflect Uses

func (x *ClientStatusResponse) ProtoReflect() protoreflect.Message

func (*ClientStatusResponse) Reset Uses

func (x *ClientStatusResponse) Reset()

func (*ClientStatusResponse) String Uses

func (x *ClientStatusResponse) String() string

func (*ClientStatusResponse) Validate Uses

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.

type ClientStatusResponseValidationError Uses

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 Uses

func (e ClientStatusResponseValidationError) Cause() error

Cause function returns cause value.

func (ClientStatusResponseValidationError) Error Uses

func (e ClientStatusResponseValidationError) Error() string

Error satisfies the builtin error interface

func (ClientStatusResponseValidationError) ErrorName Uses

func (e ClientStatusResponseValidationError) ErrorName() string

ErrorName returns error name.

func (ClientStatusResponseValidationError) Field Uses

func (e ClientStatusResponseValidationError) Field() string

Field function returns field value.

func (ClientStatusResponseValidationError) Key Uses

func (e ClientStatusResponseValidationError) Key() bool

Key function returns key value.

func (ClientStatusResponseValidationError) Reason Uses

func (e ClientStatusResponseValidationError) Reason() string

Reason function returns reason value.

type ConfigStatus Uses

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) Descriptor Uses

func (ConfigStatus) Descriptor() protoreflect.EnumDescriptor

func (ConfigStatus) Enum Uses

func (x ConfigStatus) Enum() *ConfigStatus

func (ConfigStatus) EnumDescriptor Uses

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

Deprecated: Use ConfigStatus.Descriptor instead.

func (ConfigStatus) Number Uses

func (x ConfigStatus) Number() protoreflect.EnumNumber

func (ConfigStatus) String Uses

func (x ConfigStatus) String() string

func (ConfigStatus) Type Uses

func (ConfigStatus) Type() protoreflect.EnumType

type PerXdsConfig Uses

type PerXdsConfig struct {
    Status ConfigStatus `protobuf:"varint,1,opt,name=status,proto3,enum=envoy.service.status.v2.ConfigStatus" json:"status,omitempty"`
    // Types that are assignable to PerXdsConfig:
    //	*PerXdsConfig_ListenerConfig
    //	*PerXdsConfig_ClusterConfig
    //	*PerXdsConfig_RouteConfig
    //	*PerXdsConfig_ScopedRouteConfig
    PerXdsConfig isPerXdsConfig_PerXdsConfig `protobuf_oneof:"per_xds_config"`
    // contains filtered or unexported fields
}

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

func (*PerXdsConfig) Descriptor Uses

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

Deprecated: Use PerXdsConfig.ProtoReflect.Descriptor instead.

func (*PerXdsConfig) GetClusterConfig Uses

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

func (*PerXdsConfig) GetListenerConfig Uses

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

func (*PerXdsConfig) GetPerXdsConfig Uses

func (m *PerXdsConfig) GetPerXdsConfig() isPerXdsConfig_PerXdsConfig

func (*PerXdsConfig) GetRouteConfig Uses

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

func (*PerXdsConfig) GetScopedRouteConfig Uses

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

func (*PerXdsConfig) GetStatus Uses

func (x *PerXdsConfig) GetStatus() ConfigStatus

func (*PerXdsConfig) ProtoMessage Uses

func (*PerXdsConfig) ProtoMessage()

func (*PerXdsConfig) ProtoReflect Uses

func (x *PerXdsConfig) ProtoReflect() protoreflect.Message

func (*PerXdsConfig) Reset Uses

func (x *PerXdsConfig) Reset()

func (*PerXdsConfig) String Uses

func (x *PerXdsConfig) String() string

func (*PerXdsConfig) Validate Uses

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.

type PerXdsConfigValidationError Uses

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 Uses

func (e PerXdsConfigValidationError) Cause() error

Cause function returns cause value.

func (PerXdsConfigValidationError) Error Uses

func (e PerXdsConfigValidationError) Error() string

Error satisfies the builtin error interface

func (PerXdsConfigValidationError) ErrorName Uses

func (e PerXdsConfigValidationError) ErrorName() string

ErrorName returns error name.

func (PerXdsConfigValidationError) Field Uses

func (e PerXdsConfigValidationError) Field() string

Field function returns field value.

func (PerXdsConfigValidationError) Key Uses

func (e PerXdsConfigValidationError) Key() bool

Key function returns key value.

func (PerXdsConfigValidationError) Reason Uses

func (e PerXdsConfigValidationError) Reason() string

Reason function returns reason value.

type PerXdsConfig_ClusterConfig Uses

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

type PerXdsConfig_ListenerConfig Uses

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

type PerXdsConfig_RouteConfig Uses

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

type PerXdsConfig_ScopedRouteConfig Uses

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

type UnimplementedClientStatusDiscoveryServiceServer Uses

type UnimplementedClientStatusDiscoveryServiceServer struct {
}

UnimplementedClientStatusDiscoveryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedClientStatusDiscoveryServiceServer) FetchClientStatus Uses

func (*UnimplementedClientStatusDiscoveryServiceServer) FetchClientStatus(context.Context, *ClientStatusRequest) (*ClientStatusResponse, error)

func (*UnimplementedClientStatusDiscoveryServiceServer) StreamClientStatus Uses

func (*UnimplementedClientStatusDiscoveryServiceServer) StreamClientStatus(ClientStatusDiscoveryService_StreamClientStatusServer) error

Package envoy_service_status_v2 imports 26 packages (graph) and is imported by 6 packages. Updated 2021-01-08. Refresh now. Tools for package owners.