logic

Documentation

Index

• func NewAgentService(httpPublisher service.HttpClient) service.Agent
• func NewBitbucketService(httpPublisher service.HttpClient) service.Bitbucket
• func NewCompanyService(publisher service.HttpClient) service.Company
• func NewGithubService(httpPublisher service.HttpClient) service.Github
• func NewHttpClientService() service.HttpClient
• func NewJwtService() service.Jwt
• func NewKubeEventEventService(publisher service.HttpClient) service.KubeEvent
• func NewKubeObjectService(publisher service.HttpClient) service.KubeObject
• func NewLogEventService(httpPublisher service.HttpClient) service.LogEvent
• func NewPipelineService(publisher service.HttpClient, websocketClient service.WebsocketClient) service.Pipeline
• func NewProcessEvent(httpPublisher service.HttpClient) service.ProcessEvent
• func NewProcessLifeCycleEventService(publisher service.HttpClient) service.ProcessLifeCycleEvent
• func NewProcessService(publisher service.HttpClient) service.Process
• func NewWebsocketClientService() service.WebsocketClient
• type LogEvent
  • func (l LogEvent) Store(log interface{}) (httpCode int, error error)
• type ProcessEvent
  • func (p ProcessEvent) Get(companyId, userId, processId, scope string, option v1.ProcessQueryOption) (httpCode int, data interface{})
  • func (p ProcessEvent) Store(events interface{}) (httpCode int, error error)

Functions

func NewAgentService

func NewAgentService(httpPublisher service.HttpClient) service.Agent

NewAgentService returns agent type service

func NewBitbucketService

func NewBitbucketService(httpPublisher service.HttpClient) service.Bitbucket

NewBitbucketService returns bitbucket type service

func NewCompanyService

func NewCompanyService(publisher service.HttpClient) service.Company

NewCompanyService returns Company type service

func NewGithubService

func NewGithubService(httpPublisher service.HttpClient) service.Github

NewGithubService returns github type service

func NewHttpClientService

func NewHttpClientService() service.HttpClient

NewHttpClientService returns HttpClient type service

func NewJwtService

func NewJwtService() service.Jwt

NewJwtService returns Jwt type service

func NewKubeEventEventService

func NewKubeEventEventService(publisher service.HttpClient) service.KubeEvent

NewKubeEventEventService returns KubeEvent type service

func NewKubeObjectService

func NewKubeObjectService(publisher service.HttpClient) service.KubeObject

NewKubeObjectService returns KubeObject type service

func NewLogEventService

func NewLogEventService(httpPublisher service.HttpClient) service.LogEvent

func NewPipelineService

func NewPipelineService(publisher service.HttpClient, websocketClient service.WebsocketClient) service.Pipeline

NewPipelineService returns Pipeline type service

func NewProcessEvent

func NewProcessEvent(httpPublisher service.HttpClient) service.ProcessEvent

func NewProcessLifeCycleEventService

func NewProcessLifeCycleEventService(publisher service.HttpClient) service.ProcessLifeCycleEvent

NewProcessLifeCycleEventService returns ProcessLifeCycleEvent type service

func NewProcessService

func NewProcessService(publisher service.HttpClient) service.Process

NewProcessService returns Process type service

func NewWebsocketClientService

func NewWebsocketClientService() service.WebsocketClient

NewWebsocketClientService returns WebsocketClient type service

Types

type LogEvent

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

func (LogEvent) Store

func (l LogEvent) Store(log interface{}) (httpCode int, error error)

type ProcessEvent

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

func (ProcessEvent) Get

func (p ProcessEvent) Get(companyId, userId, processId, scope string, option v1.ProcessQueryOption) (httpCode int, data interface{})

func (ProcessEvent) Store

func (p ProcessEvent) Store(events interface{}) (httpCode int, error error)