loggingadmin

package
v0.8.2-rc3 Latest Latest
Warning

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

 Go to latest Published: Feb 16, 2023 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 LoggingAdminV2_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loggingadmin.LoggingAdminV2",
	HandlerType: (*LoggingAdminV2Server)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOpensearchCluster",
			Handler:    _LoggingAdminV2_GetOpensearchCluster_Handler,
		},
		{
			MethodName: "DeleteOpensearchCluster",
			Handler:    _LoggingAdminV2_DeleteOpensearchCluster_Handler,
		},
		{
			MethodName: "CreateOrUpdateOpensearchCluster",
			Handler:    _LoggingAdminV2_CreateOrUpdateOpensearchCluster_Handler,
		},
		{
			MethodName: "UpgradeAvailable",
			Handler:    _LoggingAdminV2_UpgradeAvailable_Handler,
		},
		{
			MethodName: "DoUpgrade",
			Handler:    _LoggingAdminV2_DoUpgrade_Handler,
		},
		{
			MethodName: "GetStorageClasses",
			Handler:    _LoggingAdminV2_GetStorageClasses_Handler,
		},
		{
			MethodName: "GetOpensearchStatus",
			Handler:    _LoggingAdminV2_GetOpensearchStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/rancher/opni/plugins/logging/pkg/apis/loggingadmin/loggingadmin.proto",
}

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

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)

func RegisterLoggingAdminV2Handler added in v0.7.0 

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

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

func RegisterLoggingAdminV2HandlerClient added in v0.7.0 

func RegisterLoggingAdminV2HandlerClient(ctx context.Context, mux *runtime.ServeMux, client LoggingAdminV2Client) error

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

func RegisterLoggingAdminV2HandlerFromEndpoint added in v0.7.0 

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

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

func RegisterLoggingAdminV2HandlerServer added in v0.7.0 

func RegisterLoggingAdminV2HandlerServer(ctx context.Context, mux *runtime.ServeMux, server LoggingAdminV2Server) error

RegisterLoggingAdminV2HandlerServer registers the http handlers for service LoggingAdminV2 to "mux". UnaryRPC :call LoggingAdminV2Server 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 RegisterLoggingAdminV2HandlerFromEndpoint instead.

func RegisterLoggingAdminV2Server added in v0.7.0 

func RegisterLoggingAdminV2Server(s grpc.ServiceRegistrar, srv LoggingAdminV2Server)

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 added in v0.8.0 

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 ControlplaneDetails added in v0.7.0 

type ControlplaneDetails struct {
	Replicas     *int32            `protobuf:"varint,1,opt,name=replicas,proto3,oneof" json:"replicas,omitempty"`
	NodeSelector map[string]string `` /* 165-byte string literal not displayed */
	Tolerations  []*v1.Toleration  `protobuf:"bytes,3,rep,name=tolerations,proto3" json:"tolerations,omitempty"`
	Persistence  *DataPersistence  `protobuf:"bytes,4,opt,name=persistence,proto3,oneof" json:"persistence,omitempty"`
	// contains filtered or unexported fields
}

func (*ControlplaneDetails) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use ControlplaneDetails.ProtoReflect.Descriptor instead.

func (*ControlplaneDetails) GetNodeSelector added in v0.7.0 

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

func (*ControlplaneDetails) GetPersistence added in v0.7.0 

func (x *ControlplaneDetails) GetPersistence() *DataPersistence

func (*ControlplaneDetails) GetReplicas added in v0.7.0 

func (x *ControlplaneDetails) GetReplicas() int32

func (*ControlplaneDetails) GetTolerations added in v0.7.0 

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

func (*ControlplaneDetails) ProtoMessage added in v0.7.0 

func (*ControlplaneDetails) ProtoMessage()

func (*ControlplaneDetails) ProtoReflect added in v0.7.0 

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

func (*ControlplaneDetails) Reset added in v0.7.0 

func (x *ControlplaneDetails) Reset()

func (*ControlplaneDetails) String added in v0.7.0 

func (x *ControlplaneDetails) 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 DataDetails added in v0.7.0 

