multiplexer

Apr 8, 2021

Changes in this version

+ type Server struct

+ func NewServer(port string, timeout time.Duration) (*Server, error)

+ func (s *Server) ServeHTTP(ctx context.Context, srv *http.Server) error

+ func (s *Server) ServeHTTPHandler(ctx context.Context, handler http.Handler) error

Oct 2, 2020

Changes in this version

+ type HandlerFactory func(server http.Handler, selectors ...Selector) Handler

Oct 1, 2020

Changes in this version

+ const PubSubMetaMessageID

+ const PubSubMetaPublishTime

+ const PubSubMetaSubscription

+ const PubSubQueryAuthorization

+ const PubSubQueryToken

+ func PubSubAttributeHeader(attr string) string

+ func PubSubMetaAttributeHeader(attr PubSubMetaAttribute) string

+ func PubSubQueryHeader(param PubSubQueryParam) string

+ type PubSubMetaAttribute string

+ type PubSubQueryParam string

Sep 30, 2020

Changes in this version

+ var ErrNoHandlerFulfilled = errors.New("no handler was fulfilled for your request")

+ func InterceptPubSubRequest(r *http.Request) (*http.Request, error)

+ func IsGRPCRequest(r *http.Request) bool

+ func IsPubSubRequest(r *http.Request) bool

+ func Make(server *http2.Server, handlers ...Handler) http.Handler

+ type Handler func(http.ResponseWriter, *http.Request) bool

+ func GRPCHandler(server *grpc.Server, selectors ...Selector) Handler

+ func GRPCWebTextHandler(server *grpcweb.WrappedGrpcServer, selectors ...Selector) Handler

+ func HTTPHandler(handler http.Handler, selectors ...Selector) Handler

+ func PubSubHandler(handler http.Handler, selectors ...Selector) Handler

+ type PubSubMessage struct

+ Attributes map[string]string

+ Data []byte

+ MessageID string

+ OrderingKey string

+ PublishTime string

+ type PushMessage struct

+ Message *PubSubMessage

+ Subscription string

+ type Selector func(*http.Request) bool

+ func OrSelector(selectors ...Selector) Selector