loggingadmin

package
v0.7.0-rc1 Latest Latest
Warning

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

 Go to latest Published: Nov 18, 2022 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Overview

Package loggingadmin is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var File_github_com_rancher_opni_plugins_logging_pkg_apis_loggingadmin_loggingadmin_proto protoreflect.FileDescriptor
View Source 
var LoggingAdmin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loggingadmin.LoggingAdmin",
	HandlerType: (*LoggingAdminServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOpensearchCluster",
			Handler:    _LoggingAdmin_GetOpensearchCluster_Handler,
		},
		{
			MethodName: "DeleteOpensearchCluster",
			Handler:    _LoggingAdmin_DeleteOpensearchCluster_Handler,
		},
		{
			MethodName: "CreateOrUpdateOpensearchCluster",
			Handler:    _LoggingAdmin_CreateOrUpdateOpensearchCluster_Handler,
		},
		{
			MethodName: "UpgradeAvailable",
			Handler:    _LoggingAdmin_UpgradeAvailable_Handler,
		},
		{
			MethodName: "DoUpgrade",
			Handler:    _LoggingAdmin_DoUpgrade_Handler,
		},
		{
			MethodName: "GetStorageClasses",
			Handler:    _LoggingAdmin_GetStorageClasses_Handler,
		},
		{
			MethodName: "GetOpensearchStatus",
			Handler:    _LoggingAdmin_GetOpensearchStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/rancher/opni/plugins/logging/pkg/apis/loggingadmin/loggingadmin.proto",
}

LoggingAdmin_ServiceDesc is the grpc.ServiceDesc for LoggingAdmin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterLoggingAdminHandler 

func RegisterLoggingAdminHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterLoggingAdminHandler registers the http handlers for service LoggingAdmin to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterLoggingAdminHandlerClient 

func RegisterLoggingAdminHandlerClient(ctx context.Context, mux *runtime.ServeMux, client LoggingAdminClient) error

RegisterLoggingAdminHandlerClient registers the http handlers for service LoggingAdmin to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "LoggingAdminClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "LoggingAdminClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "LoggingAdminClient" to call the correct interceptors.

func RegisterLoggingAdminHandlerFromEndpoint 

func RegisterLoggingAdminHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterLoggingAdminHandlerFromEndpoint is same as RegisterLoggingAdminHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterLoggingAdminHandlerServer 

func RegisterLoggingAdminHandlerServer(ctx context.Context, mux *runtime.ServeMux, server LoggingAdminServer) error

RegisterLoggingAdminHandlerServer registers the http handlers for service LoggingAdmin to "mux". UnaryRPC :call LoggingAdminServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterLoggingAdminHandlerFromEndpoint instead.

func RegisterLoggingAdminServer 

func RegisterLoggingAdminServer(s grpc.ServiceRegistrar, srv LoggingAdminServer)

Types

type AdminClientOption added in v0.6.1 

type AdminClientOption func(*AdminClientOptions)

func WithDialOptions added in v0.6.1 

func WithDialOptions(options ...grpc.DialOption) AdminClientOption

func WithListenAddress added in v0.6.1 

func WithListenAddress(addr string) AdminClientOption

type AdminClientOptions added in v0.6.1 

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

type CPUResource 

type CPUResource struct {
	Request string `protobuf:"bytes,1,opt,name=Request,proto3" json:"Request,omitempty"`
	Limit   string `protobuf:"bytes,2,opt,name=Limit,proto3" json:"Limit,omitempty"`
	// contains filtered or unexported fields
}

func (*CPUResource) Descriptor deprecated 

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

Deprecated: Use CPUResource.ProtoReflect.Descriptor instead.

func (*CPUResource) GetLimit 

func (x *CPUResource) GetLimit() string

func (*CPUResource) GetRequest 

func (x *CPUResource) GetRequest() string

func (*CPUResource) ProtoMessage 