type DataDetails struct {
	Replicas           *int32            `protobuf:"varint,1,opt,name=replicas,proto3,oneof" json:"replicas,omitempty"`
	DiskSize           string            `protobuf:"bytes,2,opt,name=diskSize,proto3" json:"diskSize,omitempty"`
	MemoryLimit        string            `protobuf:"bytes,3,opt,name=memoryLimit,proto3" json:"memoryLimit,omitempty"`
	CpuResources       *CPUResource      `protobuf:"bytes,4,opt,name=cpuResources,proto3,oneof" json:"cpuResources,omitempty"`
	EnableAntiAffinity *bool             `protobuf:"varint,5,opt,name=enableAntiAffinity,proto3,oneof" json:"enableAntiAffinity,omitempty"`
	NodeSelector       map[string]string `` /* 165-byte string literal not displayed */
	Tolerations        []*v1.Toleration  `protobuf:"bytes,7,rep,name=tolerations,proto3" json:"tolerations,omitempty"`
	Persistence        *DataPersistence  `protobuf:"bytes,8,opt,name=persistence,proto3,oneof" json:"persistence,omitempty"`
	// contains filtered or unexported fields
}

func (*DataDetails) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use DataDetails.ProtoReflect.Descriptor instead.

func (*DataDetails) GetCpuResources added in v0.7.0 

func (x *DataDetails) GetCpuResources() *CPUResource

func (*DataDetails) GetDiskSize added in v0.7.0 

func (x *DataDetails) GetDiskSize() string

func (*DataDetails) GetEnableAntiAffinity added in v0.7.0 

func (x *DataDetails) GetEnableAntiAffinity() bool

func (*DataDetails) GetMemoryLimit added in v0.7.0 

func (x *DataDetails) GetMemoryLimit() string

func (*DataDetails) GetNodeSelector added in v0.7.0 

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

func (*DataDetails) GetPersistence added in v0.7.0 

func (x *DataDetails) GetPersistence() *DataPersistence

func (*DataDetails) GetReplicas added in v0.7.0 

func (x *DataDetails) GetReplicas() int32

func (*DataDetails) GetTolerations added in v0.7.0 

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

func (*DataDetails) ProtoMessage added in v0.7.0 

func (*DataDetails) ProtoMessage()

func (*DataDetails) ProtoReflect added in v0.7.0 

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

func (*DataDetails) Reset added in v0.7.0 

func (x *DataDetails) Reset()

func (*DataDetails) String added in v0.7.0 

func (x *DataDetails) 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 IngestDetails added in v0.7.0 

type IngestDetails struct {
	Replicas           *int32            `protobuf:"varint,1,opt,name=replicas,proto3,oneof" json:"replicas,omitempty"`
	MemoryLimit        string            `protobuf:"bytes,2,opt,name=memoryLimit,proto3" json:"memoryLimit,omitempty"`
	CpuResources       *CPUResource      `protobuf:"bytes,3,opt,name=cpuResources,proto3,oneof" json:"cpuResources,omitempty"`
	EnableAntiAffinity *bool             `protobuf:"varint,4,opt,name=enableAntiAffinity,proto3,oneof" json:"enableAntiAffinity,omitempty"`
	NodeSelector       map[string]string `` /* 165-byte string literal not displayed */
	Tolerations        []*v1.Toleration  `protobuf:"bytes,6,rep,name=tolerations,proto3" json:"tolerations,omitempty"`
	// contains filtered or unexported fields
}

func (*IngestDetails) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use IngestDetails.ProtoReflect.Descriptor instead.

func (*IngestDetails) GetCpuResources added in v0.7.0 

func (x *IngestDetails) GetCpuResources() *CPUResource

func (*IngestDetails) GetEnableAntiAffinity added in v0.7.0 

func (x *IngestDetails) GetEnableAntiAffinity() bool

func (*IngestDetails) GetMemoryLimit added in v0.7.0 

func (x *IngestDetails) GetMemoryLimit() string

func (*IngestDetails) GetNodeSelector added in v0.7.0 

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

func (*IngestDetails) GetReplicas added in v0.7.0 

func (x *IngestDetails) GetReplicas() int32

func (*IngestDetails) GetTolerations added in v0.7.0 

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

func (*IngestDetails) ProtoMessage added in v0.7.0 

func (*IngestDetails) ProtoMessage()

func (*IngestDetails) ProtoReflect added in v0.7.0 

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

func (*IngestDetails) Reset added in v0.7.0 

func (x *IngestDetails) Reset()

func (*IngestDetails) String added in v0.7.0 

func (x *IngestDetails) 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 LoggingAdminV2Client added in v0.7.0 

