Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

pulseha

package

Go to main page

Versions in this module

v1

v1.1.24

Jan 15, 2021

v1.1.23

Sep 1, 2020

v1.1.22

Aug 24, 2020

Changes in this version

+ const PluginGeneral

+ const PluginHealthCheck

+ const PluginNetworking

+ var CLUSTER_REQUIRED_MESSAGE = "You must be in a configured cluster to complete this action."

+ func BringDownIPs(iface string, ips []string) error

+ func BringUpIPs(iface string, ips []string) error

+ func CanCommunicate(ctx context.Context) bool

+ func GetFailOverCountWinner(members []*rpc.MemberlistMember) string

+ func InformMLSChange()

+ func MakeLocalActive() error

+ func MakeLocalPassive()

+ func MyCaller() string

+ type CLIServer struct

+ Listener net.Listener

+ Server *Server

+ func (s *CLIServer) Config(ctx context.Context, in *rpc.PulseConfig) (*rpc.PulseConfig, error)

+ func (s *CLIServer) Create(ctx context.Context, in *rpc.PulseCreate) (*rpc.PulseCreate, error)

+ func (s *CLIServer) DeleteGroup(ctx context.Context, in *rpc.PulseGroupDelete) (*rpc.PulseGroupDelete, error)

+ func (s *CLIServer) Describe(ctx context.Context, in *rpc.PulseDescribe) (*rpc.PulseDescribe, error)

+ func (s *CLIServer) GroupAssign(ctx context.Context, in *rpc.PulseGroupAssign) (*rpc.PulseGroupAssign, error)

+ func (s *CLIServer) GroupIPAdd(ctx context.Context, in *rpc.PulseGroupAdd) (*rpc.PulseGroupAdd, error)

+ func (s *CLIServer) GroupIPRemove(ctx context.Context, in *rpc.PulseGroupRemove) (*rpc.PulseGroupRemove, error)

+ func (s *CLIServer) GroupList(ctx context.Context, in *rpc.GroupTable) (*rpc.GroupTable, error)

+ func (s *CLIServer) GroupUnassign(ctx context.Context, in *rpc.PulseGroupUnassign) (*rpc.PulseGroupUnassign, error)

+ func (s *CLIServer) Join(ctx context.Context, in *rpc.PulseJoin) (*rpc.PulseJoin, error)

+ func (s *CLIServer) Leave(ctx context.Context, in *rpc.PulseLeave) (*rpc.PulseLeave, error)

+ func (s *CLIServer) Network(ctx context.Context, in *rpc.PulseNetwork) (*rpc.PulseNetwork, error)

+ func (s *CLIServer) NewGroup(ctx context.Context, in *rpc.PulseGroupNew) (*rpc.PulseGroupNew, error)

+ func (s *CLIServer) Promote(ctx context.Context, in *rpc.PulsePromote) (*rpc.PulsePromote, error)

+ func (s *CLIServer) Remove(ctx context.Context, in *rpc.PulseRemove) (*rpc.PulseRemove, error)

+ func (s *CLIServer) Setup()

+ func (s *CLIServer) Status(ctx context.Context, in *rpc.PulseStatus) (*rpc.PulseStatus, error)

+ func (s *CLIServer) TLS(ctx context.Context, in *rpc.PulseCert) (*rpc.PulseCert, error)

+ func (s *CLIServer) Token(ctx context.Context, in *rpc.PulseToken) (*rpc.PulseToken, error)

+ type Database struct

+ Config *config.Config

+ Logging logging.Logging

+ MemberList *MemberList

+ Plugins *Plugins

+ StartDelay bool

+ StartInterval int

+ var DB *Database

+ func (d *Database) SetConfig(config *config.Config)

+ type Member struct

+ HCBusy bool

+ Hostname string

+ LastHCResponse time.Time

+ Latency string

+ Status rpc.MemberStatus_Status

+ func (m *Member) BringUpIPs(ips []string, group string) bool

+ func (m *Member) Close()

+ func (m *Member) Connect() error

+ func (m *Member) GetHCBusy() bool

+ func (m *Member) GetHostname() string

+ func (m *Member) GetLastHCResponse() time.Time

+ func (m *Member) GetLatency() string

