loggingadmin

package
v0.12.0-rc1 Latest Latest
Warning

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

 Go to latest Published: Oct 30, 2023 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

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"
	LoggingAdminV2_CreateOrUpdateSnapshotSchedule_FullMethodName  = "/loggingadmin.LoggingAdminV2/CreateOrUpdateSnapshotSchedule"
	LoggingAdminV2_GetSnapshotSchedule_FullMethodName             = "/loggingadmin.LoggingAdminV2/GetSnapshotSchedule"
	LoggingAdminV2_DeleteSnapshotSchedule_FullMethodName          = "/loggingadmin.LoggingAdminV2/DeleteSnapshotSchedule"
	LoggingAdminV2_ListSnapshotSchedules_FullMethodName           = "/loggingadmin.LoggingAdminV2/ListSnapshotSchedules"
)

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,
		},
		{
			MethodName: "CreateOrUpdateSnapshotSchedule",
			Handler:    _LoggingAdminV2_CreateOrUpdateSnapshotSchedule_Handler,
		},
		{
			MethodName: "GetSnapshotSchedule",
			Handler:    _LoggingAdminV2_GetSnapshotSchedule_Handler,
		},
		{
			MethodName: "DeleteSnapshotSchedule",
			Handler:    _LoggingAdminV2_DeleteSnapshotSchedule_Handler,
		},
		{
			MethodName: "ListSnapshotSchedules",
			Handler:    _LoggingAdminV2_ListSnapshotSchedules_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)

Functions

func RegisterLoggingAdminV2Server 

func RegisterLoggingAdminV2Server(s grpc.ServiceRegistrar, srv LoggingAdminV2Server)

Types

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 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 *UpgradeOptions, 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)
	CreateOrUpdateSnapshotSchedule(ctx context.Context, in *SnapshotSchedule, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetSnapshotSchedule(ctx context.Context, in *SnapshotReference, opts ...grpc.CallOption) (*SnapshotSchedule, error)
	DeleteSnapshotSchedule(ctx context.Context, in *SnapshotReference, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ListSnapshotSchedules(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*SnapshotStatusList, 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

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, *UpgradeOptions) (*emptypb.Empty, error)
	GetStorageClasses(context.Context, *emptypb.Empty) (*StorageClassResponse, error)
	GetOpensearchStatus(context.Context, *emptypb.Empty) (*StatusResponse, error)
	CreateOrUpdateSnapshotSchedule(context.Context, *SnapshotSchedule) (*emptypb.Empty, error)
	GetSnapshotSchedule(context.Context, *SnapshotReference) (*SnapshotSchedule, error)
	DeleteSnapshotSchedule(context.Context, *SnapshotReference) (*emptypb.Empty, error)
	ListSnapshotSchedules(context.Context, *emptypb.Empty) (*SnapshotStatusList, error)
	// contains filtered or unexported methods
}

LoggingAdminV2Server is the server API for LoggingAdminV2 service. All implementations must embed UnimplementedLoggingAdminV2Server for forward compatibility

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"`
	S3                *OpensearchS3Settings `protobuf:"bytes,7,opt,name=s3,proto3,oneof" json:"s3,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) GetS3 added in v0.11.2 

func (x *OpensearchClusterV2) GetS3() *OpensearchS3Settings

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

type OpensearchS3Settings struct {
	Endpoint        string         `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Insecure        bool           `protobuf:"varint,2,opt,name=insecure,proto3" json:"insecure,omitempty"`
	PathStyleAccess bool           `protobuf:"varint,3,opt,name=pathStyleAccess,proto3" json:"pathStyleAccess,omitempty"`
	Credentials     *S3Credentials `protobuf:"bytes,4,opt,name=credentials,proto3" json:"credentials,omitempty"`
	Bucket          string         `protobuf:"bytes,5,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Folder          *string        `protobuf:"bytes,6,opt,name=folder,proto3,oneof" json:"folder,omitempty"`
	ProxySettings   *ProxySettings `protobuf:"bytes,7,opt,name=proxySettings,proto3" json:"proxySettings,omitempty"`
	// contains filtered or unexported fields
}

func (*OpensearchS3Settings) Descriptor deprecated added in v0.11.2 

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

Deprecated: Use OpensearchS3Settings.ProtoReflect.Descriptor instead.

func (*OpensearchS3Settings) GetBucket added in v0.11.2 

func (x *OpensearchS3Settings) GetBucket() string

func (*OpensearchS3Settings) GetCredentials added in v0.11.2 

func (x *OpensearchS3Settings) GetCredentials() *S3Credentials

func (*OpensearchS3Settings) GetEndpoint added in v0.11.2 

func (x *OpensearchS3Settings) GetEndpoint() string

func (*OpensearchS3Settings) GetFolder added in v0.11.2 

func (x *OpensearchS3Settings) GetFolder() string

func (*OpensearchS3Settings) GetInsecure added in v0.11.2 

func (x *OpensearchS3Settings) GetInsecure() bool

func (*OpensearchS3Settings) GetPathStyleAccess added in v0.11.2 

func (x *OpensearchS3Settings) GetPathStyleAccess() bool

func (*OpensearchS3Settings) GetProxySettings added in v0.11.2 

func (x *OpensearchS3Settings) GetProxySettings() *ProxySettings

func (*OpensearchS3Settings) ProtoMessage added in v0.11.2 

func (*OpensearchS3Settings) ProtoMessage()

func (*OpensearchS3Settings) ProtoReflect added in v0.11.2 

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

func (*OpensearchS3Settings) Reset added in v0.11.2 

func (x *OpensearchS3Settings) Reset()

func (*OpensearchS3Settings) String added in v0.11.2 

func (x *OpensearchS3Settings) String() string

type ProxySettings added in v0.11.2 

type ProxySettings struct {
	ProxyHost string `protobuf:"bytes,1,opt,name=proxyHost,proto3" json:"proxyHost,omitempty"`
	ProxyPort *int32 `protobuf:"varint,2,opt,name=proxyPort,proto3,oneof" json:"proxyPort,omitempty"`
	// contains filtered or unexported fields
}

func (*ProxySettings) Descriptor deprecated added in v0.11.2 

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

Deprecated: Use ProxySettings.ProtoReflect.Descriptor instead.

func (*ProxySettings) GetProxyHost added in v0.11.2 

func (x *ProxySettings) GetProxyHost() string

func (*ProxySettings) GetProxyPort added in v0.11.2 

func (x *ProxySettings) GetProxyPort() int32

func (*ProxySettings) ProtoMessage added in v0.11.2 

func (*ProxySettings) ProtoMessage()

func (*ProxySettings) ProtoReflect added in v0.11.2 

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

func (*ProxySettings) Reset added in v0.11.2 

func (x *ProxySettings) Reset()

func (*ProxySettings) String added in v0.11.2 

func (x *ProxySettings) 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 S3Credentials added in v0.11.2 

type S3Credentials struct {
	AccessKey string `protobuf:"bytes,1,opt,name=accessKey,proto3" json:"accessKey,omitempty"`
	SecretKey string `protobuf:"bytes,2,opt,name=secretKey,proto3" json:"secretKey,omitempty"`
	// contains filtered or unexported fields
}

func (*S3Credentials) Descriptor deprecated added in v0.11.2 

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

Deprecated: Use S3Credentials.ProtoReflect.Descriptor instead.

func (*S3Credentials) GetAccessKey added in v0.11.2 

func (x *S3Credentials) GetAccessKey() string

func (*S3Credentials) GetSecretKey added in v0.11.2 

func (x *S3Credentials) GetSecretKey() string

func (*S3Credentials) ProtoMessage added in v0.11.2 

func (*S3Credentials) ProtoMessage()

func (*S3Credentials) ProtoReflect added in v0.11.2 

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

func (*S3Credentials) Reset added in v0.11.2 

func (x *S3Credentials) Reset()

func (*S3Credentials) String added in v0.11.2 

func (x *S3Credentials) String() string

type SnapshotReference added in v0.11.2 

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

func (*SnapshotReference) Descriptor deprecated added in v0.11.2 

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

Deprecated: Use SnapshotReference.ProtoReflect.Descriptor instead.

func (*SnapshotReference) GetName added in v0.11.2 

func (x *SnapshotReference) GetName() string

func (*SnapshotReference) ProtoMessage added in v0.11.2 

func (*SnapshotReference) ProtoMessage()

func (*SnapshotReference) ProtoReflect added in v0.11.2 

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

func (*SnapshotReference) Reset added in v0.11.2 

func (x *SnapshotReference) Reset()

func (*SnapshotReference) String added in v0.11.2 

func (x *SnapshotReference) String() string

type SnapshotRetention added in v0.11.2 

type SnapshotRetention struct {
	TimeRetention *string `protobuf:"bytes,1,opt,name=timeRetention,proto3,oneof" json:"timeRetention,omitempty"`
	MaxSnapshots  *int32  `protobuf:"varint,2,opt,name=maxSnapshots,proto3,oneof" json:"maxSnapshots,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotRetention) Descriptor deprecated added in v0.11.2 

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

Deprecated: Use SnapshotRetention.ProtoReflect.Descriptor instead.

func (*SnapshotRetention) GetMaxSnapshots added in v0.11.2 

func (x *SnapshotRetention) GetMaxSnapshots() int32

func (*SnapshotRetention) GetTimeRetention added in v0.11.2 

func (x *SnapshotRetention) GetTimeRetention() string

func (*SnapshotRetention) ProtoMessage added in v0.11.2 

func (*SnapshotRetention) ProtoMessage()

func (*SnapshotRetention) ProtoReflect added in v0.11.2 

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

func (*SnapshotRetention) Reset added in v0.11.2 

func (x *SnapshotRetention) Reset()

func (*SnapshotRetention) String added in v0.11.2 

func (x *SnapshotRetention) String() string

type SnapshotSchedule added in v0.12.0 

type SnapshotSchedule struct {
	Ref               *SnapshotReference `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	CronSchedule      string             `protobuf:"bytes,3,opt,name=cronSchedule,proto3" json:"cronSchedule,omitempty"`
	Retention         *SnapshotRetention `protobuf:"bytes,4,opt,name=retention,proto3,oneof" json:"retention,omitempty"`
	AdditionalIndices []string           `protobuf:"bytes,5,rep,name=additionalIndices,proto3" json:"additionalIndices,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotSchedule) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use SnapshotSchedule.ProtoReflect.Descriptor instead.

func (*SnapshotSchedule) GetAdditionalIndices added in v0.12.0 

func (x *SnapshotSchedule) GetAdditionalIndices() []string

func (*SnapshotSchedule) GetCronSchedule added in v0.12.0 

func (x *SnapshotSchedule) GetCronSchedule() string

func (*SnapshotSchedule) GetRef added in v0.12.0 

func (x *SnapshotSchedule) GetRef() *SnapshotReference

func (*SnapshotSchedule) GetRetention added in v0.12.0 

func (x *SnapshotSchedule) GetRetention() *SnapshotRetention

func (*SnapshotSchedule) ProtoMessage added in v0.12.0 

func (*SnapshotSchedule) ProtoMessage()

func (*SnapshotSchedule) ProtoReflect added in v0.12.0 

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

func (*SnapshotSchedule) Reset added in v0.12.0 

func (x *SnapshotSchedule) Reset()

func (*SnapshotSchedule) String added in v0.12.0 

func (x *SnapshotSchedule) String() string

type SnapshotStatus added in v0.11.2 

type SnapshotStatus struct {
	Ref           *SnapshotReference     `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	Status        string                 `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	StatusMessage *string                `protobuf:"bytes,3,opt,name=statusMessage,proto3,oneof" json:"statusMessage,omitempty"`
	LastUpdated   *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=lastUpdated,proto3" json:"lastUpdated,omitempty"`
	Recurring     bool                   `protobuf:"varint,5,opt,name=recurring,proto3" json:"recurring,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotStatus) Descriptor deprecated added in v0.11.2 

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

Deprecated: Use SnapshotStatus.ProtoReflect.Descriptor instead.

func (*SnapshotStatus) GetLastUpdated added in v0.11.2 

func (x *SnapshotStatus) GetLastUpdated() *timestamppb.Timestamp

func (*SnapshotStatus) GetRecurring added in v0.11.2 

func (x *SnapshotStatus) GetRecurring() bool

func (*SnapshotStatus) GetRef added in v0.11.2 

func (x *SnapshotStatus) GetRef() *SnapshotReference

func (*SnapshotStatus) GetStatus added in v0.11.2 

func (x *SnapshotStatus) GetStatus() string

func (*SnapshotStatus) GetStatusMessage added in v0.11.2 

func (x *SnapshotStatus) GetStatusMessage() string

func (*SnapshotStatus) ProtoMessage added in v0.11.2 

func (*SnapshotStatus) ProtoMessage()

func (*SnapshotStatus) ProtoReflect added in v0.11.2 

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

func (*SnapshotStatus) Reset added in v0.11.2 

func (x *SnapshotStatus) Reset()

func (*SnapshotStatus) String added in v0.11.2 

func (x *SnapshotStatus) String() string

type SnapshotStatusList added in v0.11.2 

type SnapshotStatusList struct {
	Statuses []*SnapshotStatus `protobuf:"bytes,1,rep,name=statuses,proto3" json:"statuses,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotStatusList) Descriptor deprecated added in v0.11.2 

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

Deprecated: Use SnapshotStatusList.ProtoReflect.Descriptor instead.

func (*SnapshotStatusList) GetStatuses added in v0.11.2 

func (x *SnapshotStatusList) GetStatuses() []*SnapshotStatus

func (*SnapshotStatusList) ProtoMessage added in v0.11.2 

func (*SnapshotStatusList) ProtoMessage()

func (*SnapshotStatusList) ProtoReflect added in v0.11.2 

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

func (*SnapshotStatusList) Reset added in v0.11.2 

func (x *SnapshotStatusList) Reset()

func (*SnapshotStatusList) String added in v0.11.2 

func (x *SnapshotStatusList) 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 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) CreateOrUpdateSnapshotSchedule added in v0.12.0 

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

func (UnimplementedLoggingAdminV2Server) DeleteOpensearchCluster 

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

func (UnimplementedLoggingAdminV2Server) DeleteSnapshotSchedule added in v0.12.0 

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

func (UnimplementedLoggingAdminV2Server) DoUpgrade 

func (UnimplementedLoggingAdminV2Server) DoUpgrade(context.Context, *UpgradeOptions) (*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) GetSnapshotSchedule added in v0.12.0 

func (UnimplementedLoggingAdminV2Server) GetSnapshotSchedule(context.Context, *SnapshotReference) (*SnapshotSchedule, error)

func (UnimplementedLoggingAdminV2Server) GetStorageClasses 

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

func (UnimplementedLoggingAdminV2Server) ListSnapshotSchedules added in v0.12.0 

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

func (UnimplementedLoggingAdminV2Server) UpgradeAvailable 

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

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

type UpgradeOptions added in v0.12.0 

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

func (*UpgradeOptions) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use UpgradeOptions.ProtoReflect.Descriptor instead.

func (*UpgradeOptions) GetSnapshotCluster added in v0.12.0 

func (x *UpgradeOptions) GetSnapshotCluster() bool

func (*UpgradeOptions) ProtoMessage added in v0.12.0 

func (*UpgradeOptions) ProtoMessage()

func (*UpgradeOptions) ProtoReflect added in v0.12.0 

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

func (*UpgradeOptions) Reset added in v0.12.0 

func (x *UpgradeOptions) Reset()

func (*UpgradeOptions) String added in v0.12.0 

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