loggingadmin

package
v0.11.1 Latest Latest
Warning

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

 Go to latest Published: Aug 16, 2023 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	LoggingAdmin_GetOpensearchCluster_FullMethodName            = "/loggingadmin.LoggingAdmin/GetOpensearchCluster"
	LoggingAdmin_DeleteOpensearchCluster_FullMethodName         = "/loggingadmin.LoggingAdmin/DeleteOpensearchCluster"
	LoggingAdmin_CreateOrUpdateOpensearchCluster_FullMethodName = "/loggingadmin.LoggingAdmin/CreateOrUpdateOpensearchCluster"
	LoggingAdmin_UpgradeAvailable_FullMethodName                = "/loggingadmin.LoggingAdmin/UpgradeAvailable"
	LoggingAdmin_DoUpgrade_FullMethodName                       = "/loggingadmin.LoggingAdmin/DoUpgrade"
	LoggingAdmin_GetStorageClasses_FullMethodName               = "/loggingadmin.LoggingAdmin/GetStorageClasses"
	LoggingAdmin_GetOpensearchStatus_FullMethodName             = "/loggingadmin.LoggingAdmin/GetOpensearchStatus"
)
View Source 
const (
	LoggingAdminV2_GetOpensearchCluster_FullMethodName            = "/loggingadmin.LoggingAdminV2/GetOpensearchCluster"
	LoggingAdminV2_DeleteOpensearchCluster_FullMethodName         = "/loggingadmin.LoggingAdminV2/DeleteOpensearchCluster"
	LoggingAdminV2_CreateOrUpdateOpensearchCluster_FullMethodName = "/loggingadmin.LoggingAdminV2/CreateOrUpdateOpensearchCluster"
	LoggingAdminV2_UpgradeAvailable_FullMethodName                = "/loggingadmin.LoggingAdminV2/UpgradeAvailable"
	LoggingAdminV2_DoUpgrade_FullMethodName                       = "/loggingadmin.LoggingAdminV2/DoUpgrade"
	LoggingAdminV2_GetStorageClasses_FullMethodName               = "/loggingadmin.LoggingAdminV2/GetStorageClasses"
	LoggingAdminV2_GetOpensearchStatus_FullMethodName             = "/loggingadmin.LoggingAdminV2/GetOpensearchStatus"
)

Variables

View Source 
var File_github_com_rancher_opni_plugins_logging_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/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/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 RegisterLoggingAdminServer 

func RegisterLoggingAdminServer(s grpc.ServiceRegistrar, srv LoggingAdminServer)

func RegisterLoggingAdminV2Server 

func RegisterLoggingAdminV2Server(s grpc.ServiceRegistrar, srv LoggingAdminV2Server)

Types

type AdminClientOption 

type AdminClientOption func(*AdminClientOptions)

func WithDialOptions 

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

func WithListenAddress 

func WithListenAddress(addr string) AdminClientOption

type AdminClientOptions 

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 ControlplaneDetails 

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 

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

Deprecated: Use ControlplaneDetails.ProtoReflect.Descriptor instead.

func (*ControlplaneDetails) GetNodeSelector 

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

func (*ControlplaneDetails) GetPersistence 

func (x *ControlplaneDetails) GetPersistence() *DataPersistence

func (*ControlplaneDetails) GetReplicas 

func (x *ControlplaneDetails) GetReplicas() int32

func (*ControlplaneDetails) GetTolerations 

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

func (*ControlplaneDetails) ProtoMessage 

func (*ControlplaneDetails) ProtoMessage()

func (*ControlplaneDetails) ProtoReflect 

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

func (*ControlplaneDetails) Reset 

func (x *ControlplaneDetails) Reset()

func (*ControlplaneDetails) String 

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 

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 

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

Deprecated: Use DataDetails.ProtoReflect.Descriptor instead.

func (*DataDetails) GetCpuResources 

func (x *DataDetails) GetCpuResources() *CPUResource

func (*DataDetails) GetDiskSize 

