registry

Documentation

Index

• type Client
  • func NewClient(ident string, cfg *ali_notifier.RegistryConfig) *Client
  • func (c *Client) DetectRecorderStatus() bool
  • func (c *Client) Run() error
• type ContainerStatus
• type GetIdentRequest
• type GetRegistryResponse
• type Info
• type PostIdentRequest
• type PostRegisterRequest
• type Registry
  • func NewRegistry(srv *server.Server, cfg *ali_notifier.Config, ident string) *Registry
  • func (reg *Registry) Delegate(ctx *context.Context, req *http.Request)
  • func (reg *Registry) DelegateGetRequest(ctx *context.Context)
  • func (reg *Registry) DelegatePostRequest(ctx *context.Context)
  • func (reg *Registry) ExposeHttp(r *iris.Application)
  • func (reg *Registry) GetRegistry(ctx *context.Context)
  • func (reg *Registry) Loop()
  • func (reg *Registry) ModifyHost(ctx *context.Context, ident string, req *http.Request) bool
  • func (reg *Registry) PostRegister(ctx *context.Context)

Types

type Client

type Client struct {
	Ident  string
	Config *ali_notifier.RegistryConfig
	// contains filtered or unexported fields
}

func NewClient

func NewClient(ident string, cfg *ali_notifier.RegistryConfig) *Client

func (*Client) DetectRecorderStatus

func (c *Client) DetectRecorderStatus() bool

func (*Client) Run

func (c *Client) Run() error

type ContainerStatus

type ContainerStatus struct {
	State struct {
		Status     string    `json:"Status"`
		Running    bool      `json:"Running"`
		Paused     bool      `json:"Paused"`
		Restarting bool      `json:"Restarting"`
		OOMKilled  bool      `json:"OOMKilled"`
		Dead       bool      `json:"Dead"`
		Pid        int       `json:"Pid"`
		ExitCode   int       `json:"ExitCode"`
		Error      string    `json:"Error"`
		StartedAt  time.Time `json:"StartedAt"`
		FinishedAt time.Time `json:"FinishedAt"`
	} `json:"State"`
}

type GetIdentRequest

type GetIdentRequest struct {
	Server string `url:"server"`
}

type GetRegistryResponse

type GetRegistryResponse struct {
	Items []*Info `json:"items"`
}

type Info

type Info struct {
	Server         string    `json:"server"`
	Name           string    `json:"name"`
	Host           string    `json:"host"`
	Port           string    `json:"port"`
	UploaderStatus uint64    `json:"uploaderStatus"`
	RecorderStatus uint64    `json:"recorderStatus"`
	LastActive     time.Time `json:"last_active"`
}

type PostIdentRequest

type PostIdentRequest struct {
	Server string `json:"server"`
}

type PostRegisterRequest

type PostRegisterRequest struct {
	Name           string `json:"name"`
	Server         string `json:"server"`
	Port           string `json:"port"`
	Secret         string `json:"secret"`
	RecorderStatus uint64 `json:"recorderStatus"`
}

type Registry

type Registry struct {
	*server.Server

	RegistryConfig *ali_notifier.RegistryConfig
	Servers        map[string]*ali_notifier.RegistryConfig
	Ident          string
	// contains filtered or unexported fields
}

func NewRegistry

func NewRegistry(srv *server.Server, cfg *ali_notifier.Config, ident string) *Registry

func (*Registry) Delegate

func (reg *Registry) Delegate(ctx *context.Context, req *http.Request)

func (*Registry) DelegateGetRequest

func (reg *Registry) DelegateGetRequest(ctx *context.Context)

func (*Registry) DelegatePostRequest

func (reg *Registry) DelegatePostRequest(ctx *context.Context)

func (*Registry) ExposeHttp

func (reg *Registry) ExposeHttp(r *iris.Application)

func (*Registry) GetRegistry

func (reg *Registry) GetRegistry(ctx *context.Context)

func (*Registry) Loop

func (reg *Registry) Loop()

func (*Registry) ModifyHost

func (reg *Registry) ModifyHost(ctx *context.Context, ident string, req *http.Request) bool

func (*Registry) PostRegister

func (reg *Registry) PostRegister(ctx *context.Context)