gateway

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

type Config struct {
	EtcdEndpoints       []string      `yaml:"etcd_endpoints"`
	EtcdDialTimeout     time.Duration `yaml:"etcd_dial_timeout"`
	Namespace           string        `yaml:"namespace"`
	RoutePrefix         string        `yaml:"route_prefix"`
	HTTPAddr            string        `yaml:"http_addr"`
	GRPCServiceExcludes []string      `yaml:"grpc_service_excludes"`
	MaxRequestBodyBytes int64         `yaml:"max_request_body_bytes"`
}

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

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

type MethodDescriptor struct {
	FullMethod  string
	Package     string // proto package, e.g. "v1.auth"
	Service     string // service name, e.g. "UserService"
	Method      string // method name, e.g. "PostLogin"
	NewRequest  func() proto.Message
	NewResponse func() proto.Message
	Resolver    interface {
		protoregistry.MessageTypeResolver
		protoregistry.ExtensionTypeResolver
	}
}

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

type Route struct {
	ID           string            `json:"id"`
	Protocol     RouteProtocol     `json:"protocol,omitempty"`
	Method       string            `json:"method"`
	Path         string            `json:"path"`
	ServiceName  string            `json:"service_name"`
	GRPCMethod   string            `json:"grpc_method"`
	UpstreamPath string            `json:"upstream_path,omitempty"`
	Description  string            `json:"description"`
	Headers      map[string]string `json:"headers,omitempty"`
	Enabled      bool              `json:"enabled"`
	CreatedAt    time.Time         `json:"created_at"`
	UpdatedAt    time.Time         `json:"updated_at"`
}

type RouteProtocol string

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