Documentation
¶
Overview ¶
+k8s:deepcopy-gen=package +groupName=streaming.nats.io
Index ¶
Constants ¶
This section is empty.
Variables ¶
var ( SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes) AddToScheme = SchemeBuilder.AddToScheme // SchemeGroupVersion is the group version used to register these objects. SchemeGroupVersion = schema.GroupVersion{Group: groupName, Version: version} )
Functions ¶
This section is empty.
Types ¶
type NatsStreamingCluster ¶
type NatsStreamingCluster struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata"`
Spec NatsStreamingClusterSpec `json:"spec"`
Status NatsStreamingClusterStatus `json:"status,omitempty"`
}
NatsStreamingCluster
+genclient +genclient:noStatus +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
func (*NatsStreamingCluster) DeepCopy ¶
func (in *NatsStreamingCluster) DeepCopy() *NatsStreamingCluster
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NatsStreamingCluster.
func (*NatsStreamingCluster) DeepCopyInto ¶
func (in *NatsStreamingCluster) DeepCopyInto(out *NatsStreamingCluster)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*NatsStreamingCluster) DeepCopyObject ¶
func (in *NatsStreamingCluster) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type NatsStreamingClusterList ¶
type NatsStreamingClusterList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata"`
Items []NatsStreamingCluster `json:"items"`
}
NatsStreamingClusterList
+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
func (*NatsStreamingClusterList) DeepCopy ¶
func (in *NatsStreamingClusterList) DeepCopy() *NatsStreamingClusterList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NatsStreamingClusterList.
func (*NatsStreamingClusterList) DeepCopyInto ¶
func (in *NatsStreamingClusterList) DeepCopyInto(out *NatsStreamingClusterList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*NatsStreamingClusterList) DeepCopyObject ¶
func (in *NatsStreamingClusterList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type NatsStreamingClusterSpec ¶
type NatsStreamingClusterSpec struct {
// Size is the number of nodes in the NATS Streaming cluster.
Size int32 `json:"size"`
// Image is the version of NATS Streaming that is being used.
// By default it will be set to the latest version.
Image string `json:"image"`
// NatsService is the Kubernetes service to which the NATS
// Streaming nodes will connect. The service has to be in the
// same namespace as the NATS Operator.
NatsService string `json:"natsSvc"`
// Config is the server configuration.
Config *ServerConfig `json:"config,omitempty"`
// StoreType is the type of storage.
StoreType string `json:"store,omitempty"`
// ConfigFile is the optional configuration file for the server.
ConfigFile string `json:"configFile,omitempty"`
// PodTemplate is the optional template to use for the pods.
PodTemplate *k8scorev1.PodTemplateSpec `json:"template,omitempty"`
}
func (*NatsStreamingClusterSpec) DeepCopy ¶
func (in *NatsStreamingClusterSpec) DeepCopy() *NatsStreamingClusterSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NatsStreamingClusterSpec.
func (*NatsStreamingClusterSpec) DeepCopyInto ¶
func (in *NatsStreamingClusterSpec) DeepCopyInto(out *NatsStreamingClusterSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type NatsStreamingClusterStatus ¶
type NatsStreamingClusterStatus struct {
}
func (*NatsStreamingClusterStatus) DeepCopy ¶
func (in *NatsStreamingClusterStatus) DeepCopy() *NatsStreamingClusterStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NatsStreamingClusterStatus.
func (*NatsStreamingClusterStatus) DeepCopyInto ¶
func (in *NatsStreamingClusterStatus) DeepCopyInto(out *NatsStreamingClusterStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServerConfig ¶ added in v0.2.0
type ServerConfig struct {
// Debug enables debugging information for the server.
Debug bool `json:"debug"`
// Trace enables tracing for the server.
Trace bool `json:"trace"`
// RaftLogging enables debugging the raft server logs.
RaftLogging bool `json:"raftLogging"`
// StoreDir is the directory where the files will be persisted,
// in case file system is backed by a persistent volume.
StoreDir string `json:"storeDir"`
// FTGroup enables the fault tolerance mode for the server.
FTGroup string `json:"ftGroup"`
// Clustered enables explicitly in the cluster
Clustered bool `json:"clustered"`
}
ServerConfig is the configuration for the server.
func (*ServerConfig) DeepCopy ¶ added in v0.2.0
func (in *ServerConfig) DeepCopy() *ServerConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServerConfig.
func (*ServerConfig) DeepCopyInto ¶ added in v0.2.0
func (in *ServerConfig) DeepCopyInto(out *ServerConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
Source Files