Help us shape the future of Go! Take the 2026 Go Developer Survey

client

package
v1.8.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 1, 2025 License: Apache-2.0 Imports: 25 Imported by: 16

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Event 

type Event struct {
	EventTypeId         int               `json:"eventTypeId"`
	EventName           string            `json:"eventName"`
	PipelineId          int               `json:"pipelineId"`
	PipelineType        string            `json:"pipelineType"`
	CorrelationId       string            `json:"correlationId"`
	Payload             *Payload          `json:"payload"`
	EventTime           string            `json:"eventTime"`
	TeamId              int               `json:"teamId"`
	AppId               int               `json:"appId"`
	EnvId               int               `json:"envId"`
	IsProdEnv           bool              `json:"isProdEnv"`
	ClusterId           int               `json:"clusterId"`
	CdWorkflowType      bean.WorkflowType `json:"cdWorkflowType,omitempty"`
	CdWorkflowRunnerId  int               `json:"cdWorkflowRunnerId"`
	CiWorkflowRunnerId  int               `json:"ciWorkflowRunnerId"`
	CiArtifactId        int               `json:"ciArtifactId"`
	EnvIdsForCiPipeline []int             `json:"envIdsForCiPipeline"`
	BaseUrl             string            `json:"baseUrl"`
	UserId              int               `json:"-"`
}

type EventClient 

type EventClient interface {
	WriteNotificationEvent(event Event) (bool, error)
	WriteNatsEvent(channel string, payload interface{}) error
}

type EventClientConfig 

type EventClientConfig struct {
	DestinationURL     string             `env:"EVENT_URL" envDefault:"http://localhost:3000/notify" description:"Notifier service url"`
	NotificationMedium NotificationMedium `env:"NOTIFICATION_MEDIUM" envDefault:"rest" description:"notification medium"`
}

func GetEventClientConfig 

func GetEventClientConfig() (*EventClientConfig, error)

type EventFactory 

type EventFactory interface {
	Build(eventType util.EventType, sourceId *int, appId int, envId *int, pipelineType util.PipelineType) (Event, error)
	BuildExtraCDData(event Event, wfr *pipelineConfig.CdWorkflowRunner, pipelineOverrideId int, stage bean2.WorkflowType) Event
	BuildExtraCIData(event Event, material *buildBean.MaterialTriggerInfo) Event
}

type EventRESTClientImpl 

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

func NewEventRESTClientImpl 

func NewEventRESTClientImpl(logger *zap.SugaredLogger, client *http.Client, config *EventClientConfig, pubsubClient *pubsub.PubSubClientServiceImpl,
	ciPipelineRepository pipelineConfig.CiPipelineRepository, pipelineRepository pipelineConfig.PipelineRepository,
	attributesRepository repository.AttributesRepository, moduleService module.ModuleService,
	notificationSettingsRepository repository.NotificationSettingsRepository) *EventRESTClientImpl

func (*EventRESTClientImpl) WriteNatsEvent 

func (impl *EventRESTClientImpl) WriteNatsEvent(topic string, payload interface{}) error

func (*EventRESTClientImpl) WriteNotificationEvent added in v0.6.0 

func (impl *EventRESTClientImpl) WriteNotificationEvent(event Event) (bool, error)

type EventSimpleFactoryImpl 

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

func NewEventSimpleFactoryImpl 

func NewEventSimpleFactoryImpl(logger *zap.SugaredLogger, cdWorkflowRepository pipelineConfig.CdWorkflowRepository,
	pipelineOverrideRepository chartConfig.PipelineOverrideRepository, ciWorkflowRepository pipelineConfig.CiWorkflowRepository,
	ciPipelineMaterialRepository pipelineConfig.CiPipelineMaterialRepository,
	ciPipelineRepository pipelineConfig.CiPipelineRepository, pipelineRepository pipelineConfig.PipelineRepository,
	userRepository repository.UserRepository, envRepository repository4.EnvironmentRepository, ciArtifactRepository repository2.CiArtifactRepository) *EventSimpleFactoryImpl

func (*EventSimpleFactoryImpl) Build 

func (impl *EventSimpleFactoryImpl) Build(eventType util.EventType, sourceId *int, appId int, envId *int, pipelineType util.PipelineType) (Event, error)

func (*EventSimpleFactoryImpl) BuildExtraCDData 

func (impl *EventSimpleFactoryImpl) BuildExtraCDData(event Event, wfr *pipelineConfig.CdWorkflowRunner, pipelineOverrideId int, stage bean2.WorkflowType) Event

func (*EventSimpleFactoryImpl) BuildExtraCIData 

func (impl *EventSimpleFactoryImpl) BuildExtraCIData(event Event, material *buildBean.MaterialTriggerInfo) Event

type NotificationMedium added in v0.7.1 

type NotificationMedium string
const PUB_SUB NotificationMedium = "nats"

type Payload 

type Payload struct {
	AppName               string                         `json:"appName"`
	EnvName               string                         `json:"envName"`
	PipelineName          string                         `json:"pipelineName"`
	Source                string                         `json:"source"`
	DockerImageUrl        string                         `json:"dockerImageUrl"`
	TriggeredBy           string                         `json:"triggeredBy"`
	Stage                 string                         `json:"stage"`
	DeploymentHistoryLink string                         `json:"deploymentHistoryLink"`
	AppDetailLink         string                         `json:"appDetailLink"`
	DownloadLink          string                         `json:"downloadLink"`
	BuildHistoryLink      string                         `json:"buildHistoryLink"`
	MaterialTriggerInfo   *buildBean.MaterialTriggerInfo `json:"material"`
	FailureReason         string                         `json:"failureReason"`
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.