server

Documentation

Index

• Constants
• Variables
• func CanAccessPath(requestPath string, caps []Capabilities, accessType string) bool
• func CheckRequestPermissions(localClient *tailscale.LocalClient, r *http.Request, accessType string) (*apitype.WhoIsResponse, string, error)
• func CheckRequestPermissionsHandler(localClient *tailscale.LocalClient, accessType string, handler http.Handler) http.Handler
• func GetValueByPath(store map[string]interface{}, requestPath string) (interface{}, error)
• type ACLMiddleware
  • func (m *ACLMiddleware) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type Capabilities

Constants

const (
	WhoisKey    contextKey = "whois"
	RemoteIPKey contextKey = "remoteIP"
)

const PeerCapName = "github.com/josh/datajar-server"

Variables

var MetricsHandler = promhttp.HandlerFor(
	MetricsRegistry,
	promhttp.HandlerOpts{},
)

var MetricsRegistry = prometheus.NewRegistry()

var ReadsTotal = promauto.With(MetricsRegistry).NewCounterVec(
	prometheus.CounterOpts{
		Name: "datajar_reads_total",
		Help: "Tracks the number of Data Jar reads.",
	}, []string{"hostname", "ip", "path"},
)

var UnauthorizedTotal = promauto.With(MetricsRegistry).NewCounterVec(
	prometheus.CounterOpts{
		Name: "datajar_unauthorized_total",
		Help: "Tracks the number of unauthorized Data Jar requests.",
	}, []string{"hostname", "ip", "path"},
)

var WritesTotal = promauto.With(MetricsRegistry).NewCounterVec(
	prometheus.CounterOpts{
		Name: "datajar_writes_total",
		Help: "Tracks the number of Data Jar writes.",
	}, []string{"hostname", "ip", "path"},
)

Functions

func CanAccessPath

func CanAccessPath(requestPath string, caps []Capabilities, accessType string) bool

func CheckRequestPermissions

func CheckRequestPermissions(localClient *tailscale.LocalClient, r *http.Request, accessType string) (*apitype.WhoIsResponse, string, error)

func CheckRequestPermissionsHandler

func CheckRequestPermissionsHandler(localClient *tailscale.LocalClient, accessType string, handler http.Handler) http.Handler

func GetValueByPath

func GetValueByPath(store map[string]interface{}, requestPath string) (interface{}, error)

Given a HTTP request path, traverse the store and return the value at that path.

Types

type ACLMiddleware

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

func (*ACLMiddleware) ServeHTTP

func (m *ACLMiddleware) ServeHTTP(w http.ResponseWriter, r *http.Request)

type Capabilities

type Capabilities struct {
	Read    []string `json:"read"`
	Write   []string `json:"write"`
	Metrics bool     `json:"metrics"`
}