daemon

Documentation

Index

• Variables
• func NewHandler(s api.Server, r *mux.Router) http.Handler
• func NewRouter() *mux.Router
• type HTTPServer
  • func (s HTTPServer) Export(w http.ResponseWriter, r *http.Request)
  • func (s HTTPServer) GetPublicSSHKey(w http.ResponseWriter, r *http.Request)
  • func (s HTTPServer) GitRepoConfig(w http.ResponseWriter, r *http.Request)
  • func (s HTTPServer) JobStatus(w http.ResponseWriter, r *http.Request)
  • func (s HTTPServer) ListImagesWithOptions(w http.ResponseWriter, r *http.Request)
  • func (s HTTPServer) ListServicesWithOptions(w http.ResponseWriter, r *http.Request)
  • func (s HTTPServer) Notify(w http.ResponseWriter, r *http.Request)
  • func (s HTTPServer) Ping(w http.ResponseWriter, r *http.Request)
  • func (s HTTPServer) RegeneratePublicSSHKey(w http.ResponseWriter, r *http.Request)
  • func (s HTTPServer) SyncStatus(w http.ResponseWriter, r *http.Request)
  • func (s HTTPServer) UpdateImages(w http.ResponseWriter, r *http.Request)
  • func (s HTTPServer) UpdateManifests(w http.ResponseWriter, r *http.Request)
  • func (s HTTPServer) UpdatePolicies(w http.ResponseWriter, r *http.Request)
  • func (s HTTPServer) Version(w http.ResponseWriter, r *http.Request)
• type Upstream
  • func NewUpstream(client *http.Client, ua string, t fluxclient.Token, router *mux.Router, ...) (*Upstream, error)
  • func (a *Upstream) Close() error
  • func (a *Upstream) LogEvent(event event.Event) error

Variables

var (
	ErrEndpointDeprecated = errors.New("Your fluxd version is deprecated - please upgrade, see https://github.com/nholuongut/flux/releases")
)

Functions

func NewHandler

func NewHandler(s api.Server, r *mux.Router) http.Handler

func NewRouter

func NewRouter() *mux.Router

An API server for the daemon

Types

type HTTPServer

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

func (HTTPServer) Export

func (s HTTPServer) Export(w http.ResponseWriter, r *http.Request)

func (HTTPServer) GetPublicSSHKey

func (s HTTPServer) GetPublicSSHKey(w http.ResponseWriter, r *http.Request)

func (HTTPServer) GitRepoConfig

func (s HTTPServer) GitRepoConfig(w http.ResponseWriter, r *http.Request)

func (HTTPServer) JobStatus

func (s HTTPServer) JobStatus(w http.ResponseWriter, r *http.Request)

func (HTTPServer) ListImagesWithOptions

func (s HTTPServer) ListImagesWithOptions(w http.ResponseWriter, r *http.Request)

func (HTTPServer) ListServicesWithOptions

func (s HTTPServer) ListServicesWithOptions(w http.ResponseWriter, r *http.Request)

func (HTTPServer) Notify

func (s HTTPServer) Notify(w http.ResponseWriter, r *http.Request)

func (HTTPServer) Ping

func (s HTTPServer) Ping(w http.ResponseWriter, r *http.Request)

func (HTTPServer) RegeneratePublicSSHKey

func (s HTTPServer) RegeneratePublicSSHKey(w http.ResponseWriter, r *http.Request)

func (HTTPServer) SyncStatus

func (s HTTPServer) SyncStatus(w http.ResponseWriter, r *http.Request)

func (HTTPServer) UpdateImages

func (s HTTPServer) UpdateImages(w http.ResponseWriter, r *http.Request)

func (HTTPServer) UpdateManifests

func (s HTTPServer) UpdateManifests(w http.ResponseWriter, r *http.Request)

func (HTTPServer) UpdatePolicies

func (s HTTPServer) UpdatePolicies(w http.ResponseWriter, r *http.Request)

func (HTTPServer) Version

func (s HTTPServer) Version(w http.ResponseWriter, r *http.Request)

type Upstream

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

Upstream handles communication from the daemon to a service

func NewUpstream

func NewUpstream(client *http.Client, ua string, t fluxclient.Token, router *mux.Router, endpoint string, s api.Server, timeout time.Duration, logger log.Logger) (*Upstream, error)

func (*Upstream) Close

func (a *Upstream) Close() error

Close closes the connection to the service

func (*Upstream) LogEvent

func (a *Upstream) LogEvent(event event.Event) error