v1alpha1

Documentation

Overview

Package v1alpha1 is the v1alpha1 version of the API.

Index

• Variables
• func Kind(kind string) schema.GroupKind
• func Resource(resource string) schema.GroupResource
• type DataTopicAndThread
  • func (in *DataTopicAndThread) DeepCopy() *DataTopicAndThread
  • func (in *DataTopicAndThread) DeepCopyInto(out *DataTopicAndThread)
• type FileSync
  • func (in *FileSync) DeepCopy() *FileSync
  • func (in *FileSync) DeepCopyInto(out *FileSync)
  • func (in *FileSync) DeepCopyObject() runtime.Object
• type FileSyncList
  • func (in *FileSyncList) DeepCopy() *FileSyncList
  • func (in *FileSyncList) DeepCopyInto(out *FileSyncList)
  • func (in *FileSyncList) DeepCopyObject() runtime.Object
• type FileSyncSpec
  • func (in *FileSyncSpec) DeepCopy() *FileSyncSpec
  • func (in *FileSyncSpec) DeepCopyInto(out *FileSyncSpec)
• type FileSyncStatus
  • func (in *FileSyncStatus) DeepCopy() *FileSyncStatus
  • func (in *FileSyncStatus) DeepCopyInto(out *FileSyncStatus)
• type GlobalSpec
  • func (in *GlobalSpec) DeepCopy() *GlobalSpec
  • func (in *GlobalSpec) DeepCopyInto(out *GlobalSpec)
• type LogSpec
  • func (in *LogSpec) DeepCopy() *LogSpec
  • func (in *LogSpec) DeepCopyInto(out *LogSpec)
• type MonitSpec
  • func (in *MonitSpec) DeepCopy() *MonitSpec
  • func (in *MonitSpec) DeepCopyInto(out *MonitSpec)
• type NATSSpec
  • func (in *NATSSpec) DeepCopy() *NATSSpec
  • func (in *NATSSpec) DeepCopyInto(out *NATSSpec)
• type ReaderSpec
  • func (in *ReaderSpec) DeepCopy() *ReaderSpec
  • func (in *ReaderSpec) DeepCopyInto(out *ReaderSpec)
• type SyncMetadata
  • func (in *SyncMetadata) DeepCopy() *SyncMetadata
  • func (in *SyncMetadata) DeepCopyInto(out *SyncMetadata)
• type WriterSpec
  • func (in *WriterSpec) DeepCopy() *WriterSpec
  • func (in *WriterSpec) DeepCopyInto(out *WriterSpec)

Variables

var (
	// SchemeBuilder initializes a scheme builder
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
	// AddToScheme is a global function that registers this API group & version to a scheme
	AddToScheme = SchemeBuilder.AddToScheme
)

var SchemeGroupVersion = schema.GroupVersion{Group: filesync.GroupName, Version: "v1alpha1"}

SchemeGroupVersion is group version used to register these objects

Functions

func Kind

func Kind(kind string) schema.GroupKind

Kind takes an unqualified kind and returns back a Group qualified GroupKind

func Resource

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

Types

type DataTopicAndThread

type DataTopicAndThread struct {
	DataTopic          string `json:"dataTopic"`
	DontCheckDataTopic bool   `json:"dontCheckDataTopic,omitempty"`
	ThreadNum          *int   `json:"threadNum,omitempty"`
}

func (*DataTopicAndThread) DeepCopy

func (in *DataTopicAndThread) DeepCopy() *DataTopicAndThread

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DataTopicAndThread.

func (*DataTopicAndThread) DeepCopyInto

func (in *DataTopicAndThread) DeepCopyInto(out *DataTopicAndThread)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type FileSync

type FileSync struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   FileSyncSpec   `json:"spec"`
	Status FileSyncStatus `json:"status"`
}

FileSync is a specification for a FileSync resource

func (*FileSync) DeepCopy

func (in *FileSync) DeepCopy() *FileSync

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FileSync.

func (*FileSync) DeepCopyInto

func (in *FileSync) DeepCopyInto(out *FileSync)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*FileSync) DeepCopyObject

func (in *FileSync) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type FileSyncList