type LoggingAdminV2Client interface {
	GetOpensearchCluster(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*OpensearchClusterV2, error)
	DeleteOpensearchCluster(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	CreateOrUpdateOpensearchCluster(ctx context.Context, in *OpensearchClusterV2, 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)
}

LoggingAdminV2Client is the client API for LoggingAdminV2 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 NewLoggingAdminV2Client added in v0.7.0 

func NewLoggingAdminV2Client(cc grpc.ClientConnInterface) LoggingAdminV2Client

func NewV2Client added in v0.7.0 

func NewV2Client(ctx waitctx.PermissiveContext, opts ...AdminClientOption) (LoggingAdminV2Client, error)

type LoggingAdminV2Server added in v0.7.0 

type LoggingAdminV2Server interface {
	GetOpensearchCluster(context.Context, *emptypb.Empty) (*OpensearchClusterV2, error)
	DeleteOpensearchCluster(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	CreateOrUpdateOpensearchCluster(context.Context, *OpensearchClusterV2) (*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
}

LoggingAdminV2Server is the server API for LoggingAdminV2 service. All implementations must embed UnimplementedLoggingAdminV2Server 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 OpensearchClusterV2 added in v0.7.0 

type OpensearchClusterV2 struct {
	ExternalURL       string               `protobuf:"bytes,1,opt,name=externalURL,proto3" json:"externalURL,omitempty"`
	DataNodes         *DataDetails         `protobuf:"bytes,2,opt,name=dataNodes,proto3" json:"dataNodes,omitempty"`
	IngestNodes       *IngestDetails       `protobuf:"bytes,3,opt,name=ingestNodes,proto3,oneof" json:"ingestNodes,omitempty"`
	ControlplaneNodes *ControlplaneDetails `protobuf:"bytes,4,opt,name=controlplaneNodes,proto3,oneof" json:"controlplaneNodes,omitempty"`
	Dashboards        *DashboardsDetails   `protobuf:"bytes,5,opt,name=dashboards,proto3,oneof" json:"dashboards,omitempty"`
	DataRetention     *string              `protobuf:"bytes,6,opt,name=dataRetention,proto3,oneof" json:"dataRetention,omitempty"`
	// contains filtered or unexported fields
}

func (*OpensearchClusterV2) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use OpensearchClusterV2.ProtoReflect.Descriptor instead.

func (*OpensearchClusterV2) GetControlplaneNodes added in v0.7.0 

func (x *OpensearchClusterV2) GetControlplaneNodes() *ControlplaneDetails

func (*OpensearchClusterV2) GetDashboards added in v0.7.0 

func (x *OpensearchClusterV2) GetDashboards() *DashboardsDetails

func (*OpensearchClusterV2) GetDataNodes added in v0.7.0 

func (x *OpensearchClusterV2) GetDataNodes() *DataDetails

func (*OpensearchClusterV2) GetDataRetention added in v0.7.0 

func (x *OpensearchClusterV2) GetDataRetention() string

func (*OpensearchClusterV2) GetExternalURL added in v0.7.0 

func (x *OpensearchClusterV2) GetExternalURL() string

func (*OpensearchClusterV2) GetIngestNodes added in v0.7.0 

func (x *OpensearchClusterV2) GetIngestNodes() *IngestDetails

func (*OpensearchClusterV2) ProtoMessage added in v0.7.0 

func (*OpensearchClusterV2) ProtoMessage()

func (*OpensearchClusterV2) ProtoReflect added in v0.7.0 

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

func (*OpensearchClusterV2) Reset added in v0.7.0 

func (x *OpensearchClusterV2) Reset()

func (*OpensearchClusterV2) String added in v0.7.0 

func (x *OpensearchClusterV2) 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 UnimplementedLoggingAdminV2Server added in v0.7.0 

type UnimplementedLoggingAdminV2Server struct {
}

UnimplementedLoggingAdminV2Server must be embedded to have forward compatible implementations.

func (UnimplementedLoggingAdminV2Server) CreateOrUpdateOpensearchCluster added in v0.7.0 

func (UnimplementedLoggingAdminV2Server) CreateOrUpdateOpensearchCluster(context.Context, *OpensearchClusterV2) (*emptypb.Empty, error)

func (UnimplementedLoggingAdminV2Server) DeleteOpensearchCluster added in v0.7.0 

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

func (UnimplementedLoggingAdminV2Server) DoUpgrade added in v0.7.0 

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

func (UnimplementedLoggingAdminV2Server) GetOpensearchCluster added in v0.7.0 

func (UnimplementedLoggingAdminV2Server) GetOpensearchCluster(context.Context, *emptypb.Empty) (*OpensearchClusterV2, error)

func (UnimplementedLoggingAdminV2Server) GetOpensearchStatus added in v0.7.0 

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

func (UnimplementedLoggingAdminV2Server) GetStorageClasses added in v0.7.0 

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

func (UnimplementedLoggingAdminV2Server) UpgradeAvailable added in v0.7.0 

func (UnimplementedLoggingAdminV2Server) 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 UnsafeLoggingAdminV2Server added in v0.7.0 

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

UnsafeLoggingAdminV2Server may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LoggingAdminV2Server 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.