sponge_services

Documentation

Index

• Constants
• type ServicesManager
  • func NewServicesManager(ctx context.Context, d ServicesRecorder, user, userToken string) *ServicesManager
  • func (r *ServicesManager) AddServices(s *services.Service) error
  • func (r *ServicesManager) DeleteServices(guid string) error
  • func (r *ServicesManager) ExistServices(guid string) bool
  • func (r *ServicesManager) GetServices(guid string) *services.Service
  • func (r *ServicesManager) ListServices() map[string]*services.Service
  • func (r *ServicesManager) NewWatcher() clientv3.WatchChan
  • func (r *ServicesManager) UpdateServices(s *services.Service) error
• type ServicesRecorder

Constants

const (
	ServicesSavePathPrefixFormat = "/spongeregister/superbahnManager/services/%v/"
)

Types

type ServicesManager

type ServicesManager struct {
	// contains filtered or unexported fields
}

func NewServicesManager

func NewServicesManager(ctx context.Context, d ServicesRecorder, user, userToken string) *ServicesManager

func (*ServicesManager) AddServices

func (r *ServicesManager) AddServices(s *services.Service) error

func (*ServicesManager) DeleteServices

func (r *ServicesManager) DeleteServices(guid string) error

func (*ServicesManager) ExistServices

func (r *ServicesManager) ExistServices(guid string) bool

func (*ServicesManager) GetServices

func (r *ServicesManager) GetServices(guid string) *services.Service

func (*ServicesManager) ListServices

func (r *ServicesManager) ListServices() map[string]*services.Service

func (*ServicesManager) NewWatcher

func (r *ServicesManager) NewWatcher() clientv3.WatchChan

func (*ServicesManager) UpdateServices

func (r *ServicesManager) UpdateServices(s *services.Service) error

type ServicesRecorder

type ServicesRecorder interface {
	Put(string, string) error
	Get(string) ([]byte, error)
	GetWithPrefix(string) (map[string][]byte, error)
	Del(string) error
	GetWatcher(string) clientv3.WatchChan
}