type FileSyncList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`

	Items []FileSync `json:"items"`
}

FileSyncList is a list of FileSync resources

func (*FileSyncList) DeepCopy

func (in *FileSyncList) DeepCopy() *FileSyncList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FileSyncList.

func (*FileSyncList) DeepCopyInto

func (in *FileSyncList) DeepCopyInto(out *FileSyncList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*FileSyncList) DeepCopyObject

func (in *FileSyncList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type FileSyncSpec

type FileSyncSpec struct {
	Global GlobalSpec  `json:"global"`
	NATS   *NATSSpec   `json:"nats,omitempty"`
	Monit  *MonitSpec  `json:"monit,omitempty"`
	Reader *ReaderSpec `json:"reader,omitempty"`
	Writer *WriterSpec `json:"writer,omitempty"`
}

FileSyncSpec is the spec for a FileSync resource

func (*FileSyncSpec) DeepCopy

func (in *FileSyncSpec) DeepCopy() *FileSyncSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FileSyncSpec.

func (*FileSyncSpec) DeepCopyInto

func (in *FileSyncSpec) DeepCopyInto(out *FileSyncSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type FileSyncStatus

type FileSyncStatus struct {
	ObservedGeneration int64   `json:"observedGeneration"`
	ConfigMapStatus    string  `json:"configmapStatus"`
	ReaderStatus       *string `json:"readerStatus,omitempty"`
	WriterStatus       *string `json:"writerStatus,omitempty"`
}

FileSyncStatus is the status for a FileSync resource

func (*FileSyncStatus) DeepCopy

func (in *FileSyncStatus) DeepCopy() *FileSyncStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FileSyncStatus.

func (*FileSyncStatus) DeepCopyInto

func (in *FileSyncStatus) DeepCopyInto(out *FileSyncStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type GlobalSpec

type GlobalSpec struct {
	MQ string `json:"mq"`
}

func (*GlobalSpec) DeepCopy

func (in *GlobalSpec) DeepCopy() *GlobalSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GlobalSpec.

func (*GlobalSpec) DeepCopyInto

func (in *GlobalSpec) DeepCopyInto(out *GlobalSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type LogSpec

type LogSpec struct {
	LogPath    *string `json:"logPath,omitempty"`
	LogPathPVC *string `json:"logPathPVC,omitempty"`
	LogLevel   *string `json:"logLevel,omitempty"`
}

func (*LogSpec) DeepCopy

func (in *LogSpec) DeepCopy() *LogSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LogSpec.

func (*LogSpec) DeepCopyInto

func (in *LogSpec) DeepCopyInto(out *LogSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type MonitSpec

type MonitSpec struct {
	Topic       string  `json:"topic"`
	Encoding    string  `json:"encoding"`
	Hash        int     `json:"hash"`
	EndMsgTopic *string `json:"endMsgTopic,omitempty"`
}

func (*MonitSpec) DeepCopy

func (in *MonitSpec) DeepCopy() *MonitSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MonitSpec.

func (*MonitSpec) DeepCopyInto

func (in *MonitSpec) DeepCopyInto(out *MonitSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type NATSSpec

type NATSSpec struct {
	IP          string  `json:"ip"`
	Port        int     `json:"port"`
	User        string  `json:"user"`
	Password    string  `json:"password"`
	CredsSecret *string `json:"credsSecret,omitempty"`
	SecretKey   string  `json:"secretKey,omitempty"`
}

func (*NATSSpec) DeepCopy

func (in *NATSSpec) DeepCopy() *NATSSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NATSSpec.

func (*NATSSpec) DeepCopyInto

func (in *NATSSpec) DeepCopyInto(out *NATSSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ReaderSpec

type ReaderSpec struct {
	SyncMetadata       `json:",inline"`
	LogSpec            `json:",inline"`
	DataTopicAndThread `json:",inline"`

	SrcPath         string  `json:"srcPath"`
	SrcPathPVC      *string `json:"srcPathPVC,omitempty"`
	ShadowPath      *string `json:"shadowPath,omitempty"`
	ShadowPathPVC   *string `json:"shadowPathPVC,omitempty"`
	DirShadowPrefix *string `json:"dirShadowPrefix,omitempty"`

	HandleModeAfterRead *string `json:"handleModeAfterRead,omitempty"`
	TrashPath           *string `json:"trashPath,omitempty"`
	TrashPathPVC        *string `json:"trashPathPVC,omitempty"`

	IncScanMode     *int `json:"incScanMode,omitempty"`
	IncScanInterval *int `json:"incScanInterval,omitempty"`
	IncQnotifyMode  *int `json:"incQnotifyMode,omitempty"`

	DirLevelUseThread *int   `json:"dirLevelUseThread,omitempty"`
	DataSliceSize     string `json:"dataSliceSize"`

	IncSkipDays *int `json:"incSkipDays,omitempty"`

	IncludedFiletype *string `json:"includedFiletype,omitempty"`
	ExcludedFiletype *string `json:"excludedFiletype,omitempty"`
	FilepathRegex    *string `json:"filepathRegex,omitempty"`

	FmodeRead int `json:"fmodeRead"`
	UserRead  int `json:"userRead"`

	LogsyncMode int `json:"logsyncMode"`

	ReaderLabel *string `json:"readerLabel,omitempty"`
}

func (*ReaderSpec) DeepCopy

func (in *ReaderSpec) DeepCopy() *ReaderSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReaderSpec.

func (*ReaderSpec) DeepCopyInto

func (in *ReaderSpec) DeepCopyInto(out *ReaderSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SyncMetadata

type SyncMetadata struct {
	NodeSelector map[string]string `json:"nodeSelector"`
	Image        string            `json:"image"`

	ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty"`
	Tolerations      []corev1.Toleration           `json:"tolerations,omitempty"`
	Labels           map[string]string             `json:"labels,omitempty"`
}

func (*SyncMetadata) DeepCopy

func (in *SyncMetadata) DeepCopy() *SyncMetadata

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SyncMetadata.

func (*SyncMetadata) DeepCopyInto

func (in *SyncMetadata) DeepCopyInto(out *SyncMetadata)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WriterSpec

type WriterSpec struct {
	SyncMetadata       `json:",inline"`
	LogSpec            `json:",inline"`
	DataTopicAndThread `json:",inline"`

	RcvPath      string  `json:"rcvPath"`
	RcvPathPVC   *string `json:"rcvPathPVC,omitempty"`
	TrashPath    *string `json:"trashPath,omitempty"`
	TrashPathPVC *string `json:"trashPathPVC,omitempty"`

	FmodeWrite int `json:"fmodeWrite"`
	UserWrite  int `json:"userWrite"`

	BisyncShadowPath *string `json:"bisyncShadowPath,omitempty"`
	BisyncMode       *int    `json:"bisyncMode,omitempty"`

	BigfileSliceCount *int    `json:"bigfileSliceCount,omitempty"`
	WriterLabel       *string `json:"writerLabel,omitempty"`
}

func (*WriterSpec) DeepCopy

func (in *WriterSpec) DeepCopy() *WriterSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WriterSpec.

func (*WriterSpec) DeepCopyInto

func (in *WriterSpec) DeepCopyInto(out *WriterSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.