knotserver

Documentation

Index

• Variables
• func Command() *cli.Command
• func Internal(ctx context.Context, c *config.Config, db *db.DB, e *rbac.Enforcer, ...) http.Handler
• func Run(ctx context.Context, cmd *cli.Command) error
• func Setup(ctx context.Context, c *config.Config, db *db.DB, e *rbac.Enforcer, ...) (http.Handler, error)
• func TID() string
• type InternalHandle
  • func (h *InternalHandle) Guard(w http.ResponseWriter, r *http.Request)
  • func (h *InternalHandle) InternalKeys(w http.ResponseWriter, r *http.Request)
  • func (h *InternalHandle) PostReceiveHook(w http.ResponseWriter, r *http.Request)
  • func (h *InternalHandle) PushAllowed(w http.ResponseWriter, r *http.Request)
• type Knot
  • func (h *Knot) CORS(next http.Handler) http.Handler
  • func (h *Knot) Events(w http.ResponseWriter, r *http.Request)
  • func (h *Knot) InfoRefs(w http.ResponseWriter, r *http.Request)
  • func (h *Knot) ReceivePack(w http.ResponseWriter, r *http.Request)
  • func (h *Knot) RejectPush(w http.ResponseWriter, r *http.Request, unqualifiedRepoName string)
  • func (h *Knot) RequestLogger(next http.Handler) http.Handler
  • func (h *Knot) Router() http.Handler
  • func (h *Knot) UploadPack(w http.ResponseWriter, r *http.Request)
  • func (h *Knot) XrpcRouter() http.Handler
• type PushOptions

Variables

var TIDClock = syntax.NewTIDClock(0)

Functions

func Command

func Command() *cli.Command

func Internal

func Internal(ctx context.Context, c *config.Config, db *db.DB, e *rbac.Enforcer, n *notifier.Notifier) http.Handler

func Run

func Run(ctx context.Context, cmd *cli.Command) error

func Setup

func Setup(ctx context.Context, c *config.Config, db *db.DB, e *rbac.Enforcer, jc *jetstream.JetstreamClient, n *notifier.Notifier) (http.Handler, error)

func TID

func TID() string

Types

type InternalHandle

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

func (*InternalHandle) Guard

func (h *InternalHandle) Guard(w http.ResponseWriter, r *http.Request)

response in text/plain format the body will be qualified repository path on success/push-denied or an error message when process failed

func (*InternalHandle) InternalKeys

func (h *InternalHandle) InternalKeys(w http.ResponseWriter, r *http.Request)

func (*InternalHandle) PostReceiveHook

func (h *InternalHandle) PostReceiveHook(w http.ResponseWriter, r *http.Request)

func (*InternalHandle) PushAllowed

func (h *InternalHandle) PushAllowed(w http.ResponseWriter, r *http.Request)

type Knot

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

func (*Knot) CORS

func (h *Knot) CORS(next http.Handler) http.Handler

func (*Knot) Events

func (h *Knot) Events(w http.ResponseWriter, r *http.Request)

func (*Knot) InfoRefs

func (h *Knot) InfoRefs(w http.ResponseWriter, r *http.Request)

func (*Knot) ReceivePack

func (h *Knot) ReceivePack(w http.ResponseWriter, r *http.Request)

func (*Knot) RejectPush

func (h *Knot) RejectPush(w http.ResponseWriter, r *http.Request, unqualifiedRepoName string)

func (*Knot) RequestLogger

func (h *Knot) RequestLogger(next http.Handler) http.Handler

func (*Knot) Router

func (h *Knot) Router() http.Handler

func (*Knot) UploadPack

func (h *Knot) UploadPack(w http.ResponseWriter, r *http.Request)

func (*Knot) XrpcRouter

func (h *Knot) XrpcRouter() http.Handler

type PushOptions

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