+ func (m *Member) GetStatus() rpc.MemberStatus_Status

+ func (m *Member) Lock()

+ func (m *Member) MakeActive() bool

+ func (m *Member) MakePassive() error

+ func (m *Member) MonitorReceivedHCs() bool

+ func (m *Member) RoutineHC(data *rpc.PulseHealthCheck)

+ func (m *Member) SendHealthCheck(data *rpc.PulseHealthCheck) (interface{}, error)

+ func (m *Member) SetClient(client *client.Client)

+ func (m *Member) SetHCBusy(busy bool)

+ func (m *Member) SetHostname(hostname string)

+ func (m *Member) SetLastHCResponse(time time.Time)

+ func (m *Member) SetLatency(latency string)

+ func (m *Member) SetStatus(status rpc.MemberStatus_Status)

+ func (m *Member) Unlock()

+ type MemberList struct

+ Members []*Member

+ StopChan chan bool

+ func (m *MemberList) AddHealthCheckHandler() bool

+ func (m *MemberList) AddMember(hostname string, client *client.Client)

+ func (m *MemberList) Broadcast(funcName client.ProtoFunction, data interface{})

+ func (m *MemberList) GetActiveMember() (string, *Member)

+ func (m *MemberList) GetLocalMember() (*Member, error)

+ func (m *MemberList) GetMemberByHostname(hostname string) *Member

+ func (m *MemberList) GetNextActiveMember() (*Member, error)

+ func (m *MemberList) LoadMembers()

+ func (m *MemberList) Lock()

+ func (m *MemberList) MemberExists(hostname string) bool

+ func (m *MemberList) MemberGetStatus(hostname string) (rpc.MemberStatus_Status, error)

+ func (m *MemberList) MemberRemoveByHostname(hostname string)

+ func (m *MemberList) MonitorClientConns() bool

+ func (m *MemberList) PromoteMember(hostname string) error

+ func (m *MemberList) Reload()

+ func (m *MemberList) Reset()

+ func (m *MemberList) Setup()

+ func (m *MemberList) SyncConfig() error

+ func (m *MemberList) Unlock()

+ func (m *MemberList) Update(memberlist []*rpc.MemberlistMember)

+ type Plugin struct

+ Name string

+ Plugin interface{}

+ Type interface{}

+ Version float64

+ type PluginGen interface

+ Name func() string

+ OnMemberListStatusChange func(members []Member)

+ Run func(db *Database) error

+ Version func() float64

+ type PluginHC interface

+ Name func() string

+ Send func() (bool, bool)

+ Version func() float64

+ type PluginNet interface

+ BringDownIPs func(iface string, ips []string) error

+ BringUpIPs func(iface string, ips []string) error

+ Name func() string

+ Version func() float64

+ type Plugins struct

+ func (p *Plugins) GetGeneralPlugin() []*Plugin

+ func (p *Plugins) GetHealthCheckPlugins() []*Plugin

+ func (p *Plugins) GetNetworkingPlugin() *Plugin

+ func (p *Plugins) Load(pluginType pluginType, pluginList []*plugin.Plugin)

+ func (p *Plugins) Setup()

+ func (p *Plugins) Validate()

+ type Server struct

+ HCScheduler func()

+ Listener net.Listener

+ Server *grpc.Server

+ func (s *Server) BringDownIP(ctx context.Context, in *rpc.PulseBringIP) (*rpc.PulseBringIP, error)

+ func (s *Server) BringUpIP(ctx context.Context, in *rpc.PulseBringIP) (*rpc.PulseBringIP, error)

+ func (s *Server) ConfigSync(ctx context.Context, in *rpc.PulseConfigSync) (*rpc.PulseConfigSync, error)

+ func (s *Server) Describe(ctx context.Context, in *rpc.PulseDescribe) (*rpc.PulseDescribe, error)

+ func (s *Server) HealthCheck(ctx context.Context, in *rpc.PulseHealthCheck) (*rpc.PulseHealthCheck, error)

+ func (s *Server) Init(db *Database)

+ func (s *Server) Join(ctx context.Context, in *rpc.PulseJoin) (*rpc.PulseJoin, error)

+ func (s *Server) Leave(ctx context.Context, in *rpc.PulseLeave) (*rpc.PulseLeave, error)