func (*CPUResource) ProtoMessage()

func (*CPUResource) ProtoReflect 

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

func (*CPUResource) Reset 

func (x *CPUResource) Reset()

func (*CPUResource) String 

func (x *CPUResource) String() string

type ComputeResourceQuantities 

type ComputeResourceQuantities struct {
	CPU    string `protobuf:"bytes,1,opt,name=CPU,proto3" json:"CPU,omitempty"`
	Memory string `protobuf:"bytes,2,opt,name=Memory,proto3" json:"Memory,omitempty"`
	// contains filtered or unexported fields
}

func (*ComputeResourceQuantities) Descriptor deprecated 

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

Deprecated: Use ComputeResourceQuantities.ProtoReflect.Descriptor instead.

func (*ComputeResourceQuantities) GetCPU 

func (x *ComputeResourceQuantities) GetCPU() string

func (*ComputeResourceQuantities) GetMemory 

func (x *ComputeResourceQuantities) GetMemory() string

func (*ComputeResourceQuantities) ProtoMessage 

func (*ComputeResourceQuantities) ProtoMessage()

func (*ComputeResourceQuantities) ProtoReflect 

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

func (*ComputeResourceQuantities) Reset 

func (x *ComputeResourceQuantities) Reset()

func (*ComputeResourceQuantities) String 

func (x *ComputeResourceQuantities) String() string

type DashboardsDetails 

type DashboardsDetails struct {
	Enabled   *bool                 `protobuf:"varint,1,opt,name=Enabled,proto3,oneof" json:"Enabled,omitempty"`
	Replicas  *int32                `protobuf:"varint,2,opt,name=Replicas,proto3,oneof" json:"Replicas,omitempty"`
	Resources *ResourceRequirements `protobuf:"bytes,3,opt,name=Resources,proto3" json:"Resources,omitempty"`
	// contains filtered or unexported fields
}

func (*DashboardsDetails) Descriptor deprecated 

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

Deprecated: Use DashboardsDetails.ProtoReflect.Descriptor instead.

func (*DashboardsDetails) GetEnabled 

func (x *DashboardsDetails) GetEnabled() bool

func (*DashboardsDetails) GetReplicas 

func (x *DashboardsDetails) GetReplicas() int32

func (*DashboardsDetails) GetResources 

func (x *DashboardsDetails) GetResources() *ResourceRequirements

func (*DashboardsDetails) ProtoMessage 

func (*DashboardsDetails) ProtoMessage()

func (*DashboardsDetails) ProtoReflect 

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

func (*DashboardsDetails) Reset 

func (x *DashboardsDetails) Reset()

func (*DashboardsDetails) String 

func (x *DashboardsDetails) String() string

type DataPersistence 

type DataPersistence struct {
	Enabled      *bool   `protobuf:"varint,1,opt,name=Enabled,proto3,oneof" json:"Enabled,omitempty"`
	StorageClass *string `protobuf:"bytes,2,opt,name=StorageClass,proto3,oneof" json:"StorageClass,omitempty"`
	// contains filtered or unexported fields
}

func (*DataPersistence) Descriptor deprecated 

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

Deprecated: Use DataPersistence.ProtoReflect.Descriptor instead.

func (*DataPersistence) GetEnabled 

func (x *DataPersistence) GetEnabled() bool

func (*DataPersistence) GetStorageClass 

func (x *DataPersistence) GetStorageClass() string

func (*DataPersistence) ProtoMessage 

func (*DataPersistence) ProtoMessage()

func (*DataPersistence) ProtoReflect 

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

func (*DataPersistence) Reset 

func (x *DataPersistence) Reset()

func (*DataPersistence) String 

func (x *DataPersistence) String() string

type LoggingAdminClient 

