Documentation
¶
Index ¶
- Variables
- type ConsulProvider
- func (p *ConsulProvider) DeregisterMember() error
- func (p *ConsulProvider) GetHealthStatus() error
- func (p *ConsulProvider) MonitorMemberStatusChanges()
- func (p *ConsulProvider) RegisterMember(clusterName string, address string, port int, knownKinds []string, ...) error
- func (p *ConsulProvider) Shutdown() error
- func (p *ConsulProvider) UpdateMemberStatusValue(statusValue cluster.MemberStatusValue) error
- func (p *ConsulProvider) UpdateTTL()
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ProviderShuttingDownError = fmt.Errorf("consul cluster provider is shutting down")
)
Functions ¶
This section is empty.
Types ¶
type ConsulProvider ¶
type ConsulProvider struct {
// contains filtered or unexported fields
}
func New ¶
func New() (*ConsulProvider, error)
func NewWithConfig ¶
func NewWithConfig(consulConfig *api.Config) (*ConsulProvider, error)
func (*ConsulProvider) DeregisterMember ¶
func (p *ConsulProvider) DeregisterMember() error
func (*ConsulProvider) GetHealthStatus ¶
func (p *ConsulProvider) GetHealthStatus() error
GetHealthStatus returns an error if the cluster health status has problems
func (*ConsulProvider) MonitorMemberStatusChanges ¶
func (p *ConsulProvider) MonitorMemberStatusChanges()
func (*ConsulProvider) RegisterMember ¶
func (p *ConsulProvider) RegisterMember(clusterName string, address string, port int, knownKinds []string, statusValue cluster.MemberStatusValue, serializer cluster.MemberStatusValueSerializer) error
func (*ConsulProvider) Shutdown ¶
func (p *ConsulProvider) Shutdown() error
func (*ConsulProvider) UpdateMemberStatusValue ¶
func (p *ConsulProvider) UpdateMemberStatusValue(statusValue cluster.MemberStatusValue) error
func (*ConsulProvider) UpdateTTL ¶
func (p *ConsulProvider) UpdateTTL()
Source Files
Click to show internal directories.
Click to hide internal directories.