gitlab

Documentation

Index

• func NewFromCLI(c *cli.Context, tracer opentracing.Tracer) (eventsources.EventSource, error)
• func NewSource(tracer opentracing.Tracer) (eventsources.EventSource, error)
• func PostEvent(payload []byte, eventType string, u *url.URL, client *http.Client) (*http.Response, error)
• type IssueEvent
  • func (ie IssueEvent) IsError() (bool, error)
  • func (ie IssueEvent) OperationName() string
  • func (ie IssueEvent) ParentSpanID() (*string, error)
  • func (ie IssueEvent) SpanID() (string, error)
  • func (ie IssueEvent) State(prev *eventsources.EventState) (eventsources.SpanState, error)
  • func (ie IssueEvent) Tags() (map[string]interface{}, error)
  • func (ie IssueEvent) Timings() (eventsources.EventTimings, error)
• type JobEvent
  • func (je JobEvent) IsError() (bool, error)
  • func (je JobEvent) OperationName() string
  • func (je JobEvent) ParentSpanID() (*string, error)
  • func (je JobEvent) SpanID() (string, error)
  • func (je JobEvent) State(prev *eventsources.EventState) (eventsources.SpanState, error)
  • func (je JobEvent) Tags() (map[string]interface{}, error)
  • func (je JobEvent) Timings() (eventsources.EventTimings, error)
• type MergeEvent
  • func (me MergeEvent) IsError() (bool, error)
  • func (me MergeEvent) OperationName() string
  • func (me MergeEvent) ParentSpanID() (*string, error)
  • func (me MergeEvent) SpanID() (string, error)
  • func (me MergeEvent) State(prev *eventsources.EventState) (eventsources.SpanState, error)
  • func (me MergeEvent) Tags() (map[string]interface{}, error)
  • func (me MergeEvent) Timings() (eventsources.EventTimings, error)
  • func (me MergeEvent) TraceID() (*string, error)
• type PipelineEvent
  • func (pe PipelineEvent) IsError() (bool, error)
  • func (pe PipelineEvent) OperationName() string
  • func (pe PipelineEvent) ParentSpanID() (*string, error)
  • func (pe PipelineEvent) SpanID() (string, error)
  • func (pe PipelineEvent) State(prev *eventsources.EventState) (eventsources.SpanState, error)
  • func (pe PipelineEvent) Tags() (map[string]interface{}, error)
  • func (pe PipelineEvent) Timings() (eventsources.EventTimings, error)
• type Source
  • func (s *Source) Event(r *http.Request, payload []byte) (eventsources.Event, error)
  • func (s Source) Name() string
  • func (s *Source) SecretKey() []byte
  • func (s *Source) Tracer() opentracing.Tracer
  • func (s *Source) ValidatePayload(r *http.Request, secretKey []byte) ([]byte, error)

Functions

func NewFromCLI

func NewFromCLI(c *cli.Context, tracer opentracing.Tracer) (eventsources.EventSource, error)

func NewSource

func NewSource(tracer opentracing.Tracer) (eventsources.EventSource, error)

func PostEvent

func PostEvent(payload []byte, eventType string, u *url.URL, client *http.Client) (*http.Response, error)

Types

type IssueEvent

type IssueEvent struct {
	*gitlab.IssueEvent
}

func (IssueEvent) IsError

func (ie IssueEvent) IsError() (bool, error)

func (IssueEvent) OperationName

func (ie IssueEvent) OperationName() string

func (IssueEvent) ParentSpanID

func (ie IssueEvent) ParentSpanID() (*string, error)

func (IssueEvent) SpanID

func (ie IssueEvent) SpanID() (string, error)

func (IssueEvent) State

func (ie IssueEvent) State(prev *eventsources.EventState) (eventsources.SpanState, error)

func (IssueEvent) Tags

func (ie IssueEvent) Tags() (map[string]interface{}, error)

func (IssueEvent) Timings

func (ie IssueEvent) Timings() (eventsources.EventTimings, error)

type JobEvent

type JobEvent struct {
	*gitlab.JobEvent
}

func (JobEvent) IsError

func (je JobEvent) IsError() (bool, error)

func (JobEvent) OperationName

func (je JobEvent) OperationName() string

func (JobEvent) ParentSpanID

func (je JobEvent) ParentSpanID() (*string, error)

func (JobEvent) SpanID

func (je JobEvent) SpanID() (string, error)

func (JobEvent) State

func (je JobEvent) State(prev *eventsources.EventState) (eventsources.SpanState, error)

State identifies the current state of the build, valid states are: - pending - created - running - canceled - success

func (JobEvent) Tags

func (je JobEvent) Tags() (map[string]interface{}, error)

func (JobEvent) Timings

func (je JobEvent) Timings() (eventsources.EventTimings, error)

type MergeEvent

type MergeEvent struct {
	*gitlab.MergeEvent
}

func (MergeEvent) IsError

func (me MergeEvent) IsError() (bool, error)

func (MergeEvent) OperationName

func (me MergeEvent) OperationName() string

func (MergeEvent) ParentSpanID

func (me MergeEvent) ParentSpanID() (*string, error)

func (MergeEvent) SpanID

func (me MergeEvent) SpanID() (string, error)

func (MergeEvent) State

func (me MergeEvent) State(prev *eventsources.EventState) (eventsources.SpanState, error)

func (MergeEvent) Tags

func (me MergeEvent) Tags() (map[string]interface{}, error)

func (MergeEvent) Timings

func (me MergeEvent) Timings() (eventsources.EventTimings, error)

func (MergeEvent) TraceID

func (me MergeEvent) TraceID() (*string, error)

type PipelineEvent

type PipelineEvent struct {
	*gitlab.PipelineEvent
}

func (PipelineEvent) IsError

func (pe PipelineEvent) IsError() (bool, error)

func (PipelineEvent) OperationName

func (pe PipelineEvent) OperationName() string

func (PipelineEvent) ParentSpanID

func (pe PipelineEvent) ParentSpanID() (*string, error)

ParentSpanID inspects the pipeline payload for the causing event: - Pull Request - Issue

func (PipelineEvent) SpanID

func (pe PipelineEvent) SpanID() (string, error)

func (PipelineEvent) State

func (pe PipelineEvent) State(prev *eventsources.EventState) (eventsources.SpanState, error)

func (PipelineEvent) Tags

func (pe PipelineEvent) Tags() (map[string]interface{}, error)

func (PipelineEvent) Timings

func (pe PipelineEvent) Timings() (eventsources.EventTimings, error)

type Source

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

func (*Source) Event

func (s *Source) Event(r *http.Request, payload []byte) (eventsources.Event, error)

func (Source) Name

func (s Source) Name() string

func (*Source) SecretKey

func (s *Source) SecretKey() []byte

func (*Source) Tracer

func (s *Source) Tracer() opentracing.Tracer

func (*Source) ValidatePayload

func (s *Source) ValidatePayload(r *http.Request, secretKey []byte) ([]byte, error)