type LoggingAdminClient interface {
	GetOpensearchCluster(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*OpensearchCluster, error)
	DeleteOpensearchCluster(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	CreateOrUpdateOpensearchCluster(ctx context.Context, in *OpensearchCluster, opts ...grpc.CallOption) (*emptypb.Empty, error)
	UpgradeAvailable(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*UpgradeAvailableResponse, error)
	DoUpgrade(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetStorageClasses(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*StorageClassResponse, error)
	GetOpensearchStatus(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*StatusResponse, error)
}

LoggingAdminClient is the client API for LoggingAdmin 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 NewClient added in v0.6.1 

func NewClient(ctx waitctx.PermissiveContext, opts ...AdminClientOption) (LoggingAdminClient, error)

func NewLoggingAdminClient 

func NewLoggingAdminClient(cc grpc.ClientConnInterface) LoggingAdminClient

type LoggingAdminServer 

type LoggingAdminServer interface {
	GetOpensearchCluster(context.Context, *emptypb.Empty) (*OpensearchCluster, error)
	DeleteOpensearchCluster(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	CreateOrUpdateOpensearchCluster(context.Context, *OpensearchCluster) (*emptypb.Empty, error)
	UpgradeAvailable(context.Context, *emptypb.Empty) (*UpgradeAvailableResponse, error)
	DoUpgrade(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	GetStorageClasses(context.Context, *emptypb.Empty) (*StorageClassResponse, error)
	GetOpensearchStatus(context.Context, *emptypb.Empty) (*StatusResponse, error)
	// contains filtered or unexported methods
}

LoggingAdminServer is the server API for LoggingAdmin service. All implementations must embed UnimplementedLoggingAdminServer for forward compatibility

type OpensearchCluster 

type OpensearchCluster struct {
	ExternalURL string `protobuf:"bytes,1,opt,name=ExternalURL,proto3" json:"ExternalURL,omitempty"`
	// +optional
	NodePools     []*OpensearchNodeDetails `protobuf:"bytes,2,rep,name=NodePools,proto3" json:"NodePools,omitempty"`
	Dashboards    *DashboardsDetails       `protobuf:"bytes,3,opt,name=Dashboards,proto3,oneof" json:"Dashboards,omitempty"`
	DataRetention *string                  `protobuf:"bytes,4,opt,name=DataRetention,proto3,oneof" json:"DataRetention,omitempty"`
	// contains filtered or unexported fields
}

func (*OpensearchCluster) Descriptor deprecated 

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

Deprecated: Use OpensearchCluster.ProtoReflect.Descriptor instead.

func (*OpensearchCluster) GetDashboards 

func (x *OpensearchCluster) GetDashboards() *DashboardsDetails

func (*OpensearchCluster) GetDataRetention 

func (x *OpensearchCluster) GetDataRetention() string

func (*OpensearchCluster) GetExternalURL 

func (x *OpensearchCluster) GetExternalURL() string

func (*OpensearchCluster) GetNodePools 

func (x *OpensearchCluster) GetNodePools() []*OpensearchNodeDetails

func (*OpensearchCluster) ProtoMessage 

func (*OpensearchCluster) ProtoMessage()

func (*OpensearchCluster) ProtoReflect 

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

func (*OpensearchCluster) Reset 

func (x *OpensearchCluster) Reset()

func (*OpensearchCluster) String 

func (x *OpensearchCluster) String() string

type OpensearchNodeDetails 

type OpensearchNodeDetails struct {
	Name               string            `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Replicas           *int32            `protobuf:"varint,2,opt,name=Replicas,proto3,oneof" json:"Replicas,omitempty"`
	DiskSize           string            `protobuf:"bytes,3,opt,name=DiskSize,proto3" json:"DiskSize,omitempty"`
	MemoryLimit        string            `protobuf:"bytes,4,opt,name=MemoryLimit,proto3" json:"MemoryLimit,omitempty"`
	CPUResources       *CPUResource      `protobuf:"bytes,5,opt,name=CPUResources,proto3,oneof" json:"CPUResources,omitempty"`
	EnableAntiAffinity *bool             `protobuf:"varint,6,opt,name=EnableAntiAffinity,proto3,oneof" json:"EnableAntiAffinity,omitempty"`
	NodeSelector       map[string]string `` /* 165-byte string literal not displayed */
	Tolerations        []*v1.Toleration  `protobuf:"bytes,8,rep,name=Tolerations,proto3" json:"Tolerations,omitempty"`
	Roles              []string          `protobuf:"bytes,9,rep,name=Roles,proto3" json:"Roles,omitempty"`
	Persistence        *DataPersistence  `protobuf:"bytes,10,opt,name=Persistence,proto3,oneof" json:"Persistence,omitempty"`
	// contains filtered or unexported fields
}

func (*OpensearchNodeDetails) Descriptor deprecated 

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

Deprecated: Use OpensearchNodeDetails.ProtoReflect.Descriptor instead.

func (*OpensearchNodeDetails) GetCPUResources 

func (x *OpensearchNodeDetails) GetCPUResources() *CPUResource

func (*OpensearchNodeDetails) GetDiskSize 

func (x *OpensearchNodeDetails) GetDiskSize() string

func (*OpensearchNodeDetails) GetEnableAntiAffinity 

func (x *OpensearchNodeDetails) GetEnableAntiAffinity() bool

func (*OpensearchNodeDetails) GetMemoryLimit 

func (x *OpensearchNodeDetails) GetMemoryLimit() string

func (*OpensearchNodeDetails) GetName 

func (x *OpensearchNodeDetails) GetName() string

func (*OpensearchNodeDetails) GetNodeSelector 

func (x *OpensearchNodeDetails) GetNodeSelector() map[string]string

func (*OpensearchNodeDetails) GetPersistence 

func (x *OpensearchNodeDetails) GetPersistence() *DataPersistence

func (*OpensearchNodeDetails) GetReplicas 

func (x *OpensearchNodeDetails) GetReplicas() int32

func (*OpensearchNodeDetails) GetRoles 

func (x *OpensearchNodeDetails) GetRoles() []string

func (*OpensearchNodeDetails) GetTolerations 

func (x *OpensearchNodeDetails) GetTolerations() []*v1.Toleration

func (*OpensearchNodeDetails) ProtoMessage 

func (*OpensearchNodeDetails) ProtoMessage()

func (*OpensearchNodeDetails) ProtoReflect 

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

func (*OpensearchNodeDetails) Reset 

func (x *OpensearchNodeDetails) Reset()

func (*OpensearchNodeDetails) String 

func (x *OpensearchNodeDetails) String() string

type ResourceRequirements 

type ResourceRequirements struct {
	Requests *ComputeResourceQuantities `protobuf:"bytes,1,opt,name=Requests,proto3" json:"Requests,omitempty"`
	Limits   *ComputeResourceQuantities `protobuf:"bytes,2,opt,name=Limits,proto3" json:"Limits,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceRequirements) Descriptor deprecated 

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

Deprecated: Use ResourceRequirements.ProtoReflect.Descriptor instead.

func (*ResourceRequirements) GetLimits 

func (x *ResourceRequirements) GetLimits() *ComputeResourceQuantities

func (*ResourceRequirements) GetRequests 

func (x *ResourceRequirements) GetRequests() *ComputeResourceQuantities

func (*ResourceRequirements) ProtoMessage 

func (*ResourceRequirements) ProtoMessage()

func (*ResourceRequirements) ProtoReflect 

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

func (*ResourceRequirements) Reset 

func (x *ResourceRequirements) Reset()

func (*ResourceRequirements) String 

func (x *ResourceRequirements) String() string

type StatusResponse 

type StatusResponse struct {
	Status  int32  `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Details string `protobuf:"bytes,2,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusResponse) Descriptor deprecated 

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

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) GetDetails 

func (x *StatusResponse) GetDetails() string

func (*StatusResponse) GetStatus 

func (x *StatusResponse) GetStatus() int32

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect 

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

func (*StatusResponse) Reset 

func (x *StatusResponse) Reset()

func (*StatusResponse) String 

func (x *StatusResponse) String() string

type StorageClassResponse 

type StorageClassResponse struct {
	StorageClasses []string `protobuf:"bytes,1,rep,name=StorageClasses,proto3" json:"StorageClasses,omitempty"`
	// contains filtered or unexported fields
}

func (*StorageClassResponse) Descriptor deprecated 

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

Deprecated: Use StorageClassResponse.ProtoReflect.Descriptor instead.

func (*StorageClassResponse) GetStorageClasses 

func (x *StorageClassResponse) GetStorageClasses() []string

func (*StorageClassResponse) ProtoMessage 

func (*StorageClassResponse) ProtoMessage()

func (*StorageClassResponse) ProtoReflect 

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

func (*StorageClassResponse) Reset 

func (x *StorageClassResponse) Reset()

func (*StorageClassResponse) String 

func (x *StorageClassResponse) String() string

type UnimplementedLoggingAdminServer 

type UnimplementedLoggingAdminServer struct {
}

UnimplementedLoggingAdminServer must be embedded to have forward compatible implementations.

func (UnimplementedLoggingAdminServer) CreateOrUpdateOpensearchCluster 

func (UnimplementedLoggingAdminServer) CreateOrUpdateOpensearchCluster(context.Context, *OpensearchCluster) (*emptypb.Empty, error)

func (UnimplementedLoggingAdminServer) DeleteOpensearchCluster 

func (UnimplementedLoggingAdminServer) DeleteOpensearchCluster(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedLoggingAdminServer) DoUpgrade 

func (UnimplementedLoggingAdminServer) DoUpgrade(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedLoggingAdminServer) GetOpensearchCluster 

func (UnimplementedLoggingAdminServer) GetOpensearchCluster(context.Context, *emptypb.Empty) (*OpensearchCluster, error)

func (UnimplementedLoggingAdminServer) GetOpensearchStatus 

func (UnimplementedLoggingAdminServer) GetOpensearchStatus(context.Context, *emptypb.Empty) (*StatusResponse, error)

func (UnimplementedLoggingAdminServer) GetStorageClasses 

func (UnimplementedLoggingAdminServer) GetStorageClasses(context.Context, *emptypb.Empty) (*StorageClassResponse, error)

func (UnimplementedLoggingAdminServer) UpgradeAvailable 

func (UnimplementedLoggingAdminServer) UpgradeAvailable(context.Context, *emptypb.Empty) (*UpgradeAvailableResponse, error)

type UnsafeLoggingAdminServer 

type UnsafeLoggingAdminServer interface {
	// contains filtered or unexported methods
}

UnsafeLoggingAdminServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LoggingAdminServer will result in compilation errors.

type UpgradeAvailableResponse 

type UpgradeAvailableResponse struct {
	UpgradePending bool `protobuf:"varint,1,opt,name=UpgradePending,proto3" json:"UpgradePending,omitempty"`
	// contains filtered or unexported fields
}

func (*UpgradeAvailableResponse) Descriptor deprecated 

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

Deprecated: Use UpgradeAvailableResponse.ProtoReflect.Descriptor instead.

func (*UpgradeAvailableResponse) GetUpgradePending 

func (x *UpgradeAvailableResponse) GetUpgradePending() bool

func (*UpgradeAvailableResponse) ProtoMessage 

func (*UpgradeAvailableResponse) ProtoMessage()

func (*UpgradeAvailableResponse) ProtoReflect 

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

func (*UpgradeAvailableResponse) Reset 

func (x *UpgradeAvailableResponse) Reset()

func (*UpgradeAvailableResponse) String 

func (x *UpgradeAvailableResponse) 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.