application

Documentation

Index

• type AddApplicationServersRequest
• type AllServices
• type ApplicationServer
• type Authorization
  • func NewAuthorization(mainSecret, mainSecretForRefresh string, credentials map[string]string, ...) *Authorization
• type BalancerFacade
  • func NewBalancerFacade(locker *domain.Locker, cacheStorage *portadapter.StorageEntity, ...) *BalancerFacade
  • func (balancerFacade *BalancerFacade) AddApplicationServers(addApplicationServersRequest *Service, addApplicationServersRequestID string) (*Service, error)
  • func (balancerFacade *BalancerFacade) DisableRemoveService(serviceConfigFromStorage *domain.ServiceInfo, isMockMode bool, id string) error
  • func (balancerFacade *BalancerFacade) DisableRuntimeSettings(isMockMode bool, id string) error
  • func (balancerFacade *BalancerFacade) GetServiceState(ip, port, getServiceRequestID string) (*Service, error)
  • func (balancerFacade *BalancerFacade) GetServices(getNWBServicesID string) ([]*domain.ServiceInfo, error)
  • func (balancerFacade *BalancerFacade) InitializeCreateService(serviceConfigFromStorage *domain.ServiceInfo, id string) error
  • func (balancerFacade *BalancerFacade) InitializeRuntimeSettings(id string) error
  • func (balancerFacade *BalancerFacade) ModifyService(modifyService *Service, modifyServiceID string) (*Service, error)
  • func (balancerFacade *BalancerFacade) NewService(newService *Service, newServiceID string) (*Service, error)
  • func (balancerFacade *BalancerFacade) RemoveApplicationServers(removeApplicationServersRequest *Service, ...) (*Service, error)
  • func (balancerFacade *BalancerFacade) RemoveService(ip, port, newNWBRequestID string) error
• type LoginRequest
• type LoginResponseError
• type LoginResponseOkay
• type RemoveApplicationServersRequest
• type RestAPIstruct
  • func NewRestAPIentity(ip, port string, authorization *Authorization, balancerFacade *BalancerFacade, ...) *RestAPIstruct
  • func (restAPI *RestAPIstruct) GracefulShutdownRestAPI(gracefulShutdownCommandForRestAPI, restAPIisDone chan struct{})
  • func (restAPI *RestAPIstruct) UpRestAPI()
• type Service

Types

type AddApplicationServersRequest

type AddApplicationServersRequest struct {
	IP                 string               `json:"serviceIP" validate:"ipv4" example:"1.1.1.1"`
	Port               string               `json:"servicePort" validate:"required" example:"1111"`
	ApplicationServers []*ApplicationServer `json:"applicationServers" validate:"required,dive,required"`
}

AddApplicationServersRequest ...

type AllServices

type AllServices struct {
	Services []*Service `json:"services"`
}

type ApplicationServer

type ApplicationServer struct {
	IP                  string `json:"ip" validate:"ipv4" example:"1.1.1.1"`
	Port                string `json:"port" validate:"required" example:"1111"`
	IsUp                bool   `json:"isUp,omitempty" swagger:"ignoreParam"`
	HCAddress           string `json:"hcAddress" validate:"required" example:"http://1.1.1.1:1234"`
	ExampleBashCommands string `json:"exampleBashCommands,omitempty" swagger:"ignoreParam"`
}

type Authorization

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

Authorization ...

func NewAuthorization

func NewAuthorization(mainSecret, mainSecretForRefresh string, credentials map[string]string, expireToken, expireTokenForRefresh time.Duration) *Authorization

NewAuthorization ...

type BalancerFacade

type BalancerFacade struct {
	Locker            *domain.Locker
	CacheStorage      *portadapter.StorageEntity // so dirty
	PersistentStorage *portadapter.StorageEntity // so dirty
	TunnelConfig      domain.TunnelMaker
	HeathcheckEntity  *healthcheck.HeathcheckEntity
	CommandGenerator  domain.CommandGenerator
	GracefulShutdown  *domain.GracefulShutdown
	IDgenerator       domain.IDgenerator
	Logging           *logrus.Logger
}

BalancerFacade struct

func NewBalancerFacade

func NewBalancerFacade(locker *domain.Locker,
	cacheStorage *portadapter.StorageEntity,
	persistentStorage *portadapter.StorageEntity,
	tunnelConfig domain.TunnelMaker,
	hc *healthcheck.HeathcheckEntity,
	commandGenerator domain.CommandGenerator,
	gracefulShutdown *domain.GracefulShutdown,
	idGenerator domain.IDgenerator,
	logging *logrus.Logger) *BalancerFacade

NewBalancerFacade ...

func (*BalancerFacade) AddApplicationServers

func (balancerFacade *BalancerFacade) AddApplicationServers(addApplicationServersRequest *Service,
	addApplicationServersRequestID string) (*Service, error)

AddApplicationServers ...

func (*BalancerFacade) DisableRemoveService

