spec

package

Go to main page

Versions in this module

v1

v1.5.3

Jun 28, 2022

Changes in this version

type Admin

+ WorkerSpec *WorkerSpec

+ type EgressServerSpec struct

+ KeepAlive bool

+ KeepAliveTimeout string

+ type IngressServerSpec struct

+ KeepAlive bool

+ KeepAliveTimeout string

+ type WorkerSpec struct

+ Egress EgressServerSpec

+ Ingress IngressServerSpec

v1.5.2

May 10, 2022

v1.5.1

Apr 6, 2022

Changes in this version

type Admin

+ MonitorMTLS *MonitorMTLS

type GlobalTransmission

+ MomitorMTLS *MTLSTransmission

+ type MTLSTransmission struct

+ CaCertBase64 string

+ CertBase64 string

+ KeyBase64 string

+ type MonitorCert struct

+ CertBase64 string

+ KeyBase64 string

+ Services []string

+ type MonitorMTLS struct

+ CaCertBase64 string

+ Certs []*MonitorCert

+ Enabled bool

+ Password string

+ ReporterAppendType string

+ URL string

+ Username string

v1.5.0

Mar 3, 2022

Changes in this version

type Admin

+ AgentInitializerImageName string

+ ImagePullPolicy string

+ ImageRegistryURL string

+ Log4jConfigName string

+ SidecarImageName string

v1.4.1

Jan 7, 2022

Changes in this version

+ type GlobalTransmission struct

+ Headers []string

type Service

+ func (s *Service) IngressControllerPipelineName() string

+ func (s *Service) SidecarIngressPipelineName() string

v1.4.0

Dec 7, 2021

Changes in this version

+ const ServiceCanaryHeaderKey

+ var NoopServiceSelector = &ServiceSelector

type Service

+ func (s *Service) IngressControllerPipelineSpec(instanceSpecs []*ServiceInstanceSpec, canaries []*ServiceCanary, ...) (*supervisor.Spec, error)

+ func (s *Service) SidecarEgressHTTPServerSpec() (*supervisor.Spec, error)

+ func (s *Service) SidecarEgressPipelineSpec(instanceSpecs []*ServiceInstanceSpec, canaries []*ServiceCanary, ...) (*supervisor.Spec, error)

+ func (s *Service) SidecarIngressHTTPServerSpec(cert, rootCert *Certificate) (*supervisor.Spec, error)

+ func (s *Service) SidecarIngressPipelineSpec(applicationPort uint32) (*supervisor.Spec, error)

+ type ServiceCanary struct

+ Name string

+ Priority int

+ Selector *ServiceSelector

+ TrafficRules *TrafficRules

+ func (sc ServiceCanary) Validate() error

+ type ServiceSelector struct

+ MatchInstanceLabels map[string]string

+ MatchServices []string

+ func (s *ServiceSelector) MatchInstance(serviceName string, instancelabels map[string]string) bool

+ func (s *ServiceSelector) MatchService(serviceName string) bool

+ type TrafficRules struct

+ Headers map[string]*urlrule.StringMatch

+ func (tr *TrafficRules) Clone() *TrafficRules

v1.3.2

Nov 8, 2021

Changes in this version

type Admin

+ CleanExternalRegistry bool

+ type HTTPMatch struct

+ Methods []string

+ Name string

+ PathRegex string

+ type HTTPRouteGroup struct

+ Matches []HTTPMatch

+ Name string

+ type IdentityBindingSubject struct

+ Kind string

+ Name string

+ type TrafficTarget struct

+ Destination IdentityBindingSubject

+ Name string

+ Rules []TrafficTargetRule

+ Sources []IdentityBindingSubject

+ type TrafficTargetRule struct

+ Kind string

+ Matches []string

+ Name string

v1.3.1

Oct 20, 2021

Changes in this version

+ const CertProviderSelfSign

+ const DefaultCommonName

+ const IngressControllerName

+ const PodEnvApplicationIP

+ const PodEnvHostname

+ const SecurityLevelPermissive

+ const SecurityLevelStrict

type Admin

+ Security *Security

+ func (a Admin) EnablemTLS() bool

+ type Certificate struct

+ CertBase64 string

+ HOST string

+ IP string

+ KeyBase64 string

+ ServiceName string

+ SignTime string

+ TTL string

type CustomResource

+ func (cr *CustomResource) UnmarshalYAML(unmarshal func(interface{}) error) error

+ type DynamicObject map[string]interface

+ func (do *DynamicObject) UnmarshalYAML(unmarshal func(interface{}) error) error

+ type Security struct

+ AppCertTTL string

+ CertProvider string

+ MTLSMode string

+ RootCertTTL string

v1.3.0

Oct 13, 2021

Changes in this version

type Admin

+ ExternalServiceRegistry string

+ type CustomResource map[string]interface

+ func (cr CustomResource) Kind() string

+ func (cr CustomResource) Name() string

+ type CustomResourceKind struct

+ JSONSchema string

+ Name string

+ type Mock struct

+ Enabled bool

+ Rules []*mock.Rule

type Service

+ Mock *Mock

+ RegistryName string

+ func (s *Service) Runnable() bool

type ServiceInstanceSpec

+ RegistryName string

+ func (s *ServiceInstanceSpec) Key() string

v1.2.1

Aug 27, 2021

v1.2.0

Aug 4, 2021

v1.1.0

Jul 16, 2021

Changes in this version

type Service

+ func (s *Service) BackendName() string

v1.0.1

Jun 29, 2021

Changes in this version

+ const ServiceStatusOutOfService

+ const ServiceStatusUp

v1.0.0

Jun 1, 2021

