Documentation ¶
Index ¶
- Constants
- Variables
- func IsWebLogicServer(url string) bool
- type Fetcher
- type HTTPFetcher
- func (h HTTPFetcher) CheckJFR(jfrName, jfrType, target string) ([]byte, error)
- func (h HTTPFetcher) CompactElasticData(journalType, nodeID string) ([]byte, error)
- func (h HTTPFetcher) ConfigureTracing(role string, tracingRatio float32) ([]byte, error)
- func (h HTTPFetcher) DumpClusterHeap(role string) ([]byte, error)
- func (h HTTPFetcher) DumpJFR(jfrName, jfrType, target, filename string) ([]byte, error)
- func (h HTTPFetcher) GetArchivedSnapshots(serviceName string) ([]byte, error)
- func (h HTTPFetcher) GetCacheMembers(serviceName, cacheName string) ([]byte, error)
- func (h HTTPFetcher) GetCachePartitions(serviceName, cacheName string) ([]byte, error)
- func (h HTTPFetcher) GetCachesSummaryJSON(serviceName string) ([]byte, error)
- func (h HTTPFetcher) GetCachesSummaryJSONAllServices() ([]byte, error)
- func (h HTTPFetcher) GetClusterConfig() ([]byte, error)
- func (h HTTPFetcher) GetClusterDescriptionJSON() ([]byte, error)
- func (h HTTPFetcher) GetClusterDetailsJSON() ([]byte, error)
- func (h HTTPFetcher) GetClusterName() string
- func (h HTTPFetcher) GetElasticDataDetails(journalType string) ([]byte, error)
- func (h HTTPFetcher) GetEnvironment(memberID string) ([]byte, error)
- func (h HTTPFetcher) GetExecutorsJSON() ([]byte, error)
- func (h HTTPFetcher) GetExtendedMemberInfoJSON(result []byte, nodeID string, tokens []string) ([][]byte, error)
- func (h HTTPFetcher) GetFederationDetails(serviceName, federationType, nodeID, participant string) ([]byte, error)
- func (h HTTPFetcher) GetFederationStatistics(serviceName, federationType string) ([]byte, error)
- func (h HTTPFetcher) GetHTTPSessionDetailsJSON() ([]byte, error)
- func (h HTTPFetcher) GetManagementJSON() ([]byte, error)
- func (h HTTPFetcher) GetMemberDetailsJSON(verbose bool) ([]byte, error)
- func (h HTTPFetcher) GetMemberOSJson(memberID string) ([]byte, error)
- func (h HTTPFetcher) GetMembersHealth() ([]byte, error)
- func (h HTTPFetcher) GetNetworkStatsJSON(nodeID string) ([]byte, error)
- func (h HTTPFetcher) GetNodeDescriptionJSON(nodeID string) ([]byte, error)
- func (h HTTPFetcher) GetPersistenceCoordinator(serviceName string) ([]byte, error)
- func (h HTTPFetcher) GetProxyConnectionsJSON(serviceName, nodeID string) ([]byte, error)
- func (h HTTPFetcher) GetProxySummaryJSON() ([]byte, error)
- func (h HTTPFetcher) GetReporterJSON(nodeID string) ([]byte, error)
- func (h HTTPFetcher) GetReportersJSON() ([]byte, error)
- func (h HTTPFetcher) GetResponseCode(requestedURL string) string
- func (h HTTPFetcher) GetScheduledDistributionsJSON(serviceName string) ([]byte, error)
- func (h HTTPFetcher) GetServiceDescriptionJSON(serviceName string) ([]byte, error)
- func (h HTTPFetcher) GetServiceDetailsJSON() ([]byte, error)
- func (h HTTPFetcher) GetServiceMembersDetailsJSON(serviceName string) ([]byte, error)
- func (h HTTPFetcher) GetServicePartitionsJSON(serviceName string) ([]byte, error)
- func (h HTTPFetcher) GetSingleMemberDetailsJSON(nodeID string) ([]byte, error)
- func (h HTTPFetcher) GetSingleServiceDetailsJSON(serviceName string) ([]byte, error)
- func (h HTTPFetcher) GetStorageDetailsJSON() ([]byte, error)
- func (h HTTPFetcher) GetThreadDump(memberID string) ([]byte, error)
- func (h HTTPFetcher) GetTopicsJSON() ([]byte, error)
- func (h HTTPFetcher) GetTopicsMembersJSON(serviceName, topicName string) ([]byte, error)
- func (h HTTPFetcher) GetTopicsSubscriberGroupsJSON(serviceName, topicName string) ([]byte, error)
- func (h HTTPFetcher) GetTopicsSubscribersJSON(serviceName, topicName string) ([]byte, error)
- func (h HTTPFetcher) GetType() string
- func (h HTTPFetcher) GetURL() string
- func (h HTTPFetcher) GetUsername() string
- func (h HTTPFetcher) GetViewCachesDetailsJSON(serviceName, viewName string) ([]byte, error)
- func (h HTTPFetcher) GetViewCachesJSON(serviceName string) ([]byte, error)
- func (h HTTPFetcher) GetViewsSummaryJSONAllServices() ([]byte, error)
- func (h HTTPFetcher) InvokeDisconnectAll(topicName, topicService, subscriberGroup string) error
- func (h HTTPFetcher) InvokeFederationOperation(serviceName, command, participant, mode string) ([]byte, error)
- func (h HTTPFetcher) InvokeResetStatistics(operation string, nodeID string, args []string) ([]byte, error)
- func (h HTTPFetcher) InvokeServiceMemberOperation(serviceName, nodeID, operation string) ([]byte, error)
- func (h HTTPFetcher) InvokeServiceOperation(serviceName, operation string) ([]byte, error)
- func (h HTTPFetcher) InvokeSnapshotOperation(serviceName, snapshotName, operation string, archived bool) ([]byte, error)
- func (h HTTPFetcher) InvokeStorageOperation(serviceName, cacheName, operation string) error
- func (h HTTPFetcher) InvokeSubscriberOperation(topicName, topicService string, subscriber int64, operation string, ...) ([]byte, error)
- func (h HTTPFetcher) IsWebLogicServer() bool
- func (h HTTPFetcher) LogClusterState(role string) ([]byte, error)
- func (h HTTPFetcher) SetCacheAttribute(memberID, serviceName, cacheName, tier, attribute string, value interface{}) ([]byte, error)
- func (h HTTPFetcher) SetExecutorAttribute(executor, attribute string, value interface{}) ([]byte, error)
- func (h HTTPFetcher) SetFederationAttribute(serviceName, attribute string, value interface{}) ([]byte, error)
- func (h HTTPFetcher) SetManagementAttribute(attribute string, value interface{}) ([]byte, error)
- func (h HTTPFetcher) SetMemberAttribute(memberID, attribute string, value interface{}) ([]byte, error)
- func (h HTTPFetcher) SetReporterAttribute(memberID, attribute string, value interface{}) ([]byte, error)
- func (h HTTPFetcher) SetServiceAttribute(memberID, serviceName, attribute string, value interface{}) ([]byte, error)
- func (h HTTPFetcher) ShutdownMember(memberID string) ([]byte, error)
- func (h HTTPFetcher) StartJFR(jfrName, directory, jfrType, target string, duration int32, ...) ([]byte, error)
- func (h HTTPFetcher) StartReporter(nodeID string) error
- func (h HTTPFetcher) StopJFR(jfrName, jfrType, target string) ([]byte, error)
- func (h HTTPFetcher) StopReporter(nodeID string) error
Constants ¶
const ( HTTP = "http" CreateSnapshot = "create snapshot" RemoveSnapshot = "remove snapshot" RemoveArchivedSnapshot = "remove archived snapshot" RecoverSnapshot = "recover snapshot" ArchiveSnapshot = "archive snapshot" RetrieveSnapshot = "retrieve snapshot" SuspendService = "suspend service" ResumeService = "resume service" StopService = "stop" StartService = "start" ShutdownService = "shutdown" ResetMembers = "members" ResetReporters = "reporters" ResetRAMJournal = "ram journal" ResetFlashJournal = "flash journal" ResetService = "service" ResetConnectionManager = "connectionManager" ResetCache = "cache" ResetFederation = "federation" ResetExecutor = "executor" JfrTypeRole = "role" JfrTypeNode = "node" JfrTypeCluster = "cluster" StopJFR = "jfrStop" DumpJFR = "jfrDump" CheckJFR = "jfrCheck" GetJFRs = "jfrCheck" WithSync = "with-sync" NoBacklog = "no-backlog" DisconnectSubscriber = "disconnect" DisconnectAll = "disconnect all" ConnectSubscriber = "connect" NotifyPopulated = "notify populated" RetrieveHeads = "retrieve current heads" RemainingMessages = "retrieve remaining messages" TruncateCache = "truncate" ClearCache = "clear" )
Variables ¶
Functions ¶
func IsWebLogicServer ¶
IsWebLogicServer returns true if the connection is of WebLogic Server format
Types ¶
type Fetcher ¶
type Fetcher interface { GetURL() string GetType() string IsWebLogicServer() bool GetUsername() string // GetClusterDetailsJSON returns cluster details in raw json. GetClusterDetailsJSON() ([]byte, error) // GetMemberDetailsJSON returns members details in raw json. verbose indicates to // retrieve all fields rather than selected fields. GetMemberDetailsJSON(verbose bool) ([]byte, error) // GetNetworkStatsJSON returns network stats in raw json. GetNetworkStatsJSON(nodeID string) ([]byte, error) // GetSingleMemberDetailsJSON returns a single members details in raw json. GetSingleMemberDetailsJSON(nodeID string) ([]byte, error) // GetExtendedMemberInfoJSON returns a single members extended info. GetExtendedMemberInfoJSON(result []byte, nodeID string, tokens []string) ([][]byte, error) // GetServiceDetailsJSON returns member details in raw json. GetServiceDetailsJSON() ([]byte, error) // GetStorageDetailsJSON returns member storage details in raw json. GetStorageDetailsJSON() ([]byte, error) // GetExecutorsJSON returns executor details in raw json. GetExecutorsJSON() ([]byte, error) // GetSingleServiceDetailsJSON returns a single service details in raw json. GetSingleServiceDetailsJSON(serviceName string) ([]byte, error) // GetScheduledDistributionsJSON returns scheduled distributions for a service. GetScheduledDistributionsJSON(serviceName string) ([]byte, error) // GetServiceDescriptionJSON returns service description. GetServiceDescriptionJSON(serviceName string) ([]byte, error) // GetNodeDescriptionJSON returns node description. GetNodeDescriptionJSON(nodeID string) ([]byte, error) // GetClusterDescriptionJSON returns cluster description. GetClusterDescriptionJSON() ([]byte, error) // GetServicePartitionsJSON returns partition information for a service. GetServicePartitionsJSON(serviceName string) ([]byte, error) // GetServiceMembersDetailsJSON returns all the service member details for a service. GetServiceMembersDetailsJSON(serviceName string) ([]byte, error) // GetCachesSummaryJSON returns caches summary json for a service. GetCachesSummaryJSON(serviceName string) ([]byte, error) // GetViewCachesJSON returns view caches summary json for a service. GetViewCachesJSON(serviceName string) ([]byte, error) // GetViewCachesDetailsJSON returns view cache details json for a service and view. GetViewCachesDetailsJSON(serviceName, viewName string) ([]byte, error) // GetCachesSummaryJSONAllServices returns summary caches details for all services. GetCachesSummaryJSONAllServices() ([]byte, error) // GetViewsSummaryJSONAllServices returns summary view caches details for all services. GetViewsSummaryJSONAllServices() ([]byte, error) // GetTopicsJSON returns the topics in a cluster. GetTopicsJSON() ([]byte, error) // GetTopicsMembersJSON returns the topics member details in a cluster. GetTopicsMembersJSON(serviceName, topicName string) ([]byte, error) // GetTopicsSubscribersJSON returns the topics subscriber details in a cluster. GetTopicsSubscribersJSON(serviceName, topicName string) ([]byte, error) // GetTopicsSubscriberGroupsJSON returns the topics subscriber group details in a cluster. GetTopicsSubscriberGroupsJSON(serviceName, topicName string) ([]byte, error) // GetProxySummaryJSON returns proxy server summary. GetProxySummaryJSON() ([]byte, error) // GetProxyConnectionsJSON returns the proxy connections for the specified service and node. GetProxyConnectionsJSON(serviceName, nodeID string) ([]byte, error) // GetThreadDump retrieves a thread dump from a member. GetThreadDump(memberID string) ([]byte, error) // ShutdownMember shuts down a member. ShutdownMember(memberID string) ([]byte, error) // GetEnvironment returns the environment for a member. GetEnvironment(memberID string) ([]byte, error) // GetClusterConfig returns the cluster operational config. GetClusterConfig() ([]byte, error) // SetMemberAttribute sets the given attribute for a member. SetMemberAttribute(memberID, attribute string, value interface{}) ([]byte, error) // SetExecutorAttribute sets the given attribute for an executor. SetExecutorAttribute(executor, attribute string, value interface{}) ([]byte, error) // SetReporterAttribute sets the given attribute for a reporter member. SetReporterAttribute(memberID, attribute string, value interface{}) ([]byte, error) // SetManagementAttribute sets the given management attribute for a cluster. SetManagementAttribute(attribute string, value interface{}) ([]byte, error) // SetCacheAttribute sets the given attribute for a cache. SetCacheAttribute(memberID, serviceName, cacheName, tier, attribute string, value interface{}) ([]byte, error) // SetServiceAttribute sets the given attribute for a service. SetServiceAttribute(memberID, serviceName, attribute string, value interface{}) ([]byte, error) // DumpClusterHeap instructs the cluster to dump the cluster heap for the role. DumpClusterHeap(role string) ([]byte, error) // ConfigureTracing instructs the cluster to configure tracing for the role or all members. ConfigureTracing(role string, tracingRatio float32) ([]byte, error) // LogClusterState instructs the cluster to log cluster state for the role. LogClusterState(role string) ([]byte, error) // GetCacheMembers retrieves cache member details. GetCacheMembers(serviceName, cacheName string) ([]byte, error) // GetCachePartitions retrieves cache partition details. GetCachePartitions(serviceName, cacheName string) ([]byte, error) // GetPersistenceCoordinator retrieves persistence coordinator details. GetPersistenceCoordinator(serviceName string) ([]byte, error) // GetMemberOSJson returns the OS information for the member. GetMemberOSJson(memberID string) ([]byte, error) // GetMembersHealth returns the health for the members in the cluster. GetMembersHealth() ([]byte, error) // GetManagementJSON returns the management information. GetManagementJSON() ([]byte, error) // GetReportersJSON returns reporters in raw json. GetReportersJSON() ([]byte, error) // GetReporterJSON returns reporter for a node in raw json. GetReporterJSON(nodeID string) ([]byte, error) // StartReporter starts the reporter on a member. StartReporter(nodeID string) error // StopReporter stops the reporter on a member. StopReporter(nodeID string) error // GetElasticDataDetails retrieves elastic data details for the type of flash or ram. GetElasticDataDetails(journalType string) ([]byte, error) // CompactElasticData compacts elastic data for a journal type and node. CompactElasticData(journalType, nodeID string) ([]byte, error) // InvokeSnapshotOperation invokes a snapshot operation against a service. InvokeSnapshotOperation(serviceName, snapshotName, operation string, archived bool) ([]byte, error) // InvokeStorageOperation invokes a storage manager operation against a service and cache InvokeStorageOperation(serviceName, cacheName, operation string) error // InvokeServiceOperation invokes a service operation such as suspend or resume. InvokeServiceOperation(serviceName, operation string) ([]byte, error) // InvokeResetStatistics invokes a reset statistics operation. InvokeResetStatistics(operation string, nodeID string, args []string) ([]byte, error) // InvokeServiceMemberOperation invokes a service operation such as start, stop, shutdown against a node. InvokeServiceMemberOperation(serviceName, nodeID, operation string) ([]byte, error) // GetArchivedSnapshots retrieves the list of archives snapshots. GetArchivedSnapshots(serviceName string) ([]byte, error) // GetHTTPSessionDetailsJSON returns Coherence*Web Http session details in raw json. GetHTTPSessionDetailsJSON() ([]byte, error) // StartJFR starts a JFR. type is "role", "cluster" or "node" and target is the role or node. StartJFR(jfrName, directory, jfrType, target string, duration int32, settingsFile string) ([]byte, error) // StopJFR stops a JFR. type is "cluster" or "node" and target is the node id if type "node". StopJFR(jfrName, jfrType, target string) ([]byte, error) // DumpJFR dumps a JFR. type is "cluster" or "node" and target is the node id if type "node". DumpJFR(jfrName, jfrType, target, filename string) ([]byte, error) // CheckJFR checks a JFR. type is "cluster" or "node" and target is the node id if type "node". CheckJFR(jfrName, jfrType, target string) ([]byte, error) // GetFederationStatistics returns federation statistics for a service and type. GetFederationStatistics(serviceName, federationType string) ([]byte, error) // GetFederationDetails returns federation statistics for a service and type and participant. GetFederationDetails(serviceName, federationType, nodeID, participant string) ([]byte, error) // InvokeFederationOperation invokes a federation operation against a service and participant. InvokeFederationOperation(serviceName, command, participant, mode string) ([]byte, error) // SetFederationAttribute sets the given attribute for a federated service. SetFederationAttribute(serviceName, attribute string, value interface{}) ([]byte, error) // InvokeSubscriberOperation invokes a subscriber operation against a topic subscriber. InvokeSubscriberOperation(topicName, topicService string, subscriber int64, operation string, args ...interface{}) ([]byte, error) // InvokeDisconnectAll invokes a disconnect all operation against a topic. InvokeDisconnectAll(topicName, topicService, subscriberGroup string) error // GetResponseCode returns the response code for the URL as a string. GetResponseCode(requestedURL string) string }
Fetcher interface contains the methods to get data for the CLI from various implementations.
func GetFetcherOrError ¶
GetFetcherOrError returns a fetcher and error
type HTTPFetcher ¶
type HTTPFetcher struct { URL string ConnectionType string WebLogicServer bool Username string ClusterName string }
HTTPFetcher is an implementation of a Fetcher to retrieve data from Management over REST.
func (HTTPFetcher) CheckJFR ¶
func (h HTTPFetcher) CheckJFR(jfrName, jfrType, target string) ([]byte, error)
CheckJFR checks a JFR. type is "cluster" or "node" and target is the node id if type "node".
func (HTTPFetcher) CompactElasticData ¶
func (h HTTPFetcher) CompactElasticData(journalType, nodeID string) ([]byte, error)
CompactElasticData compacts elastic data for a journal type and node.
func (HTTPFetcher) ConfigureTracing ¶
func (h HTTPFetcher) ConfigureTracing(role string, tracingRatio float32) ([]byte, error)
ConfigureTracing instructs the cluster to configure tracing for the role or all members
func (HTTPFetcher) DumpClusterHeap ¶
func (h HTTPFetcher) DumpClusterHeap(role string) ([]byte, error)
DumpClusterHeap instructs the cluster to dump the cluster heap for the role, role of "all" indicates all members.
func (HTTPFetcher) DumpJFR ¶
func (h HTTPFetcher) DumpJFR(jfrName, jfrType, target, filename string) ([]byte, error)
DumpJFR dumps a JFR. type is "cluster" or "node" and target is the node id if type "node".
func (HTTPFetcher) GetArchivedSnapshots ¶
func (h HTTPFetcher) GetArchivedSnapshots(serviceName string) ([]byte, error)
GetArchivedSnapshots retrieves the list of archives snapshots.
func (HTTPFetcher) GetCacheMembers ¶
func (h HTTPFetcher) GetCacheMembers(serviceName, cacheName string) ([]byte, error)
GetCacheMembers retrieves cache member details.
func (HTTPFetcher) GetCachePartitions ¶
func (h HTTPFetcher) GetCachePartitions(serviceName, cacheName string) ([]byte, error)
GetCachePartitions retrieves cache partition details.
func (HTTPFetcher) GetCachesSummaryJSON ¶
func (h HTTPFetcher) GetCachesSummaryJSON(serviceName string) ([]byte, error)
GetCachesSummaryJSON returns summary caches details for a service.
func (HTTPFetcher) GetCachesSummaryJSONAllServices ¶
func (h HTTPFetcher) GetCachesSummaryJSONAllServices() ([]byte, error)
GetCachesSummaryJSONAllServices returns summary caches details for all services.
func (HTTPFetcher) GetClusterConfig ¶
func (h HTTPFetcher) GetClusterConfig() ([]byte, error)
GetClusterConfig returns the cluster operational config.
func (HTTPFetcher) GetClusterDescriptionJSON ¶
func (h HTTPFetcher) GetClusterDescriptionJSON() ([]byte, error)
GetClusterDescriptionJSON returns cluster description.
func (HTTPFetcher) GetClusterDetailsJSON ¶
func (h HTTPFetcher) GetClusterDetailsJSON() ([]byte, error)
GetClusterDetailsJSON returns cluster details in raw json.
func (HTTPFetcher) GetClusterName ¶
func (h HTTPFetcher) GetClusterName() string
GetClusterName returns the cluster name.
func (HTTPFetcher) GetElasticDataDetails ¶
func (h HTTPFetcher) GetElasticDataDetails(journalType string) ([]byte, error)
GetElasticDataDetails retrieves elastic data details for the type of flash or ram.
func (HTTPFetcher) GetEnvironment ¶
func (h HTTPFetcher) GetEnvironment(memberID string) ([]byte, error)
GetEnvironment returns the environment for a member.
func (HTTPFetcher) GetExecutorsJSON ¶
func (h HTTPFetcher) GetExecutorsJSON() ([]byte, error)
GetExecutorsJSON returns executor details in raw json.
func (HTTPFetcher) GetExtendedMemberInfoJSON ¶
func (h HTTPFetcher) GetExtendedMemberInfoJSON(result []byte, nodeID string, tokens []string) ([][]byte, error)
GetExtendedMemberInfoJSON returns a single members extended info.
func (HTTPFetcher) GetFederationDetails ¶
func (h HTTPFetcher) GetFederationDetails(serviceName, federationType, nodeID, participant string) ([]byte, error)
GetFederationDetails returns federation statistics for a service and type and participant.
func (HTTPFetcher) GetFederationStatistics ¶
func (h HTTPFetcher) GetFederationStatistics(serviceName, federationType string) ([]byte, error)
GetFederationStatistics returns federation statistics for a service and type.
func (HTTPFetcher) GetHTTPSessionDetailsJSON ¶
func (h HTTPFetcher) GetHTTPSessionDetailsJSON() ([]byte, error)
GetHTTPSessionDetailsJSON returns Coherence*Web Http session details in raw json.
func (HTTPFetcher) GetManagementJSON ¶
func (h HTTPFetcher) GetManagementJSON() ([]byte, error)
GetManagementJSON returns the management information.
func (HTTPFetcher) GetMemberDetailsJSON ¶
func (h HTTPFetcher) GetMemberDetailsJSON(verbose bool) ([]byte, error)
GetMemberDetailsJSON returns members details in raw json. verbose indicates to retrieve all fields rather than selected fields.
func (HTTPFetcher) GetMemberOSJson ¶
func (h HTTPFetcher) GetMemberOSJson(memberID string) ([]byte, error)
GetMemberOSJson returns the OS information for the member.
func (HTTPFetcher) GetMembersHealth ¶
func (h HTTPFetcher) GetMembersHealth() ([]byte, error)
GetMembersHealth returns the health for the members in the cluster.
func (HTTPFetcher) GetNetworkStatsJSON ¶
func (h HTTPFetcher) GetNetworkStatsJSON(nodeID string) ([]byte, error)
GetNetworkStatsJSON returns network stats in raw json.
func (HTTPFetcher) GetNodeDescriptionJSON ¶
func (h HTTPFetcher) GetNodeDescriptionJSON(nodeID string) ([]byte, error)
GetNodeDescriptionJSON returns node description.
func (HTTPFetcher) GetPersistenceCoordinator ¶
func (h HTTPFetcher) GetPersistenceCoordinator(serviceName string) ([]byte, error)
GetPersistenceCoordinator retrieves persistence coordinator details.
func (HTTPFetcher) GetProxyConnectionsJSON ¶
func (h HTTPFetcher) GetProxyConnectionsJSON(serviceName, nodeID string) ([]byte, error)
GetProxyConnectionsJSON returns the proxy connections for the specified service and node.
func (HTTPFetcher) GetProxySummaryJSON ¶
func (h HTTPFetcher) GetProxySummaryJSON() ([]byte, error)
GetProxySummaryJSON returns proxy server summary.
func (HTTPFetcher) GetReporterJSON ¶
func (h HTTPFetcher) GetReporterJSON(nodeID string) ([]byte, error)
GetReporterJSON returns reporter for a node in raw json.
func (HTTPFetcher) GetReportersJSON ¶
func (h HTTPFetcher) GetReportersJSON() ([]byte, error)
GetReportersJSON returns reporters in raw json.
func (HTTPFetcher) GetResponseCode ¶
func (h HTTPFetcher) GetResponseCode(requestedURL string) string
GetResponseCode returns the response code for the URL as a string.
func (HTTPFetcher) GetScheduledDistributionsJSON ¶
func (h HTTPFetcher) GetScheduledDistributionsJSON(serviceName string) ([]byte, error)
GetScheduledDistributionsJSON returns scheduled distributions for a service.
func (HTTPFetcher) GetServiceDescriptionJSON ¶
func (h HTTPFetcher) GetServiceDescriptionJSON(serviceName string) ([]byte, error)
GetServiceDescriptionJSON returns service description.
func (HTTPFetcher) GetServiceDetailsJSON ¶
func (h HTTPFetcher) GetServiceDetailsJSON() ([]byte, error)
GetServiceDetailsJSON returns member details in raw json.
func (HTTPFetcher) GetServiceMembersDetailsJSON ¶
func (h HTTPFetcher) GetServiceMembersDetailsJSON(serviceName string) ([]byte, error)
GetServiceMembersDetailsJSON returns all the service member details for a service.
func (HTTPFetcher) GetServicePartitionsJSON ¶
func (h HTTPFetcher) GetServicePartitionsJSON(serviceName string) ([]byte, error)
GetServicePartitionsJSON returns partition information for a service.
func (HTTPFetcher) GetSingleMemberDetailsJSON ¶
func (h HTTPFetcher) GetSingleMemberDetailsJSON(nodeID string) ([]byte, error)
GetSingleMemberDetailsJSON returns a single members details in raw json.
func (HTTPFetcher) GetSingleServiceDetailsJSON ¶
func (h HTTPFetcher) GetSingleServiceDetailsJSON(serviceName string) ([]byte, error)
GetSingleServiceDetailsJSON returns a single service details in raw json.
func (HTTPFetcher) GetStorageDetailsJSON ¶
func (h HTTPFetcher) GetStorageDetailsJSON() ([]byte, error)
GetStorageDetailsJSON returns member storage details in raw json.
func (HTTPFetcher) GetThreadDump ¶
func (h HTTPFetcher) GetThreadDump(memberID string) ([]byte, error)
GetThreadDump retrieves a thread dump from a member.
func (HTTPFetcher) GetTopicsJSON ¶
func (h HTTPFetcher) GetTopicsJSON() ([]byte, error)
GetTopicsJSON returns the topics in a cluster.
func (HTTPFetcher) GetTopicsMembersJSON ¶
func (h HTTPFetcher) GetTopicsMembersJSON(serviceName, topicName string) ([]byte, error)
GetTopicsMembersJSON returns the topics member details in a cluster.
func (HTTPFetcher) GetTopicsSubscriberGroupsJSON ¶
func (h HTTPFetcher) GetTopicsSubscriberGroupsJSON(serviceName, topicName string) ([]byte, error)
GetTopicsSubscriberGroupsJSON returns the topics subscriber group details in a cluster.
func (HTTPFetcher) GetTopicsSubscribersJSON ¶
func (h HTTPFetcher) GetTopicsSubscribersJSON(serviceName, topicName string) ([]byte, error)
GetTopicsSubscribersJSON returns the topics subscriber details in a cluster.
func (HTTPFetcher) GetType ¶
func (h HTTPFetcher) GetType() string
GetType returns the connection type.
func (HTTPFetcher) GetUsername ¶
func (h HTTPFetcher) GetUsername() string
GetUsername returns the username.
func (HTTPFetcher) GetViewCachesDetailsJSON ¶
func (h HTTPFetcher) GetViewCachesDetailsJSON(serviceName, viewName string) ([]byte, error)
GetViewCachesDetailsJSON returns view cache details json for a service and view.
func (HTTPFetcher) GetViewCachesJSON ¶
func (h HTTPFetcher) GetViewCachesJSON(serviceName string) ([]byte, error)
GetViewCachesJSON returns view caches details for a service.
func (HTTPFetcher) GetViewsSummaryJSONAllServices ¶
func (h HTTPFetcher) GetViewsSummaryJSONAllServices() ([]byte, error)
GetViewsSummaryJSONAllServices returns summary view caches details for all services.
func (HTTPFetcher) InvokeDisconnectAll ¶
func (h HTTPFetcher) InvokeDisconnectAll(topicName, topicService, subscriberGroup string) error
InvokeDisconnectAll invokes a disconnect all operation against a topic.
func (HTTPFetcher) InvokeFederationOperation ¶
func (h HTTPFetcher) InvokeFederationOperation(serviceName, command, participant, mode string) ([]byte, error)
InvokeFederationOperation invokes a federation operation against a service and participant.
func (HTTPFetcher) InvokeResetStatistics ¶
func (h HTTPFetcher) InvokeResetStatistics(operation string, nodeID string, args []string) ([]byte, error)
InvokeResetStatistics invokes a reset statistics operation nodeID is either "all" for all members or a specific nodeID args[] are specific to various commands.
func (HTTPFetcher) InvokeServiceMemberOperation ¶
func (h HTTPFetcher) InvokeServiceMemberOperation(serviceName, nodeID, operation string) ([]byte, error)
InvokeServiceMemberOperation invokes a service operation such as start, stop, shutdown against a node.
func (HTTPFetcher) InvokeServiceOperation ¶
func (h HTTPFetcher) InvokeServiceOperation(serviceName, operation string) ([]byte, error)
InvokeServiceOperation invokes a service operation such as suspend or resume.
func (HTTPFetcher) InvokeSnapshotOperation ¶
func (h HTTPFetcher) InvokeSnapshotOperation(serviceName, snapshotName, operation string, archived bool) ([]byte, error)
InvokeSnapshotOperation invokes a snapshot operation against a service.
func (HTTPFetcher) InvokeStorageOperation ¶
func (h HTTPFetcher) InvokeStorageOperation(serviceName, cacheName, operation string) error
InvokeStorageOperation invokes a storage manager operation against a service and cache
func (HTTPFetcher) InvokeSubscriberOperation ¶
func (h HTTPFetcher) InvokeSubscriberOperation(topicName, topicService string, subscriber int64, operation string, args ...interface{}) ([]byte, error)
InvokeSubscriberOperation invokes a subscriber operation against a topic subscriber.
func (HTTPFetcher) IsWebLogicServer ¶
func (h HTTPFetcher) IsWebLogicServer() bool
IsWebLogicServer returns true if the connection is a WebLogic server connection.
func (HTTPFetcher) LogClusterState ¶
func (h HTTPFetcher) LogClusterState(role string) ([]byte, error)
LogClusterState instructs the cluster to log cluster state for the role.
func (HTTPFetcher) SetCacheAttribute ¶
func (h HTTPFetcher) SetCacheAttribute(memberID, serviceName, cacheName, tier, attribute string, value interface{}) ([]byte, error)
SetCacheAttribute sets the given attribute for a cache.
func (HTTPFetcher) SetExecutorAttribute ¶
func (h HTTPFetcher) SetExecutorAttribute(executor, attribute string, value interface{}) ([]byte, error)
SetExecutorAttribute sets the given attribute for an executor.
func (HTTPFetcher) SetFederationAttribute ¶
func (h HTTPFetcher) SetFederationAttribute(serviceName, attribute string, value interface{}) ([]byte, error)
SetFederationAttribute sets the given attribute for a federated service.
func (HTTPFetcher) SetManagementAttribute ¶
func (h HTTPFetcher) SetManagementAttribute(attribute string, value interface{}) ([]byte, error)
SetManagementAttribute sets the given management attribute for a cluster.
func (HTTPFetcher) SetMemberAttribute ¶
func (h HTTPFetcher) SetMemberAttribute(memberID, attribute string, value interface{}) ([]byte, error)
SetMemberAttribute sets the given attribute for a member.
func (HTTPFetcher) SetReporterAttribute ¶
func (h HTTPFetcher) SetReporterAttribute(memberID, attribute string, value interface{}) ([]byte, error)
SetReporterAttribute sets the given attribute for a reporter member.
func (HTTPFetcher) SetServiceAttribute ¶
func (h HTTPFetcher) SetServiceAttribute(memberID, serviceName, attribute string, value interface{}) ([]byte, error)
SetServiceAttribute sets the given attribute for a service.
func (HTTPFetcher) ShutdownMember ¶
func (h HTTPFetcher) ShutdownMember(memberID string) ([]byte, error)
ShutdownMember shuts down a member.
func (HTTPFetcher) StartJFR ¶
func (h HTTPFetcher) StartJFR(jfrName, directory, jfrType, target string, duration int32, settingsFile string) ([]byte, error)
StartJFR starts a JFR. type is "role", "cluster" or "node" and target is the role or node.
func (HTTPFetcher) StartReporter ¶
func (h HTTPFetcher) StartReporter(nodeID string) error
StartReporter starts the reporter on a member.
func (HTTPFetcher) StopJFR ¶
func (h HTTPFetcher) StopJFR(jfrName, jfrType, target string) ([]byte, error)
StopJFR stops a JFR. type is "cluster" or "node" and target is the node id if type "node".
func (HTTPFetcher) StopReporter ¶
func (h HTTPFetcher) StopReporter(nodeID string) error
StopReporter stops the reporter on a member.