Documentation ¶
Index ¶
- Variables
- func RegisterNodeLoggingCapabilityServer(s grpc.ServiceRegistrar, srv NodeLoggingCapabilityServer)
- type ConfigStatus
- func (ConfigStatus) Descriptor() protoreflect.EnumDescriptor
- func (x ConfigStatus) Enum() *ConfigStatus
- func (ConfigStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x ConfigStatus) Number() protoreflect.EnumNumber
- func (x ConfigStatus) String() string
- func (ConfigStatus) Type() protoreflect.EnumType
- type LoggingCapabilityConfig
- func (*LoggingCapabilityConfig) Descriptor() ([]byte, []int)deprecated
- func (x *LoggingCapabilityConfig) GetConditions() []string
- func (x *LoggingCapabilityConfig) GetEnabled() bool
- func (x *LoggingCapabilityConfig) GetOpensearchConfig() *OpensearchConfig
- func (*LoggingCapabilityConfig) ProtoMessage()
- func (x *LoggingCapabilityConfig) ProtoReflect() protoreflect.Message
- func (x *LoggingCapabilityConfig) Reset()
- func (x *LoggingCapabilityConfig) String() string
- type NodeLoggingCapabilityClient
- type NodeLoggingCapabilityServer
- type OpensearchConfig
- func (*OpensearchConfig) Descriptor() ([]byte, []int)deprecated
- func (x *OpensearchConfig) GetPassword() string
- func (x *OpensearchConfig) GetTracingEnabled() bool
- func (x *OpensearchConfig) GetUrl() string
- func (x *OpensearchConfig) GetUsername() string
- func (*OpensearchConfig) ProtoMessage()
- func (x *OpensearchConfig) ProtoReflect() protoreflect.Message
- func (x *OpensearchConfig) Reset()
- func (x *OpensearchConfig) String() string
- type SyncRequest
- type SyncResponse
- func (*SyncResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SyncResponse) GetConfigStatus() ConfigStatus
- func (x *SyncResponse) GetUpdatedConfig() *LoggingCapabilityConfig
- func (*SyncResponse) ProtoMessage()
- func (x *SyncResponse) ProtoReflect() protoreflect.Message
- func (x *SyncResponse) Reset()
- func (x *SyncResponse) String() string
- type UnimplementedNodeLoggingCapabilityServer
- type UnsafeNodeLoggingCapabilityServer
Constants ¶
This section is empty.
Variables ¶
var ( ConfigStatus_name = map[int32]string{ 0: "Unknown", 1: "UpToDate", 2: "NeedsUpdate", } ConfigStatus_value = map[string]int32{ "Unknown": 0, "UpToDate": 1, "NeedsUpdate": 2, } )
Enum value maps for ConfigStatus.
var File_github_com_rancher_opni_plugins_logging_pkg_apis_node_node_proto protoreflect.FileDescriptor
var NodeLoggingCapability_ServiceDesc = grpc.ServiceDesc{ ServiceName: "loggingnode.NodeLoggingCapability", HandlerType: (*NodeLoggingCapabilityServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Sync", Handler: _NodeLoggingCapability_Sync_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "github.com/rancher/opni/plugins/logging/pkg/apis/node/node.proto", }
NodeLoggingCapability_ServiceDesc is the grpc.ServiceDesc for NodeLoggingCapability service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterNodeLoggingCapabilityServer ¶
func RegisterNodeLoggingCapabilityServer(s grpc.ServiceRegistrar, srv NodeLoggingCapabilityServer)
Types ¶
type ConfigStatus ¶
type ConfigStatus int32
const ( ConfigStatus_Unknown ConfigStatus = 0 ConfigStatus_UpToDate ConfigStatus = 1 ConfigStatus_NeedsUpdate ConfigStatus = 2 )
func (ConfigStatus) Descriptor ¶
func (ConfigStatus) Descriptor() protoreflect.EnumDescriptor
func (ConfigStatus) Enum ¶
func (x ConfigStatus) Enum() *ConfigStatus
func (ConfigStatus) EnumDescriptor
deprecated
func (ConfigStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use ConfigStatus.Descriptor instead.
func (ConfigStatus) Number ¶
func (x ConfigStatus) Number() protoreflect.EnumNumber
func (ConfigStatus) String ¶
func (x ConfigStatus) String() string
func (ConfigStatus) Type ¶
func (ConfigStatus) Type() protoreflect.EnumType
type LoggingCapabilityConfig ¶
type LoggingCapabilityConfig struct { Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"` // If enabled is false, conditions may contain a list of relevant status // messages describing why the capability is disabled. Conditions []string `protobuf:"bytes,2,rep,name=conditions,proto3" json:"conditions,omitempty"` OpensearchConfig *OpensearchConfig `protobuf:"bytes,3,opt,name=opensearchConfig,proto3" json:"opensearchConfig,omitempty"` // contains filtered or unexported fields }
func (*LoggingCapabilityConfig) Descriptor
deprecated
func (*LoggingCapabilityConfig) Descriptor() ([]byte, []int)
Deprecated: Use LoggingCapabilityConfig.ProtoReflect.Descriptor instead.
func (*LoggingCapabilityConfig) GetConditions ¶
func (x *LoggingCapabilityConfig) GetConditions() []string
func (*LoggingCapabilityConfig) GetEnabled ¶
func (x *LoggingCapabilityConfig) GetEnabled() bool
func (*LoggingCapabilityConfig) GetOpensearchConfig ¶
func (x *LoggingCapabilityConfig) GetOpensearchConfig() *OpensearchConfig
func (*LoggingCapabilityConfig) ProtoMessage ¶
func (*LoggingCapabilityConfig) ProtoMessage()
func (*LoggingCapabilityConfig) ProtoReflect ¶
func (x *LoggingCapabilityConfig) ProtoReflect() protoreflect.Message
func (*LoggingCapabilityConfig) Reset ¶
func (x *LoggingCapabilityConfig) Reset()
func (*LoggingCapabilityConfig) String ¶
func (x *LoggingCapabilityConfig) String() string
type NodeLoggingCapabilityClient ¶
type NodeLoggingCapabilityClient interface {
Sync(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (*SyncResponse, error)
}
NodeLoggingCapabilityClient is the client API for NodeLoggingCapability service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewNodeLoggingCapabilityClient ¶
func NewNodeLoggingCapabilityClient(cc grpc.ClientConnInterface) NodeLoggingCapabilityClient
type NodeLoggingCapabilityServer ¶
type NodeLoggingCapabilityServer interface { Sync(context.Context, *SyncRequest) (*SyncResponse, error) // contains filtered or unexported methods }
NodeLoggingCapabilityServer is the server API for NodeLoggingCapability service. All implementations must embed UnimplementedNodeLoggingCapabilityServer for forward compatibility
type OpensearchConfig ¶
type OpensearchConfig struct { Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"` Url string `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"` TracingEnabled bool `protobuf:"varint,4,opt,name=tracingEnabled,proto3" json:"tracingEnabled,omitempty"` // contains filtered or unexported fields }
func (*OpensearchConfig) Descriptor
deprecated
func (*OpensearchConfig) Descriptor() ([]byte, []int)
Deprecated: Use OpensearchConfig.ProtoReflect.Descriptor instead.
func (*OpensearchConfig) GetPassword ¶
func (x *OpensearchConfig) GetPassword() string
func (*OpensearchConfig) GetTracingEnabled ¶
func (x *OpensearchConfig) GetTracingEnabled() bool
func (*OpensearchConfig) GetUrl ¶
func (x *OpensearchConfig) GetUrl() string
func (*OpensearchConfig) GetUsername ¶
func (x *OpensearchConfig) GetUsername() string
func (*OpensearchConfig) ProtoMessage ¶
func (*OpensearchConfig) ProtoMessage()
func (*OpensearchConfig) ProtoReflect ¶
func (x *OpensearchConfig) ProtoReflect() protoreflect.Message
func (*OpensearchConfig) Reset ¶
func (x *OpensearchConfig) Reset()
func (*OpensearchConfig) String ¶
func (x *OpensearchConfig) String() string
type SyncRequest ¶
type SyncRequest struct { CurrentConfig *LoggingCapabilityConfig `protobuf:"bytes,1,opt,name=currentConfig,proto3" json:"currentConfig,omitempty"` // contains filtered or unexported fields }
func (*SyncRequest) Descriptor
deprecated
func (*SyncRequest) Descriptor() ([]byte, []int)
Deprecated: Use SyncRequest.ProtoReflect.Descriptor instead.
func (*SyncRequest) GetCurrentConfig ¶
func (x *SyncRequest) GetCurrentConfig() *LoggingCapabilityConfig
func (*SyncRequest) ProtoMessage ¶
func (*SyncRequest) ProtoMessage()
func (*SyncRequest) ProtoReflect ¶
func (x *SyncRequest) ProtoReflect() protoreflect.Message
func (*SyncRequest) Reset ¶
func (x *SyncRequest) Reset()
func (*SyncRequest) String ¶
func (x *SyncRequest) String() string
type SyncResponse ¶
type SyncResponse struct { ConfigStatus ConfigStatus `protobuf:"varint,1,opt,name=configStatus,proto3,enum=loggingnode.ConfigStatus" json:"configStatus,omitempty"` UpdatedConfig *LoggingCapabilityConfig `protobuf:"bytes,2,opt,name=updatedConfig,proto3" json:"updatedConfig,omitempty"` // contains filtered or unexported fields }
func (*SyncResponse) Descriptor
deprecated
func (*SyncResponse) Descriptor() ([]byte, []int)
Deprecated: Use SyncResponse.ProtoReflect.Descriptor instead.
func (*SyncResponse) GetConfigStatus ¶
func (x *SyncResponse) GetConfigStatus() ConfigStatus
func (*SyncResponse) GetUpdatedConfig ¶
func (x *SyncResponse) GetUpdatedConfig() *LoggingCapabilityConfig
func (*SyncResponse) ProtoMessage ¶
func (*SyncResponse) ProtoMessage()
func (*SyncResponse) ProtoReflect ¶
func (x *SyncResponse) ProtoReflect() protoreflect.Message
func (*SyncResponse) Reset ¶
func (x *SyncResponse) Reset()
func (*SyncResponse) String ¶
func (x *SyncResponse) String() string
type UnimplementedNodeLoggingCapabilityServer ¶
type UnimplementedNodeLoggingCapabilityServer struct { }
UnimplementedNodeLoggingCapabilityServer must be embedded to have forward compatible implementations.
func (UnimplementedNodeLoggingCapabilityServer) Sync ¶
func (UnimplementedNodeLoggingCapabilityServer) Sync(context.Context, *SyncRequest) (*SyncResponse, error)
type UnsafeNodeLoggingCapabilityServer ¶
type UnsafeNodeLoggingCapabilityServer interface {
// contains filtered or unexported methods
}
UnsafeNodeLoggingCapabilityServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NodeLoggingCapabilityServer will result in compilation errors.