generic

Documentation

Index

• func APIKeyIdentityDef() *eventline.IdentityDef
• func GPGKeyIdentityDef() *eventline.IdentityDef
• func OAuth2IdentityDef() *eventline.IdentityDef
• func PasswordIdentityDef() *eventline.IdentityDef
• func SSHKeyIdentityDef() *eventline.IdentityDef
• type APIKeyIdentity
  • func (i *APIKeyIdentity) Check(c *check.Checker)
  • func (i *APIKeyIdentity) Def() *eventline.IdentityDataDef
  • func (i *APIKeyIdentity) Environment() map[string]string
• type Connector
  • func NewConnector() *Connector
  • func (c *Connector) DefaultCfg() eventline.ConnectorCfg
  • func (c *Connector) Definition() *eventline.ConnectorDef
  • func (c *Connector) Init(ccfg eventline.ConnectorCfg, initData eventline.ConnectorInitData) error
  • func (c *Connector) Name() string
  • func (c *Connector) Terminate()
• type ConnectorCfg
  • func (cfg *ConnectorCfg) Check(c *check.Checker)
• type GPGKeyIdentity
  • func (i *GPGKeyIdentity) Check(c *check.Checker)
  • func (i *GPGKeyIdentity) Def() *eventline.IdentityDataDef
  • func (i *GPGKeyIdentity) Environment() map[string]string
• type OAuth2Identity
  • 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)
  • func (i *OAuth2Identity) Refresh(httpClient *http.Client) error
  • func (i *OAuth2Identity) RefreshTime() time.Time
• type PasswordIdentity
  • func (i *PasswordIdentity) Check(c *check.Checker)
  • func (i *PasswordIdentity) Def() *eventline.IdentityDataDef
  • func (i *PasswordIdentity) Environment() map[string]string
• type SSHKeyIdentity
  • func (i *SSHKeyIdentity) Check(c *check.Checker)
  • func (i *SSHKeyIdentity) Def() *eventline.IdentityDataDef
  • func (i *SSHKeyIdentity) Environment() map[string]string

Functions

func APIKeyIdentityDef

func APIKeyIdentityDef() *eventline.IdentityDef

func GPGKeyIdentityDef

func GPGKeyIdentityDef() *eventline.IdentityDef

func OAuth2IdentityDef

func OAuth2IdentityDef() *eventline.IdentityDef

func PasswordIdentityDef

func PasswordIdentityDef() *eventline.IdentityDef

func SSHKeyIdentityDef

func SSHKeyIdentityDef() *eventline.IdentityDef

Types

type APIKeyIdentity

type APIKeyIdentity struct {
	Key string `json:"key"`
}

func (*APIKeyIdentity) Check

func (i *APIKeyIdentity) Check(c *check.Checker)

func (*APIKeyIdentity) Def

func (i *APIKeyIdentity) Def() *eventline.IdentityDataDef

func (*APIKeyIdentity) Environment

func (i *APIKeyIdentity) Environment() map[string]string

type Connector

type Connector struct {
	Def *eventline.ConnectorDef
	Cfg *ConnectorCfg
	Log *dlog.Logger
}

func NewConnector

func NewConnector() *Connector

func (*Connector) DefaultCfg

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

func (*Connector) Definition

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

func (*Connector) Init

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

func (*Connector) Name

func (c *Connector) Name() string

func (*Connector) Terminate

func (c *Connector) Terminate()

type ConnectorCfg

type ConnectorCfg struct {
	Secret string `json:"secret"`
}

func (*ConnectorCfg) Check

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

type GPGKeyIdentity

type GPGKeyIdentity struct {
	PrivateKey string `json:"private_key,omitempty"`
	PublicKey  string `json:"public_key,omitempty"`
	Password   string `json:"password,omitempty"`
}

func (*GPGKeyIdentity) Check

func (i *GPGKeyIdentity) Check(c *check.Checker)

func (*GPGKeyIdentity) Def

func (i *GPGKeyIdentity) Def() *eventline.IdentityDataDef

func (*GPGKeyIdentity) Environment

func (i *GPGKeyIdentity) Environment() map[string]string

type OAuth2Identity

type OAuth2Identity struct {
	Issuer                string   `json:"issuer"`
	Discovery             bool     `json:"discovery,omitempty"`
	DiscoveryEndpoint     string   `json:"discovery_endpoint,omitempty"`
	AuthorizationEndpoint string   `json:"authorization_endpoint,omitempty"`
	TokenEndpoint         string   `json:"token_endpoint,omitempty"`
	ClientId              string   `json:"client_id"`
	ClientSecret          string   `json:"client_secret"`
	Scopes                []string `json:"scopes"`

	AccessToken    string     `json:"access_token,omitempty"`
	RefreshToken   string     `json:"refresh_token,omitempty"`
	TTL            int        `json:"ttl"`
	ExpirationTime *time.Time `json:"expiration_time,omitempty"`
}

func (*OAuth2Identity) Check

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

func (*OAuth2Identity) Def

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

func (*OAuth2Identity) Environment

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

func (*OAuth2Identity) FetchTokenData

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

func (*OAuth2Identity) RedirectionURI

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

func (*OAuth2Identity) Refresh

func (i *OAuth2Identity) Refresh(httpClient *http.Client) error

func (*OAuth2Identity) RefreshTime

func (i *OAuth2Identity) RefreshTime() time.Time

type PasswordIdentity

type PasswordIdentity struct {
	Login    string `json:"login,omitempty"`
	Password string `json:"password"`
}

func (*PasswordIdentity) Check

func (i *PasswordIdentity) Check(c *check.Checker)

func (*PasswordIdentity) Def

func (i *PasswordIdentity) Def() *eventline.IdentityDataDef

func (*PasswordIdentity) Environment

func (i *PasswordIdentity) Environment() map[string]string

type SSHKeyIdentity

type SSHKeyIdentity struct {
	PrivateKey  string `json:"private_key"`
	PublicKey   string `json:"public_key,omitempty"`
	Certificate string `json:"certificate,omitempty"`
}

func (*SSHKeyIdentity) Check

func (i *SSHKeyIdentity) Check(c *check.Checker)

func (*SSHKeyIdentity) Def

func (i *SSHKeyIdentity) Def() *eventline.IdentityDataDef

func (*SSHKeyIdentity) Environment

func (i *SSHKeyIdentity) Environment() map[string]string