nificluster

Documentation

Index

• type ExternalCluster
  • func (cluster *ExternalCluster) ClusterLabelString() string
  • func (cluster *ExternalCluster) Id() string
  • func (cluster *ExternalCluster) IsExternal() bool
  • func (cluster *ExternalCluster) IsInternal() bool
  • func (cluster ExternalCluster) IsReady(log zap.Logger) bool
• type InternalCluster
  • func (cluster *InternalCluster) ClusterLabelString() string
  • func (c *InternalCluster) Id() string
  • func (c InternalCluster) IsExternal() bool
  • func (c *InternalCluster) IsInternal() bool
  • func (c InternalCluster) IsReady(log zap.Logger) bool

Types

type ExternalCluster

type ExternalCluster struct {
	NodeURITemplate    string
	NodeIds            []int32
	NifiURI            string
	Name               string
	RootProcessGroupId string

	NifiConfig *clientconfig.NifiConfig
}

func (*ExternalCluster) ClusterLabelString

func (cluster *ExternalCluster) ClusterLabelString() string

func (*ExternalCluster) Id

func (cluster *ExternalCluster) Id() string

func (*ExternalCluster) IsExternal

func (cluster *ExternalCluster) IsExternal() bool

func (*ExternalCluster) IsInternal

func (cluster *ExternalCluster) IsInternal() bool

func (ExternalCluster) IsReady

func (cluster ExternalCluster) IsReady(log zap.Logger) bool

type InternalCluster

type InternalCluster struct {
	Status    v1alpha1.NifiClusterStatus
	Name      string
	Namespace string
}

func (*InternalCluster) ClusterLabelString

func (cluster *InternalCluster) ClusterLabelString() string

func (*InternalCluster) Id

func (c *InternalCluster) Id() string

func (InternalCluster) IsExternal

func (c InternalCluster) IsExternal() bool

func (*InternalCluster) IsInternal

func (c *InternalCluster) IsInternal() bool

func (InternalCluster) IsReady

func (c InternalCluster) IsReady(log zap.Logger) bool