application

package

v0.0.0-...-b5aaafc Latest Latest Go to latest Published: Jul 27, 2021 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/khannz/crispy-palm-tree

Links

Open Source Insights

Documentation ¶

Index ¶

type ApplicationServerTransport
type ConsulWorker
- func NewConsulWorker(facade *T1OrchFacade, ...) (*ConsulWorker, error)
- func (consulWorker *ConsulWorker) ConsulConfigWatch()
- func (consulWorker *ConsulWorker) JobWorker()
type GrpcServer
- func NewGrpcServer(addr string, facade *T1OrchFacade, logging *logrus.Logger) *GrpcServer
type ServiceTransport
type T1OrchFacade
- func NewT1OrchFacade(memoryWorker domain.MemoryWorker, tunnelWorker domain.TunnelWorker, ...) *T1OrchFacade

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type ApplicationServerTransport ¶

type ApplicationServerTransport struct {
	IP                 string `json:"ip"`
	Port               string `json:"port"`
	HealthcheckAddress string `json:"healthcheckAddress"`
}

ApplicationServerTransport ...

type ConsulWorker ¶

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

ConsulWorker ...

func NewConsulWorker ¶

func NewConsulWorker(facade *T1OrchFacade,
	consulAddress,
	consulSubscribePath,
	consulAppServersPath,
	serviceManifest string,
	logging *logrus.Logger) (*ConsulWorker, error)

NewConsulWorker ...

func (*ConsulWorker) ConsulConfigWatch ¶

func (consulWorker *ConsulWorker) ConsulConfigWatch()

func (*ConsulWorker) JobWorker ¶

func (consulWorker *ConsulWorker) JobWorker()

type GrpcServer ¶

type GrpcServer struct {
	transport.UnimplementedSendRuntimeServer
	// contains filtered or unexported fields
}

GrpcServer ...

func NewGrpcServer ¶

func NewGrpcServer(addr string,
	facade *T1OrchFacade,
	logging *logrus.Logger) *GrpcServer

func (*GrpcServer) CloseServer ¶

func (grpcServer *GrpcServer) CloseServer()

func (*GrpcServer) DummyRuntime ¶

func (gs *GrpcServer) DummyRuntime(ctx context.Context,
	incomeDummyRuntimeData *transport.DummyRuntimeData) (*transport.EmptyDummyData, error)

DummyRuntime ...

func (*GrpcServer) IpRuleRuntime ¶

func (gs *GrpcServer) IpRuleRuntime(ctx context.Context,
	incomeDummyRuntimeData *transport.IpRuleRuntimeData) (*transport.EmptyIpRuleData, error)

IpRuleRuntime ...

func (*GrpcServer) RouteRuntime ¶

func (gs *GrpcServer) RouteRuntime(ctx context.Context,
	incomeRouteRuntimeData *transport.RouteRuntimeData) (*transport.EmptyRouteData, error)

RouteRuntime ...

func (*GrpcServer) StartServer ¶

func (grpcServer *GrpcServer) StartServer() error

func (*GrpcServer) TunnelRuntime ¶

func (gs *GrpcServer) TunnelRuntime(ctx context.Context,
	incomeDummyRuntimeData *transport.TunnelRuntimeData) (*transport.EmptyTunnelData, error)

TunnelRuntime ...

type ServiceTransport ¶

type ServiceTransport struct {
	IP              string `json:"ip"`
	Port            string `json:"port"`
	BalanceType     string `json:"balanceType"`
	RoutingType     string `json:"routingType"`
	Protocol        string `json:"protocol"`
	HealthcheckType string `json:"healthcheckType"`
	HelloTimer      string `json:"helloTimer"`
	ResponseTimer   string `json:"responseTimer"`
	AliveThreshold  string `json:"aliveThreshold"`
	DeadThreshold   string `json:"deadThreshold"`
	Quorum          string `json:"quorum"`
	// Hysteresis      string `json:"hysteresis"`
	ApplicationServersTransport []*ApplicationServerTransport `json:"-"`
	Uri                         string                        `json:"uri"`                // only for http(s) hc types
	ValidResponseCodes          []int64                       `json:"validResponseCodes"` // only for http(s) hc types
}

ServiceTransport ...

type T1OrchFacade ¶

type T1OrchFacade struct {
	MemoryWorker      domain.MemoryWorker
	TunnelWorker      domain.TunnelWorker
	RouteWorker       domain.RouteWorker
	IpRuleWorker      domain.IpRuleWorker
	HealthcheckEntity *healthcheck.HealthcheckEntity
	GracefulShutdown  *domain.GracefulShutdown
	IDgenerator       domain.IDgenerator
	RuntimeServices   map[string]*domain.ServiceInfo
	Logging           *logrus.Logger
}

T1OrchFacade struct

func NewT1OrchFacade ¶

func NewT1OrchFacade(memoryWorker domain.MemoryWorker,
	tunnelWorker domain.TunnelWorker,
	routeWorker domain.RouteWorker,
	ipRuleWorker domain.IpRuleWorker,
	hc *healthcheck.HealthcheckEntity,
	gracefulShutdown *domain.GracefulShutdown,
	idGenerator domain.IDgenerator,
	logging *logrus.Logger) *T1OrchFacade

NewT1OrchFacade ...

func (*T1OrchFacade) ApplyNewConfig ¶

func (t1OrchFacade *T1OrchFacade) ApplyNewConfig(updatedServicesInfo map[string]*domain.ServiceInfo) error

func (*T1OrchFacade) CreateServices ¶

func (t1OrchFacade *T1OrchFacade) CreateServices(servicesForCreate map[string]*domain.ServiceInfo,
	id string) error

func (*T1OrchFacade) RemoveAllConfig ¶

func (t1OrchFacade *T1OrchFacade) RemoveAllConfig() error

func (*T1OrchFacade) RemoveServices ¶

func (t1OrchFacade *T1OrchFacade) RemoveServices(servicesForRemove map[string]*domain.ServiceInfo,
	id string) error

func (*T1OrchFacade) UpdateServices ¶

func (t1OrchFacade *T1OrchFacade) UpdateServices(servicesForUpdate map[string]*domain.ServiceInfo,
	id string) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL