Versions in this module Expand all Collapse all v0 v0.0.1 Mar 30, 2023 Changes in this version + var Configuration_Server_Upstream_Protocol_name = map[int32]string + var Configuration_Server_Upstream_Protocol_value = map[string]int32 + var File_gateway_gateway_proto protoreflect.FileDescriptor + func BuildAttributeContext(s connect.Spec, p connect.Peer, h http.Header) *attribute_context.AttributeContext + func LoadPlugins(cfgs ...*Configuration_Plugin) (cel.EnvOption, error) + func NewMultiAddr(listeners ...net.Listener) net.Addr + func NewMultiListener(listeners ...net.Listener) net.Listener + func NewServiceHandler(sd protoreflect.ServiceDescriptor, srv validate.ServiceRuleValidater, ...) (string, http.Handler) + type Configuration struct + Files *Configuration_Files + Plugins []*Configuration_Plugin + Servers []*Configuration_Server + Validate *validate.Configuration + func (*Configuration) Descriptor() ([]byte, []int) + func (*Configuration) ProtoMessage() + func (x *Configuration) GetFiles() *Configuration_Files + func (x *Configuration) GetPlugins() []*Configuration_Plugin + func (x *Configuration) GetServers() []*Configuration_Server + func (x *Configuration) GetValidate() *validate.Configuration + func (x *Configuration) ProtoReflect() protoreflect.Message + func (x *Configuration) Reset() + func (x *Configuration) String() string + type Configuration_Files struct + Imports []string + Sources []string + func (*Configuration_Files) Descriptor() ([]byte, []int) + func (*Configuration_Files) ProtoMessage() + func (x *Configuration_Files) GetImports() []string + func (x *Configuration_Files) GetSources() []string + func (x *Configuration_Files) ProtoReflect() protoreflect.Message + func (x *Configuration_Files) Reset() + func (x *Configuration_Files) String() string + type Configuration_Plugin struct + Args map[string]string + Path string + func (*Configuration_Plugin) Descriptor() ([]byte, []int) + func (*Configuration_Plugin) ProtoMessage() + func (x *Configuration_Plugin) GetArgs() map[string]string + func (x *Configuration_Plugin) GetPath() string + func (x *Configuration_Plugin) ProtoReflect() protoreflect.Message + func (x *Configuration_Plugin) Reset() + func (x *Configuration_Plugin) String() string + type Configuration_Server struct + Listen []string + Upstreams map[string]*Configuration_Server_Upstream + func (*Configuration_Server) Descriptor() ([]byte, []int) + func (*Configuration_Server) ProtoMessage() + func (x *Configuration_Server) GetListen() []string + func (x *Configuration_Server) GetUpstreams() map[string]*Configuration_Server_Upstream + func (x *Configuration_Server) ProtoReflect() protoreflect.Message + func (x *Configuration_Server) Reset() + func (x *Configuration_Server) String() string + type Configuration_Server_Upstream struct + Address string + Protocol Configuration_Server_Upstream_Protocol + Server string + func (*Configuration_Server_Upstream) Descriptor() ([]byte, []int) + func (*Configuration_Server_Upstream) ProtoMessage() + func (x *Configuration_Server_Upstream) GetAddress() string + func (x *Configuration_Server_Upstream) GetProtocol() Configuration_Server_Upstream_Protocol + func (x *Configuration_Server_Upstream) GetServer() string + func (x *Configuration_Server_Upstream) ProtoReflect() protoreflect.Message + func (x *Configuration_Server_Upstream) Reset() + func (x *Configuration_Server_Upstream) String() string + type Configuration_Server_Upstream_Protocol int32 + const Configuration_Server_Upstream_CONNECT + const Configuration_Server_Upstream_GRPC + const Configuration_Server_Upstream_GRPC_WEB + func (Configuration_Server_Upstream_Protocol) Descriptor() protoreflect.EnumDescriptor + func (Configuration_Server_Upstream_Protocol) EnumDescriptor() ([]byte, []int) + func (Configuration_Server_Upstream_Protocol) Type() protoreflect.EnumType + func (x *Configuration_Server_Upstream_Protocol) UnmarshalYAML(value *yaml.Node) error + func (x Configuration_Server_Upstream_Protocol) Enum() *Configuration_Server_Upstream_Protocol + func (x Configuration_Server_Upstream_Protocol) MarshalYAML() (interface{}, error) + func (x Configuration_Server_Upstream_Protocol) Number() protoreflect.EnumNumber + func (x Configuration_Server_Upstream_Protocol) String() string + type Linker struct + func NewLinker(ctx context.Context, filesConfig *Configuration_Files) (*Linker, error) + type MultiAddr struct + func (a *MultiAddr) Addrs() []net.Addr + func (a *MultiAddr) Network() string + func (a *MultiAddr) String() string + type MultiListener struct + func (l *MultiListener) Accept() (net.Conn, error) + func (l *MultiListener) Addr() net.Addr + func (l *MultiListener) Close() error + type Plugin interface + BuildLibrary func(args ...string) (cel.Library, error) + Name func() string + Version func() string + type Server struct + func NewServer(linker *Linker, serverCfg *Configuration_Server, opts *validate.Configuration, ...) (*Server, error) + func (s *Server) Close() error + func (s *Server) ListenAndServe() error + func (s *Server) RegisterOnShutdown(f func()) + func (s *Server) SetKeepAlivesEnabled(v bool) + func (s *Server) Shutdown(ctx context.Context) error + type Upstream struct + func NewUpstream(cfg *Configuration_Server_Upstream) (*Upstream, error) + func (u *Upstream) NewClient(md protoreflect.MethodDescriptor) *connect.Client[*dynamicpb.Message, *dynamicpb.Message]