func (balancerFacade *BalancerFacade) DisableRemoveService(serviceConfigFromStorage *domain.ServiceInfo,
	isMockMode bool,
	id string) error

DisableRemoveService ...

func (*BalancerFacade) DisableRuntimeSettings

func (balancerFacade *BalancerFacade) DisableRuntimeSettings(isMockMode bool, id string) error

DisableRuntimeSettings ...

func (*BalancerFacade) GetServiceState

func (balancerFacade *BalancerFacade) GetServiceState(ip, port, getServiceRequestID string) (*Service, error)

GetServiceState ...

func (*BalancerFacade) GetServices

func (balancerFacade *BalancerFacade) GetServices(getNWBServicesID string) ([]*domain.ServiceInfo, error)

GetServices ...

func (*BalancerFacade) InitializeCreateService

func (balancerFacade *BalancerFacade) InitializeCreateService(serviceConfigFromStorage *domain.ServiceInfo, id string) error

InitializeCreateService ...

func (*BalancerFacade) InitializeRuntimeSettings

func (balancerFacade *BalancerFacade) InitializeRuntimeSettings(id string) error

InitializeRuntimeSettings ...

func (*BalancerFacade) ModifyService

func (balancerFacade *BalancerFacade) ModifyService(modifyService *Service,
	modifyServiceID string) (*Service, error)

ModifyService ...

func (*BalancerFacade) NewService

func (balancerFacade *BalancerFacade) NewService(newService *Service,
	newServiceID string) (*Service, error)

NewService ...

func (*BalancerFacade) RemoveApplicationServers

func (balancerFacade *BalancerFacade) RemoveApplicationServers(removeApplicationServersRequest *Service,
	removeApplicationServersRequestID string) (*Service, error)

RemoveApplicationServers ...

func (*BalancerFacade) RemoveService

func (balancerFacade *BalancerFacade) RemoveService(ip, port, newNWBRequestID string) error

RemoveService ...

type LoginRequest

type LoginRequest struct {
	User     string `json:"user" validate:"required" example:"Sneshana-IE"`
	Password string `json:"password" validate:"required" example:"secret-password"`
}

LoginRequest ...

type LoginResponseError

type LoginResponseError struct {
	Error string `json:"error"`
}

LoginResponseError ...

type LoginResponseOkay

type LoginResponseOkay struct {
	AccessToken string `json:"accessToken"`
}

LoginResponseOkay ...

type RemoveApplicationServersRequest

type RemoveApplicationServersRequest struct {
	IP                 string               `json:"serviceIP" validate:"ipv4" example:"1.1.1.1"`
	Port               string               `json:"servicePort" validate:"required" example:"1111"`
	ApplicationServers []*ApplicationServer `json:"applicationServers" validate:"required,dive,required"`
}

RemoveApplicationServersRequest ...

type RestAPIstruct

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

RestAPIstruct restapi entity

func NewRestAPIentity

func NewRestAPIentity(ip, port string, authorization *Authorization, balancerFacade *BalancerFacade, logger *logrus.Logger) *RestAPIstruct

NewRestAPIentity ...

func (*RestAPIstruct) GracefulShutdownRestAPI

func (restAPI *RestAPIstruct) GracefulShutdownRestAPI(gracefulShutdownCommandForRestAPI, restAPIisDone chan struct{})

GracefulShutdownRestAPI ...

func (*RestAPIstruct) UpRestAPI

func (restAPI *RestAPIstruct) UpRestAPI()

UpRestAPI ...

type Service

type Service struct {
	IP                    string               `json:"ip" validate:"ipv4" swagger:"ignoreParam"`
	Port                  string               `json:"port" validate:"required" swagger:"ignoreParam"`
	IsUp                  bool                 `json:"isUp,omitempty" swagger:"ignoreParam"`
	BalanceType           string               `json:"balanceType" validate:"required" example:"rr"`
	RoutingType           string               `json:"routingType" validate:"required" example:"masquerading,tunneling"`
	Protocol              string               `json:"protocol" validate:"required" example:"tcp,udp"`
	AlivedAppServersForUp int                  `json:"alivedAppServersForUp" validate:"required,gt=0,lte=100"`
	HCType                string               `json:"hcType" validate:"required" example:"tcp"`
	HCRepeat              time.Duration        `json:"hcRepeat" validate:"required" example:"3000000000"`
	HCTimeout             time.Duration        `json:"hcTimeout" validate:"required" example:"1000000000"`
	HCNearFieldsMode      bool                 `json:"hcNearFieldsMode,omitempty"`
	HCUserDefinedData     map[string]string    `json:"hcUserDefinedData,omitempty"`
	HCRetriesForUP        int                  `json:"hcRetriesForUP" validate:"required,gt=0" example:"3"`
	HCRetriesForDown      int                  `json:"hcRetriesForDown" validate:"required,gt=0" example:"10"`
	ApplicationServers    []*ApplicationServer `json:"applicationServers" validate:"required,dive,required"`
}