Documentation ¶
Index ¶
- type ApplicationServerTransport
- type ConsulWorker
- type GrpcServer
- func (grpcServer *GrpcServer) CloseServer()
- func (gs *GrpcServer) DummyRuntime(ctx context.Context, incomeDummyRuntimeData *transport.DummyRuntimeData) (*transport.EmptyDummyData, error)
- func (gs *GrpcServer) IpRuleRuntime(ctx context.Context, incomeDummyRuntimeData *transport.IpRuleRuntimeData) (*transport.EmptyIpRuleData, error)
- func (gs *GrpcServer) RouteRuntime(ctx context.Context, incomeRouteRuntimeData *transport.RouteRuntimeData) (*transport.EmptyRouteData, error)
- func (grpcServer *GrpcServer) StartServer() error
- func (gs *GrpcServer) TunnelRuntime(ctx context.Context, incomeDummyRuntimeData *transport.TunnelRuntimeData) (*transport.EmptyTunnelData, error)
- type ServiceTransport
- type T1OrchFacade
- func (t1OrchFacade *T1OrchFacade) ApplyNewConfig(updatedServicesInfo map[string]*domain.ServiceInfo) error
- func (t1OrchFacade *T1OrchFacade) CreateServices(servicesForCreate map[string]*domain.ServiceInfo, id string) error
- func (t1OrchFacade *T1OrchFacade) RemoveAllConfig() error
- func (t1OrchFacade *T1OrchFacade) RemoveServices(servicesForRemove map[string]*domain.ServiceInfo, id string) error
- func (t1OrchFacade *T1OrchFacade) UpdateServices(servicesForUpdate map[string]*domain.ServiceInfo, id string) error
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
Click to show internal directories.
Click to hide internal directories.