+ func (s *Server) Logs(ctx context.Context, in *rpc.PulseLogs) (*rpc.PulseLogs, error)

+ func (s *Server) MakePassive(ctx context.Context, in *rpc.PulsePromote) (*rpc.PulsePromote, error)

+ func (s *Server) Promote(ctx context.Context, in *rpc.PulsePromote) (*rpc.PulsePromote, error)

+ func (s *Server) Remove(ctx context.Context, in *rpc.PulseRemove) (*rpc.PulseRemove, error)

+ func (s *Server) Setup()

+ func (s *Server) Shutdown()

v1.1.21

Aug 23, 2020

Changes in this version

+ type CertCommand struct

+ Ui cli.Ui

+ func (c *CertCommand) Help() string

+ func (c *CertCommand) Run(args []string) int

+ func (c *CertCommand) Synopsis() string

+ type ConfigCommand struct

+ Ui cli.Ui

+ func (c *ConfigCommand) Help() string

+ func (c *ConfigCommand) Run(args []string) int

+ func (c *ConfigCommand) Synopsis() string

+ type CreateCommand struct

+ Ui cli.Ui

+ func (c *CreateCommand) Help() string

+ func (c *CreateCommand) Run(args []string) int

+ func (c *CreateCommand) Synopsis() string

+ type DescribeCommand struct

+ Ui cli.Ui

+ func (c *DescribeCommand) Help() string

+ func (c *DescribeCommand) Run(args []string) int

+ func (c *DescribeCommand) Synopsis() string

+ type GroupsCommand struct

+ Ui cli.Ui

+ func (c *GroupsCommand) Add(groupName, fIPs *string, client rpc.CLIClient) int

+ func (c *GroupsCommand) Assign(groupName, nodeHostname, nodeIface *string, client rpc.CLIClient) int

+ func (c *GroupsCommand) Delete(groupName *string, client rpc.CLIClient) int

+ func (c *GroupsCommand) Help() string

+ func (c *GroupsCommand) New(groupName *string, client rpc.CLIClient) int

+ func (c *GroupsCommand) Remove(groupName, fIPs *string, client rpc.CLIClient) int

+ func (c *GroupsCommand) Run(args []string) int

+ func (c *GroupsCommand) Synopsis() string

+ func (c *GroupsCommand) Unassign(groupName, nodeHostname, nodeIface *string, client rpc.CLIClient) int

+ type JoinCommand struct

+ Ui cli.Ui

+ func (c *JoinCommand) Help() string

+ func (c *JoinCommand) Run(args []string) int

+ func (c *JoinCommand) Synopsis() string

+ type LeaveCommand struct

+ Ui cli.Ui

+ func (c *LeaveCommand) Help() string

+ func (c *LeaveCommand) Run(args []string) int

+ func (c *LeaveCommand) Synopsis() string

+ type NetworkCommand struct

+ Ui cli.Ui

+ func (c *NetworkCommand) Help() string

+ func (c *NetworkCommand) Run(args []string) int

+ func (c *NetworkCommand) Synopsis() string

+ type PromoteCommand struct

+ Ui cli.Ui

+ func (c *PromoteCommand) Help() string

+ func (c *PromoteCommand) Run(args []string) int

+ func (c *PromoteCommand) Synopsis() string

+ type RemoveCommand struct

+ Ui cli.Ui

+ func (c *RemoveCommand) Help() string

+ func (c *RemoveCommand) Run(args []string) int

+ func (c *RemoveCommand) Synopsis() string

+ type StatusCommand struct

+ Ui cli.Ui

+ func (c *StatusCommand) Help() string

+ func (c *StatusCommand) Run(args []string) int

+ func (c *StatusCommand) Synopsis() string

+ type TokenCommand struct

+ Ui cli.Ui

+ func (c *TokenCommand) Help() string

+ func (c *TokenCommand) Run(args []string) int

+ func (c *TokenCommand) Synopsis() string

+ type VersionCommand struct

+ Build string

+ Ui cli.Ui

+ Version string

+ VersionRelease string

+ func (c *VersionCommand) Help() string

+ func (c *VersionCommand) Run(_ []string) int

+ func (c *VersionCommand) Synopsis() string