func (x *DataDetails) GetDiskSize() string

func (*DataDetails) GetEnableAntiAffinity 

func (x *DataDetails) GetEnableAntiAffinity() bool

func (*DataDetails) GetMemoryLimit 

func (x *DataDetails) GetMemoryLimit() string

func (*DataDetails) GetNodeSelector 

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

func (*DataDetails) GetPersistence 

func (x *DataDetails) GetPersistence() *DataPersistence

func (*DataDetails) GetReplicas 

func (x *DataDetails) GetReplicas() int32

func (*DataDetails) GetTolerations 

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

func (*DataDetails) ProtoMessage 

func (*DataDetails) ProtoMessage()

func (*DataDetails) ProtoReflect 

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

func (*DataDetails) Reset 

func (x *DataDetails) Reset()

func (*DataDetails) String 

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 

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 

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

Deprecated: Use IngestDetails.ProtoReflect.Descriptor instead.

func (*IngestDetails) GetCpuResources 

func (x *IngestDetails) GetCpuResources() *CPUResource

func (*IngestDetails) GetEnableAntiAffinity 

func (x *IngestDetails) GetEnableAntiAffinity() bool

func (*IngestDetails) GetMemoryLimit 

func (x *IngestDetails) GetMemoryLimit() string

func (*IngestDetails) GetNodeSelector 

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

func (*IngestDetails) GetReplicas 

func (x *IngestDetails) GetReplicas() int32

func (*IngestDetails) GetTolerations 

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

func (*IngestDetails) ProtoMessage 

func (*IngestDetails) ProtoMessage()

func (*IngestDetails) ProtoReflect 

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

func (*IngestDetails) Reset 

func (x *IngestDetails) Reset()

func (*IngestDetails) String 

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 

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 

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 

func NewLoggingAdminV2Client(cc grpc.ClientConnInterface) LoggingAdminV2Client

func NewV2Client 

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

type LoggingAdminV2Server 

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 

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 

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

Deprecated: Use OpensearchClusterV2.ProtoReflect.Descriptor instead.

func (*OpensearchClusterV2) GetControlplaneNodes 

func (x *OpensearchClusterV2) GetControlplaneNodes() *ControlplaneDetails

func (*OpensearchClusterV2) GetDashboards 

func (x *OpensearchClusterV2) GetDashboards() *DashboardsDetails

func (*OpensearchClusterV2) GetDataNodes 

func (x *OpensearchClusterV2) GetDataNodes() *DataDetails

func (*OpensearchClusterV2) GetDataRetention 

func (x *OpensearchClusterV2) GetDataRetention() string

func (*OpensearchClusterV2) GetExternalURL 

func (x *OpensearchClusterV2) GetExternalURL() string

func (*OpensearchClusterV2) GetIngestNodes 

func (x *OpensearchClusterV2) GetIngestNodes() *IngestDetails

func (*OpensearchClusterV2) ProtoMessage 

func (*OpensearchClusterV2) ProtoMessage()

func (*OpensearchClusterV2) ProtoReflect 

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

func (*OpensearchClusterV2) Reset 

func (x *OpensearchClusterV2) Reset()

func (*OpensearchClusterV2) String 

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 

type UnimplementedLoggingAdminV2Server struct {
}

UnimplementedLoggingAdminV2Server must be embedded to have forward compatible implementations.

func (UnimplementedLoggingAdminV2Server) CreateOrUpdateOpensearchCluster 

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

func (UnimplementedLoggingAdminV2Server) DeleteOpensearchCluster 

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

func (UnimplementedLoggingAdminV2Server) DoUpgrade 

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

func (UnimplementedLoggingAdminV2Server) GetOpensearchCluster 

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

func (UnimplementedLoggingAdminV2Server) GetOpensearchStatus 

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

func (UnimplementedLoggingAdminV2Server) GetStorageClasses 

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

func (UnimplementedLoggingAdminV2Server) UpgradeAvailable 

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 

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.