Documentation ¶
Index ¶
- type AutoManagedProvider
- func (p *AutoManagedProvider) DeregisterMember() error
- func (p *AutoManagedProvider) GetHealthStatus() error
- func (p *AutoManagedProvider) MonitorMemberStatusChanges()
- func (p *AutoManagedProvider) RegisterMember(clusterName string, address string, port int, knownKinds []string, ...) error
- func (p *AutoManagedProvider) Shutdown() error
- func (p *AutoManagedProvider) UpdateMemberStatusValue(statusValue cluster.MemberStatusValue) error
- func (p *AutoManagedProvider) UpdateTTL()
- type NodeModel
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AutoManagedProvider ¶
type AutoManagedProvider struct {
// contains filtered or unexported fields
}
func NewWithConfig ¶
func NewWithConfig(refreshTTL time.Duration, autoManPort int, hosts ...string) *AutoManagedProvider
NewWithConfig creates an Automanaged Provider that connects to a all the hosts
func NewWithTesting ¶
func NewWithTesting(refreshTTL time.Duration, autoManPort int, activeProvider *echo.Echo, hosts ...string) *AutoManagedProvider
NewWithTesting creates a testable provider
func (*AutoManagedProvider) DeregisterMember ¶
func (p *AutoManagedProvider) DeregisterMember() error
DeregisterMember set the shutdown to true preventing any more TTL updates
func (*AutoManagedProvider) GetHealthStatus ¶
func (p *AutoManagedProvider) GetHealthStatus() error
GetHealthStatus returns an error if the cluster health status has problems
func (*AutoManagedProvider) MonitorMemberStatusChanges ¶
func (p *AutoManagedProvider) MonitorMemberStatusChanges()
MonitorMemberStatusChanges creates a go routine that continuously checks other members
func (*AutoManagedProvider) RegisterMember ¶
func (p *AutoManagedProvider) RegisterMember(clusterName string, address string, port int, knownKinds []string, statusValue cluster.MemberStatusValue, serializer cluster.MemberStatusValueSerializer) error
func (*AutoManagedProvider) Shutdown ¶
func (p *AutoManagedProvider) Shutdown() error
Shutdown set the shutdown to true preventing any more TTL updates
func (*AutoManagedProvider) UpdateMemberStatusValue ¶
func (p *AutoManagedProvider) UpdateMemberStatusValue(statusValue cluster.MemberStatusValue) error
func (*AutoManagedProvider) UpdateTTL ¶
func (p *AutoManagedProvider) UpdateTTL()
UpdateTTL sets up an endpoint to respond to other members
Click to show internal directories.
Click to hide internal directories.