hooks

README

Hooks

Manage repository webhooks

License

Hooks is made available under the terms of the GPLv3.

See the LICENSE file that accompanies this distribution for the full text of the license.

Documentation

Index

• Variables
• type CollaborsRequests
• type CollaborsRequestsRepository
  • func NewCollaboratorsRequestsRepository(redisClient *redis.Client) *CollaborsRequestsRepository
  • func (repo *CollaborsRequestsRepository) Delete(payload string) error
  • func (repo *CollaborsRequestsRepository) List(limit int64) ([]string, error)
  • func (repo *CollaborsRequestsRepository) Save(payload string) (err error)
• type Mediator
• type MediatorService
  • func NewMediatorService(payloads Payloads, webClient web.Client, ...) *MediatorService
  • func (service *MediatorService) Mediate(event string, payload []byte) (err error)
• type PayloadRepository
  • func NewPayloadRepository(redisClient *redis.Client) *PayloadRepository
  • func (repo *PayloadRepository) Delete(payload string) error
  • func (repo *PayloadRepository) List(limit int64) ([]string, error)
  • func (repo *PayloadRepository) Save(payload string) (err error)
• type Payloads

Variables

var SendingError = fmt.Errorf("sending error")

Types

type CollaborsRequests

type CollaborsRequests interface {
	Save(payload string) error
	List(limit int64) ([]string, error)
	Delete(payload string) error
}

type CollaborsRequestsRepository

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

func NewCollaboratorsRequestsRepository

func NewCollaboratorsRequestsRepository(redisClient *redis.Client) *CollaborsRequestsRepository

func (*CollaborsRequestsRepository) Delete

func (repo *CollaborsRequestsRepository) Delete(payload string) error

func (*CollaborsRequestsRepository) List

func (repo *CollaborsRequestsRepository) List(limit int64) ([]string, error)

func (*CollaborsRequestsRepository) Save

func (repo *CollaborsRequestsRepository) Save(payload string) (err error)

type Mediator

type Mediator interface {
	Mediate(event string, payload []byte) (err error)
}

type MediatorService

type MediatorService struct {
	ConsumerBaseURL string
	// contains filtered or unexported fields
}

func NewMediatorService

func NewMediatorService(
	payloads Payloads, webClient web.Client,
	collaboratorsClient collaborators.Client, reviewers gh.Reviewers) *MediatorService

func (*MediatorService) Mediate

func (service *MediatorService) Mediate(event string, payload []byte) (err error)

type PayloadRepository

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

func NewPayloadRepository

func NewPayloadRepository(redisClient *redis.Client) *PayloadRepository

func (*PayloadRepository) Delete

func (repo *PayloadRepository) Delete(payload string) error

func (*PayloadRepository) List

func (repo *PayloadRepository) List(limit int64) ([]string, error)

func (*PayloadRepository) Save

func (repo *PayloadRepository) Save(payload string) (err error)

type Payloads

type Payloads interface {
	Save(payload string) error
	List(limit int64) ([]string, error)
	Delete(payload string) error
}