github

Nov 4, 2023

Changes in this version

type Connector

+ Pg *pg.Client

type ConnectorCfg

+ func (cfg *ConnectorCfg) ValidateJSON(v *ejson.Validator)

type OAuth2Identity

+ func (i *OAuth2Identity) ValidateJSON(v *ejson.Validator)

type Parameters

+ func (p *Parameters) ValidateJSON(v *ejson.Validator)

type TokenIdentity

+ func (i *TokenIdentity) ValidateJSON(v *ejson.Validator)

Jul 19, 2022

Changes in this version

+ const PgAdvisoryLockId1

+ const PgAdvisoryLockId2GitHubHooks

+ func BranchCreationEventDef() *eventline.EventDef

+ func BranchDeletionEventDef() *eventline.EventDef

+ func CountSubscriptionsByHookId(conn pg.Conn, hookId HookId) (int64, error)

+ func IsNotFoundAPIError(err error) bool

+ func LoadSubscriptionsByParams(conn pg.Conn, ename string, params *Parameters) (eventline.Subscriptions, error)

+ func LockHooks(conn pg.Conn) error

+ func OAuth2IdentityDef() *eventline.IdentityDef

+ func OAuth2Scopes() []string

+ func PushEventDef() *eventline.EventDef

+ func RawEventDef() *eventline.EventDef

+ func RepositoryCreationEventDef() *eventline.EventDef

+ func RepositoryDeletionEventDef() *eventline.EventDef

+ func RequiredOAuth2Scopes() []string

+ func TagCreationEventDef() *eventline.EventDef

+ func TagDeletionEventDef() *eventline.EventDef

+ func TokenIdentityDef() *eventline.IdentityDef

+ type BranchCreationEvent struct

+ Branch string

+ Organization string

+ Repository string

+ Revision string

+ type BranchDeletionEvent struct

+ Branch string

+ Organization string

+ Repository string

+ Revision string

+ type Connector struct

+ Cfg *ConnectorCfg

+ Daemon *daemon.Daemon

+ Def *eventline.ConnectorDef

+ Log *log.Logger

+ func NewConnector() *Connector

+ func (c *Connector) CreateEvents(ename string, eventTime *time.Time, eventData eventline.EventData, ...) error

+ func (c *Connector) CreateHook(conn pg.Conn, params *Parameters, identity *eventline.Identity) (*HookId, error)

+ func (c *Connector) DefaultCfg() eventline.ConnectorCfg

+ func (c *Connector) Definition() *eventline.ConnectorDef

+ func (c *Connector) DeleteHook(conn pg.Conn, params *Parameters, identity *eventline.Identity, hookId HookId) error

+ func (c *Connector) Enabled() bool

+ func (c *Connector) Init(ccfg eventline.ConnectorCfg, initData eventline.ConnectorInitData) error

+ func (c *Connector) MaybeCreateHook(conn pg.Conn, params *Parameters, identity *eventline.Identity) (*HookId, error)

+ func (c *Connector) MaybeDeleteHook(conn pg.Conn, params *Parameters, identity *eventline.Identity, hookId HookId) error

+ func (c *Connector) Name() string

+ func (c *Connector) NewClient(identity *eventline.Identity) (*github.Client, error)

+ func (c *Connector) ProcessWebhookRequest(req *http.Request, params *Parameters) error

+ func (c *Connector) Subscribe(conn pg.Conn, sctx *eventline.SubscriptionContext) error

+ func (c *Connector) Terminate()

+ func (c *Connector) Unsubscribe(conn pg.Conn, sctx *eventline.SubscriptionContext) error

+ func (c *Connector) WebhookURI(params *Parameters) string

+ type ConnectorCfg struct

+ Enabled bool

+ WebhookSecret string

+ func (cfg *ConnectorCfg) Check(c *check.Checker)

+ type HookId = int64

+ func LoadHookIdByParameters(conn pg.Conn, params *Parameters) (*HookId, error)

+ type InvalidWebhookEventError struct

+ Msg string

+ func NewInvalidWebhookEventError(format string, args ...interface{}) *InvalidWebhookEventError

+ func (err *InvalidWebhookEventError) Error() string

+ type OAuth2Identity struct

+ AccessToken string

+ ClientId string

+ ClientSecret string

+ ExpirationTime *time.Time

+ Scopes []string

+ TTL int

+ Username string

+ func (i *OAuth2Identity) Check(c *check.Checker)

+ func (i *OAuth2Identity) Def() *eventline.IdentityDataDef

+ func (i *OAuth2Identity) Environment() map[string]string

+ func (i *OAuth2Identity) FetchTokenData(httpClient *http.Client, code, redirectionURI string) error

+ func (i *OAuth2Identity) RedirectionURI(httpClient *http.Client, state, redirectionURI string) (string, error)

+ type Parameters struct

+ Organization string

+ Repository string

+ func (p *Parameters) Check(c *check.Checker)

+ func (p *Parameters) ParseTarget(s string)

+ func (p *Parameters) Target() string

+ type PushEvent struct

+ Branch string

+ NewRevision string

+ OldRevision string

+ Organization string

+ Repository string

+ type RawEvent struct

+ DeliveryId string

+ Event interface{}

+ EventType string

+ type RepositoryCreationEvent struct

+ Organization string

+ Repository string

+ type RepositoryDeletionEvent struct

+ Organization string

+ Repository string

+ type Subscription struct

+ HookId HookId

+ Id eventline.Id

+ Organization string

+ Repository string

+ func (s *Subscription) Delete(conn pg.Conn) error

+ func (s *Subscription) FromRow(row pgx.Row) error

+ func (s *Subscription) Insert(conn pg.Conn) error

+ func (s *Subscription) LoadForUpdate(conn pg.Conn, id eventline.Id) error

+ type TagCreationEvent struct

+ Organization string

+ Repository string

+ Revision string

+ Tag string

+ type TagDeletionEvent struct

+ Organization string

+ Repository string

+ Revision string

+ Tag string

+ type TokenIdentity struct

+ Token string

+ Username string

+ func (i *TokenIdentity) Check(c *check.Checker)

+ func (i *TokenIdentity) Def() *eventline.IdentityDataDef

+ func (i *TokenIdentity) Environment() map[string]string

+ type UnknownSubscriptionError struct

+ Id eventline.Id

+ func (err UnknownSubscriptionError) Error() string