Versions in this module Expand all Collapse all v0 v0.2.0 Mar 25, 2020 Changes in this version + type BulletinDTO struct + Category string + GroupID string + ID int64 + Level string + Message string + NodeAddress string + SourceID string + SourceName string + Timestamp string + type BulletinEntity struct + Bulletin BulletinDTO + CanRead bool + GroupID string + ID int64 + NodeAddress string + SourceID string + Timestamp string + type Client struct + func NewClient(baseURL, username, password, caCertificates string) (*Client, error) + func (c *Client) GetConnections(parentID string) ([]ConnectionEntity, error) + func (c *Client) GetCounters(nodewise bool, clusterNodeId string) (*CountersDTO, error) + func (c *Client) GetDeepProcessGroups(parentID string) ([]ProcessGroupEntity, error) + func (c *Client) GetProcessGroup(id string) (*ProcessGroupEntity, error) + func (c *Client) GetProcessGroups(parentID string) ([]ProcessGroupEntity, error) + func (c *Client) GetSystemDiagnostics(nodewise bool, clusterNodeId string) (*SystemDiagnosticsDTO, error) + type ConnectionDTO struct + AvailableRelationships []string + BackPressureDataSizeThreshold string + BackPressureObjectThreshold int + Bends []PositionDTO + Destination ConnectionEndPointDTO + FlowFileExpiration string + ID string + LabelIndex int + Name string + ParentGroupID string + Prioritizers []string + SelectedRelationships []string + Source ConnectionEndPointDTO + ZIndex int + type ConnectionEndPointDTO struct + Comments string + GroupID string + ID string + Name string + Running bool + Type string + type ConnectionEntity struct + Bends []PositionDTO + Component ConnectionDTO + DestinationGroupID string + DestinationID string + DestinationType string + ID string + LabelIndex int + Permissions PermissionsDTO + Revision RevisionDTO + SourceGroupID string + SourceID string + SourceType string + Status ConnectionStatusDTO + URI string + ZIndex int + type ConnectionStatusDTO struct + AggregateSnapshot *ConnectionStatusSnapshotDTO + DestinationID string + DestinationName string + GroupID string + ID string + Name string + NodeSnapshots []NodeProcessGroupStatusSnapshotDTO + SourceID string + SourceName string + StatsLastRefreshed string + type ConnectionStatusSnapshotDTO struct + BytesIn int64 + BytesOut int64 + BytesQueued int64 + DestinationID string + DestinationName string + FlowFilesIn int + FlowFilesOut int + FlowFilesQueued int + GroupID string + ID string + Input string + Name string + Output string + PercentUseBytes int + PercentUseCount int + Queued string + QueuedCount string + QueuedSize string + SourceID string + SourceName string + type ConnectionStatusSnapshotEntity struct + CanRead bool + ConnectionStatusSnapshot ConnectionStatusSnapshotDTO + ID string + type ConnectionsEntity struct + Connections []ConnectionEntity + type CounterDTO struct + Context string + ID string + Name string + Value string + ValueCount int64 + type CountersDTO struct + AggregateSnapshot *CountersSnapshotDTO + NodeSnapshots []NodeCountersSnapshotDTO + type CountersEntity struct + Counters CountersDTO + type CountersSnapshotDTO struct + Counters []CounterDTO + Generated string + type Credentials struct + Password string + Username string + type GarbageCollectionDTO struct + CollectionCount int64 + CollectionMillis int64 + CollectionTime string + Name string + type NodeCountersSnapshotDTO struct + Address string + ApiPort int + NodeID string + Snapshot CountersSnapshotDTO + type NodeProcessGroupStatusSnapshotDTO struct + Address string + ApiPort int + NodeID string + StatusSnapshot ProcessGroupStatusSnapshotDTO + type NodeSystemDiagnosticsSnapshotDTO struct + Address string + ApiPort int + NodeID string + Snapshot SystemDiagnosticsSnapshotDTO + type PermissionsDTO struct + CanRead bool + CanWrite bool + type PortStatusSnapshotDTO struct + ActiveThreadCount int + BytesIn int64 + BytesOut int64 + FlowFilesIn int + FlowFilesOut int + GroupID string + ID string + Input string + Name string + Output string + RunStatus string + Transmitting bool + type PortStatusSnapshotEntity struct + CanRead bool + ID string + PortStatusSnapshot PortStatusSnapshotDTO + type PositionDTO struct + X float64 + Y float64 + type ProcessGroupDTO struct + ActiveRemotePortCount int + Comments string + DisabledCount int + ID string + InactiveRemotePortCount int + InputPortCount int + InvalidCount int + Name string + OutputPortCount int + ParentGroupID string + Position PositionDTO + RunningCount int + StoppedCount int + type ProcessGroupEntity struct + ActiveRemotePortCount int + Bulletins []BulletinEntity + Component ProcessGroupDTO + DisabledCount int + ID string + InactiveRemotePortCount int + InputPortCount int + InvalidCount int + OutputPortCount int + Permissions PermissionsDTO + Position PositionDTO + Revision RevisionDTO + RunningCount int + Status ProcessGroupStatusDTO + StoppedCount int + URI string + type ProcessGroupStatusDTO struct + AggregateSnapshot *ProcessGroupStatusSnapshotDTO + ID string + Name string + NodeSnapshots []NodeProcessGroupStatusSnapshotDTO + StatsLastRefreshed string + type ProcessGroupStatusSnapshotDTO struct + ActiveThreadCount int + BytesIn int64 + BytesOut int64 + BytesQueued int64 + BytesRead int64 + BytesReceived int64 + BytesSent int64 + BytesTransferred int64 + BytesWritten int64 + ConnectionStatusSnapshots []ConnectionStatusSnapshotEntity + FlowFilesIn int + FlowFilesOut int + FlowFilesQueued int + FlowFilesReceived int + FlowFilesSent int + FlowFilesTransferred int + ID string + Input string + InputPortStatusSnapshots []PortStatusSnapshotEntity + Name string + Output string + OutputPortStatusSnapshots []PortStatusSnapshotEntity + ProcessGroupStatusSnapshots []ProcessGroupStatusSnapshotEntity + ProcessorStatusSnapshots []ProcessorStatusSnapshotEntity + Queued string + QueuedCount string + QueuedSize string + Read string + Received string + RemoteProcessGroupStatusSnapshots []RemoteProcessGroupStatusSnapshotEntity + Sent string + Transferred string + Written string + type ProcessGroupStatusSnapshotEntity struct + CanRead bool + ID string + type ProcessGroupsEntity struct + ProcessGroups []ProcessGroupEntity + type ProcessorStatusSnapshotDTO struct + ActiveThreadCount int + BytesIn int64 + BytesOut int64 + BytesRead int64 + BytesWritten int64 + FlowFilesIn int + FlowFilesOut int + GroupID string + ID string + Input string + Name string + Output string + Read string + RunStatus string + TaskCount int + Tasks string + TasksDuration string + TasksDurationNanos int64 + Type string + Written string + type ProcessorStatusSnapshotEntity struct + CanRead bool + ID string + ProcessorStatusSnapshot ProcessorStatusSnapshotDTO + type RemoteProcessGroupStatusSnapshotDTO struct + ActiveThreadCount int + BytesReceived int64 + BytesSent int64 + FlowFilesReceived int + FlowFilesSent int + GroupID string + ID string + Name string + Received string + Sent string + TargetURI string + TransmissionStatus string + type RemoteProcessGroupStatusSnapshotEntity struct + CanRead bool + ID string + RemoteProcessGroupStatusSnapshot RemoteProcessGroupStatusSnapshotDTO + type RevisionDTO struct + ClientID string + LastModifier string + Version int64 + type StorageUsageDTO struct + FreeSpace string + FreeSpaceBytes int64 + Identifier string + TotalSpace string + TotalSpaceBytes int64 + UsedSpace string + UsedSpaceBytes int64 + Utilization string + type SystemDiagnosticsDTO struct + AggregateSnapshot *SystemDiagnosticsSnapshotDTO + NodeSnapshots []NodeSystemDiagnosticsSnapshotDTO + type SystemDiagnosticsEntity struct + SystemDiagnostics SystemDiagnosticsDTO + type SystemDiagnosticsSnapshotDTO struct + AvailableProcessors int + ContentRepositoryStorageUsage []StorageUsageDTO + DaemonThreads int + FlowFileRepositoryStorageUsage StorageUsageDTO + FreeHeap string + FreeHeapBytes int64 + FreeNonHeap string + FreeNonHeapBytes int64 + GarbageCollection []GarbageCollectionDTO + HeapUtilization string + MaxHeap string + MaxHeapBytes int64 + MaxNonHeap string + MaxNonHeapBytes int64 + NonHeapUtilization string + ProcessorLoadAverage float64 + ProvenanceRepositoryStorageUsage []StorageUsageDTO + StatsLastRefreshed string + TotalHeap string + TotalHeapBytes int64 + TotalNonHeap string + TotalNonHeapBytes int64 + TotalThreads int + Uptime string + UsedHeap string + UsedHeapBytes int64 + UsedNonHeap string + UsedNonHeapBytes int64 + VersionInfo VersionInfoDTO + type VersionInfoDTO struct + BuildBranch string + BuildRevision string + BuildTag string + BuildTimestamp string + JavaVendor string + JavaVersion string + NiFiVersion string + OsArchitecture string + OsName string + OsVersion string