server

package

v0.0.0-...-8444db5 Latest Latest Go to latest Published: Jan 18, 2022 License: AGPL-3.0 Imports: 19 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

const GatewayHeaderKey = "X-Arcad-Gateway"

View Source

const (
	ServiceName service.Name = "tunnel-server"
)

View Source

var (
	ErrKeyNotFound           = errors.New("key not found")
	ErrUnexpectedStoredValue = errors.New("unexpected stored value")
)

func AddGatewayHeader(r *http.Request)

func HasGatewayHeader(r *http.Request) bool

func ServiceProvider(funcs ...tunnel.ServerConfigFunc) service.Provider

type Cache interface {
	Get(key string) ([]byte, error)
	Has(key string) bool
	Store(key string, data []byte) error
}

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

func NewClientRegistry() *ClientRegistry

func (r *ClientRegistry) Add(clientID, remoteAddr string, rc *tunnel.RemoteClient)

func (r *ClientRegistry) Get(clientID string) *tunnel.RemoteClient

func (r *ClientRegistry) RemoveByRemoteAddr(remoteAddr string)

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

func NewETagCachingTransport(upstream http.RoundTripper, maxSize int64, ttl, refreshTimeout time.Duration) *EtagCachingTransport

func (t *EtagCachingTransport) RoundTrip(req *http.Request) (*http.Response, error)

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

func NewMemoryCache() *MemoryCache

func (c *MemoryCache) Get(key string) ([]byte, error)

func (c *MemoryCache) Has(key string) bool

func (c *MemoryCache) Store(key string, data []byte) error

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

func From(container *service.Container) (*Service, error)

From retrieves the gateway server service in the given service container.

func Must(container *service.Container) *Service

Must retrieves the gateway server in the given service container or panic otherwise.

func (s *Service) Clients() *ClientRegistry

func (s *Service) Server() *tunnel.Server