api

Documentation

Index

• Constants
• func NewAgentDrainDelete(fn func(on bool)) (e *api_server.Endpoint)
• func NewAgentDrainPut(fn func(on bool)) (e *api_server.Endpoint)
• func NewAgentReloadPut(fn func()) (e *api_server.Endpoint)
• func NewAgentStopPut(signalChan chan os.Signal) (e *api_server.Endpoint)
• func NewClusterNodesGet(log *logx.Log) (e *api_server.Endpoint)
• func NewRegistryPodsDelete(log *logx.Log, consumer bus.Consumer) (e *api_server.Endpoint)
• func NewRegistryPodsGet() (e *api_server.Endpoint)
• func NewRegistryPodsPut(log *logx.Log, consumer bus.Consumer) (e *api_server.Endpoint)
• func NewStatusPingGet() (e *api_server.Endpoint)
• type Wrapper
  • func NewWrapper(fn func() (err error)) (e *Wrapper)
  • func (e *Wrapper) Empty() interface{}
  • func (e *Wrapper) Process(ctx context.Context, u *url.URL, v interface{}) (res interface{}, err error)

Constants

const (
	V1Registry = "/v1/registry"
)

Functions

func NewAgentDrainDelete

func NewAgentDrainDelete(fn func(on bool)) (e *api_server.Endpoint)

func NewAgentDrainPut

func NewAgentDrainPut(fn func(on bool)) (e *api_server.Endpoint)

func NewAgentReloadPut

func NewAgentReloadPut(fn func()) (e *api_server.Endpoint)

func NewAgentStopPut

func NewAgentStopPut(signalChan chan os.Signal) (e *api_server.Endpoint)

func NewClusterNodesGet

func NewClusterNodesGet(log *logx.Log) (e *api_server.Endpoint)

func NewRegistryPodsDelete

func NewRegistryPodsDelete(log *logx.Log, consumer bus.Consumer) (e *api_server.Endpoint)

func NewRegistryPodsGet

func NewRegistryPodsGet() (e *api_server.Endpoint)

func NewRegistryPodsPut

func NewRegistryPodsPut(log *logx.Log, consumer bus.Consumer) (e *api_server.Endpoint)

func NewStatusPingGet

func NewStatusPingGet() (e *api_server.Endpoint)

Types

type Wrapper

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

simple wrapper for non-processing handlers

func NewWrapper

func NewWrapper(fn func() (err error)) (e *Wrapper)

func (*Wrapper) Empty

func (e *Wrapper) Empty() interface{}

func (*Wrapper) Process

func (e *Wrapper) Process(ctx context.Context, u *url.URL, v interface{}) (res interface{}, err error)