Changes in this version

+ const GlobalTenant

+ const HeartbeatInterval

+ const IngressPort

+ const RegistryTypeConsul

+ const RegistryTypeEureka

+ const RegistryTypeNacos

+ const SerivceStatusOutOfSerivce

+ const SerivceStatusUp

+ const WorkerAPIPort

+ var ErrAlreadyRegistered = fmt.Errorf("service already registered")

+ var ErrNoRegisteredYet = fmt.Errorf("service not registered yet")

+ var ErrParamNotMatch = fmt.Errorf("param in url and body's spec not matched")

+ var ErrServiceNotFound = fmt.Errorf("can't find service in its tenant or in global tenant")

+ var ErrServiceNotavailable = fmt.Errorf("can't find service available instances")

+ func IngressHTTPServerSpec(port int, rules []*IngressRule) (*supervisor.Spec, error)

+ type Admin struct

+ APIPort int

+ HeartbeatInterval string

+ IngressPort int

+ RegistryType string

+ func (a Admin) Validate() error

+ type Canary struct

+ CanaryRules []*CanaryRule

+ type CanaryRule struct

+ Headers map[string]*urlrule.StringMatch

+ ServiceInstanceLabels map[string]string

+ URLs []*urlrule.URLRule

+ type GlobalCanaryHeaders struct

+ ServiceHeaders map[string][]string

+ type Ingress struct

+ Name string

+ Rules []IngressRule

+ type IngressPath struct

+ Backend string

+ Path string

+ RewriteTarget string

+ type IngressRule struct

+ Host string

+ Paths []IngressPath

+ type LoadBalance = proxy.LoadBalance

+ type Observability struct

+ Metrics *ObservabilityMetrics

+ OutputServer *ObservabilityOutputServer

+ Tracings *ObservabilityTracings

+ type ObservabilityMetrics struct

+ Access ObservabilityMetricsDetail

+ Enabled bool

+ JdbcConnection ObservabilityMetricsDetail

+ JdbcStatement ObservabilityMetricsDetail

+ JvmGC ObservabilityMetricsDetail

+ JvmMemory ObservabilityMetricsDetail

+ Kafka ObservabilityMetricsDetail

+ Md5Dictionary ObservabilityMetricsDetail

+ Rabbit ObservabilityMetricsDetail

+ Redis ObservabilityMetricsDetail

+ Request ObservabilityMetricsDetail

+ type ObservabilityMetricsDetail struct

+ Enabled bool

+ Interval int

+ Topic string

+ type ObservabilityOutputServer struct

+ BootstrapServer string

+ Enabled bool

+ Timeout int

+ type ObservabilityTracings struct

+ Enabled bool

+ Jdbc ObservabilityTracingsDetail

+ Kafka ObservabilityTracingsDetail

+ Output ObservabilityTracingsOutputConfig

+ Rabbit ObservabilityTracingsDetail

+ Redis ObservabilityTracingsDetail

+ RemoteInvoke ObservabilityTracingsDetail

+ Request ObservabilityTracingsDetail

+ SampleByQPS int

+ type ObservabilityTracingsDetail struct

+ Enabled bool

+ ServicePrefix string

+ type ObservabilityTracingsOutputConfig struct

+ Enabled bool

+ MessageMaxBytes int

+ MessageTimeout int

+ QueuedMaxSize int

+ QueuedMaxSpans int

+ ReportThread int

+ Topic string

+ type Resilience struct

+ CircuitBreaker *circuitbreaker.Spec

+ RateLimiter *ratelimiter.Spec

+ Retryer *retryer.Spec

+ TimeLimiter *timelimiter.Spec

+ type Service struct

+ Canary *Canary

+ LoadBalance *LoadBalance

+ Name string

+ Observability *Observability

+ RegisterTenant string

+ Resilience *Resilience

+ Sidecar *Sidecar

+ func (s *Service) ApplicationEndpoint(port uint32) string

+ func (s *Service) EgressEndpoint() string

+ func (s *Service) EgressHTTPServerName() string

+ func (s *Service) EgressHandlerName() string

+ func (s *Service) EgressPipelineName() string

+ func (s *Service) IngressEndpoint() string

+ func (s *Service) IngressHTTPServerName() string

+ func (s *Service) IngressHandlerName() string

+ func (s *Service) IngressPipelineName() string

+ func (s *Service) IngressPipelineSpec(instanceSpecs []*ServiceInstanceSpec) (*supervisor.Spec, error)

+ func (s *Service) SideCarEgressHTTPServerSpec() (*supervisor.Spec, error)

+ func (s *Service) SideCarEgressPipelineSpec(instanceSpecs []*ServiceInstanceSpec) (*supervisor.Spec, error)

+ func (s *Service) SideCarIngressHTTPServerSpec() (*supervisor.Spec, error)

+ func (s *Service) SideCarIngressPipelineSpec(applicationPort uint32) (*supervisor.Spec, error)

+ func (s *Service) UniqueCanaryHeaders() []string

+ type ServiceInstanceSpec struct

+ IP string

+ InstanceID string

+ Labels map[string]string

+ Port uint32

+ RegistryTime string

+ ServiceName string

+ Status string

+ type ServiceInstanceStatus struct

+ InstanceID string

+ LastHeartbeatTime string

+ ServiceName string

+ type Sidecar struct

+ Address string

+ DiscoveryType string

+ EgressPort int

+ EgressProtocol string

+ IngressPort int

+ IngressProtocol string

+ type Tenant struct

+ CreatedAt string

+ Description string

+ Name string

+ Services []string

Other modules containing this package

github.com/megaease/easegress/v2

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