Documentation
¶
Index ¶
- type DistributedLocker
- type FusisStore
- func (s *FusisStore) AddCheck(spec types.CheckSpec) error
- func (s *FusisStore) AddDestination(svc *types.Service, dst *types.Destination) error
- func (s *FusisStore) AddService(svc *types.Service) error
- func (s *FusisStore) AddWatcher(ch chan state.State)
- func (s *FusisStore) Close() error
- func (s *FusisStore) DeleteCheck(spec types.CheckSpec) error
- func (s *FusisStore) DeleteDestination(svc *types.Service, dst *types.Destination) error
- func (s *FusisStore) DeleteService(svc *types.Service) error
- func (s *FusisStore) GetCheck(serviceID string) (*types.CheckSpec, error)
- func (s *FusisStore) GetDestinations(svc *types.Service) ([]types.Destination, error)
- func (s *FusisStore) GetService(name string) (*types.Service, error)
- func (s *FusisStore) GetServices() ([]types.Service, error)
- func (s *FusisStore) GetState() (state.State, error)
- func (s *FusisStore) Watch()
- type Store
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DistributedLocker ¶
type DistributedLocker struct {
// contains filtered or unexported fields
}
type FusisStore ¶
func (*FusisStore) AddDestination ¶
func (s *FusisStore) AddDestination(svc *types.Service, dst *types.Destination) error
func (*FusisStore) AddService ¶
func (s *FusisStore) AddService(svc *types.Service) error
AddService adds a new services to store. It validates the name uniqueness and the IPVS uniqueness by saving the IPVS key in the store, which consists in a combination of address, port and protocol.
func (*FusisStore) AddWatcher ¶
func (s *FusisStore) AddWatcher(ch chan state.State)
func (*FusisStore) Close ¶
func (s *FusisStore) Close() error
func (*FusisStore) DeleteCheck ¶
func (s *FusisStore) DeleteCheck(spec types.CheckSpec) error
func (*FusisStore) DeleteDestination ¶
func (s *FusisStore) DeleteDestination(svc *types.Service, dst *types.Destination) error
func (*FusisStore) DeleteService ¶
func (s *FusisStore) DeleteService(svc *types.Service) error
func (*FusisStore) GetCheck ¶
func (s *FusisStore) GetCheck(serviceID string) (*types.CheckSpec, error)
func (*FusisStore) GetDestinations ¶
func (s *FusisStore) GetDestinations(svc *types.Service) ([]types.Destination, error)
func (*FusisStore) GetService ¶
func (s *FusisStore) GetService(name string) (*types.Service, error)
func (*FusisStore) GetServices ¶
func (s *FusisStore) GetServices() ([]types.Service, error)
func (*FusisStore) Watch ¶
func (s *FusisStore) Watch()
type Store ¶
type Store interface {
GetState() (state.State, error)
GetServices() ([]types.Service, error)
GetService(name string) (*types.Service, error)
AddService(svc *types.Service) error
DeleteService(svc *types.Service) error
GetDestinations(svc *types.Service) ([]types.Destination, error)
AddDestination(svc *types.Service, dst *types.Destination) error
DeleteDestination(svc *types.Service, dst *types.Destination) error
AddCheck(check types.CheckSpec) error
GetCheck(serviceID string) (*types.CheckSpec, error)
DeleteCheck(check types.CheckSpec) error
AddWatcher(ch chan state.State)
Watch()
Close() error
}
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.