fetcher

package
v0.0.0-...-b7e2043 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 19, 2024 License: UPL-1.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source
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

View Source
var (
	DebugEnabled           bool
	IgnoreInvalidCerts     bool
	RequestTimeout         int32
	Logger                 *zap.Logger
	UnableToFindClusterMsg string
	ReadPassStdin          bool
)

Functions

func IsWebLogicServer

func IsWebLogicServer(url string) bool

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

func GetFetcherOrError(connectionType, url, username, clusterName string) (Fetcher, error)

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) GetURL

func (h HTTPFetcher) GetURL() string

GetURL returns the URL.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL