webhook

package

v1.1.0 Latest Latest Go to latest Published: Dec 7, 2018 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/Qihoo360/wayne

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func PublishEventDeployment(namespaceId int64, appId int64, user string, ip string, action Action, ...)
func PublishEventMember(namespaceId int64, appId int64, user string, ip string, action Action, ...)
func PublishEventService(namespaceId int64, appId int64, user string, ip string, action Action, ...)
type Action
type ClientPool
type EventDeploymentPayload
type EventMemberPayload
type EventServicePayload
type Request
type WebhookWorker
- func NewWebhookWorker(b *bus.Bus) (*WebhookWorker, error)
- func (w *WebhookWorker) Process(msg *message.Message) error

Constants ¶

View Source

const QueueWebhook = "webhook"

Variables ¶

This section is empty.

Functions ¶

func PublishEventDeployment ¶

func PublishEventDeployment(namespaceId int64, appId int64, user string, ip string, action Action, deployment response.Resource)

func PublishEventMember ¶

func PublishEventMember(namespaceId int64, appId int64, user string, ip string, action Action, member models.User)

func PublishEventService ¶

func PublishEventService(namespaceId int64, appId int64, user string, ip string, action Action, service response.Resource)

Types ¶

type Action ¶

type Action string

const (
	AddMember         Action = "AddMember"
	DeleteMember      Action = "DeleteMember"
	UpdateMember      Action = "UpdateMember"
	UpgradeDeployment Action = "UpgradeDeployment"
	DeleteDeployment  Action = "OfflineDeployment"
	OnlineService     Action = "OnlineService"
	OfflineService    Action = "OfflineService"
)

type ClientPool ¶

type ClientPool struct {
	Window chan struct{}
	Client *http.Client
}

type EventDeploymentPayload ¶

type EventDeploymentPayload struct {
	Action     Action            `json:"action"`
	Deployment response.Resource `json:"deployment"`
}

type EventMemberPayload ¶

type EventMemberPayload struct {
	Action Action        `json:"action"`
	Member response.User `json:"member"`
}

type EventServicePayload ¶

type EventServicePayload struct {
	Action  Action            `json:"action"`
	Service response.Resource `json:"service"`
}

type Request ¶

type Request struct {
	EventKey  string             `json:"event"`
	Namespace response.Namespace `json:"namespace"`
	App       response.App       `json:"app"`
	User      string             `json:"user"`
	IP        string             `json:"ip"`
	Datetime  time.Time          `json:"datetime"`
	Payload   interface{}        `json:"payload"`
}

type WebhookWorker ¶

type WebhookWorker struct {
	*workers.BaseMessageWorker
	ClientPool *ClientPool
}

func NewWebhookWorker ¶

func NewWebhookWorker(b *bus.Bus) (*WebhookWorker, error)

func (*WebhookWorker) Process ¶

func (w *WebhookWorker) Process(msg *message.Message) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL