event

package
v1.19.1 Latest Latest
Warning

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

 Go to latest Published: Sep 20, 2024 License: GPL-3.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AgentFailedEvent added in v0.68.0 

type AgentFailedEvent struct {
	AgentId mesos.AgentID `json:"agentId"`
	// contains filtered or unexported fields
}

func NewAgentFailedEvent added in v0.68.0 

func NewAgentFailedEvent(agentId *mesos.AgentID) *AgentFailedEvent

func (*AgentFailedEvent) GetId added in v0.68.0 

func (e *AgentFailedEvent) GetId() mesos.AgentID

func (*AgentFailedEvent) GetLabels added in v0.68.0 

func (e *AgentFailedEvent) GetLabels() map[string]string

func (*AgentFailedEvent) GetName added in v0.68.0 

func (e *AgentFailedEvent) GetName() string

func (*AgentFailedEvent) GetTimestamp added in v0.68.0 

func (e *AgentFailedEvent) GetTimestamp() string

func (*AgentFailedEvent) SetLabels added in v0.68.0 

func (e *AgentFailedEvent) SetLabels(labels map[string]string)

type AnnounceTaskPIDEvent added in v0.17.80 

type AnnounceTaskPIDEvent struct {
	TaskId string `json:"taskId"`
	PID    int32  `json:"pid"`
	// contains filtered or unexported fields
}

func NewAnnounceTaskPIDEvent added in v0.17.80 

func NewAnnounceTaskPIDEvent(id string, pid int32) (e *AnnounceTaskPIDEvent)

func (*AnnounceTaskPIDEvent) GetLabels added in v0.48.0 

func (e *AnnounceTaskPIDEvent) GetLabels() map[string]string

func (*AnnounceTaskPIDEvent) GetName added in v0.17.80 

func (e *AnnounceTaskPIDEvent) GetName() string

func (*AnnounceTaskPIDEvent) GetTaskId added in v0.17.80 

func (e *AnnounceTaskPIDEvent) GetTaskId() string

func (*AnnounceTaskPIDEvent) GetTaskPID added in v0.17.80 

func (e *AnnounceTaskPIDEvent) GetTaskPID() int

func (*AnnounceTaskPIDEvent) GetTimestamp added in v0.17.80 

func (e *AnnounceTaskPIDEvent) GetTimestamp() string

func (*AnnounceTaskPIDEvent) SetLabels added in v0.48.0 

func (e *AnnounceTaskPIDEvent) SetLabels(labels map[string]string)

type BasicTaskTerminated added in v0.12.0 

type BasicTaskTerminated struct {
	DeviceEventBase
	ExitCode             int             `json:"exitCode"`
	Stdout               string          `json:"stdout"`
	Stderr               string          `json:"stderr"`
	VoluntaryTermination bool            `json:"voluntaryTermination"`
	FinalMesosState      mesos.TaskState `json:"finalMesosState"`
}

func (*BasicTaskTerminated) GetLabels added in v0.48.0 

func (e *BasicTaskTerminated) GetLabels() map[string]string

func (*BasicTaskTerminated) GetName added in v0.12.0 

func (e *BasicTaskTerminated) GetName() string

func (*BasicTaskTerminated) GetTimestamp added in v0.17.80 

func (e *BasicTaskTerminated) GetTimestamp() string

func (*BasicTaskTerminated) SetLabels added in v0.48.0 

func (e *BasicTaskTerminated) SetLabels(labels map[string]string)

type DeviceEvent 

type DeviceEvent interface {
	Event
	GetOrigin() DeviceEventOrigin
	GetType() pb.DeviceEventType
}

func NewDeviceEvent 

func NewDeviceEvent(origin DeviceEventOrigin, t pb.DeviceEventType) (de DeviceEvent)

type DeviceEventBase 

type DeviceEventBase struct {
	Type   pb.DeviceEventType `json:"type"`
	Origin DeviceEventOrigin  `json:"origin"`
	// contains filtered or unexported fields
}

func (*DeviceEventBase) GetLabels added in v0.48.0 

func (e *DeviceEventBase) GetLabels() map[string]string

func (*DeviceEventBase) GetOrigin 

func (b *DeviceEventBase) GetOrigin() DeviceEventOrigin

func (*DeviceEventBase) GetTimestamp added in v0.17.80 

func (e *DeviceEventBase) GetTimestamp() string

func (*DeviceEventBase) GetType 

func (b *DeviceEventBase) GetType() pb.DeviceEventType

func (*DeviceEventBase) SetLabels added in v0.48.0 

func (e *DeviceEventBase) SetLabels(labels map[string]string)

type DeviceEventOrigin 

type DeviceEventOrigin struct {
	// FIXME: replace these Mesos-tainted string wrappers with plain strings
	AgentId    mesos.AgentID    `json:"agentId"`
	ExecutorId mesos.ExecutorID `json:"executorId"`
	TaskId     mesos.TaskID     `json:"taskId"`
}

type DummyWriter added in v1.9.1 

type DummyWriter struct{}

func (*DummyWriter) Close added in v1.9.1 

func (*DummyWriter) Close()

func (*DummyWriter) WriteEvent added in v1.9.1 

func (*DummyWriter) WriteEvent(interface{})

func (*DummyWriter) WriteEventWithTimestamp added in v1.9.1 

func (*DummyWriter) WriteEventWithTimestamp(interface{}, time.Time)

type EndOfStream added in v0.12.0 

type EndOfStream struct {
	DeviceEventBase
}

func (*EndOfStream) GetLabels added in v0.48.0 

func (e *EndOfStream) GetLabels() map[string]string

func (*EndOfStream) GetName added in v0.12.0 

func (e *EndOfStream) GetName() string

func (*EndOfStream) GetTimestamp added in v0.17.80 

func (e *EndOfStream) GetTimestamp() string

func (*EndOfStream) SetLabels added in v0.48.0 

func (e *EndOfStream) SetLabels(labels map[string]string)

type EnvironmentEvent added in v0.19.80 

type EnvironmentEvent struct {
	EnvironmentID string
	Run           uint32
	State         string
	Error         error
	Message       string
	// contains filtered or unexported fields
}

func (*EnvironmentEvent) GetError added in v0.19.80 

func (e *EnvironmentEvent) GetError() string

func (*EnvironmentEvent) GetLabels added in v0.48.0 

func (e *EnvironmentEvent) GetLabels() map[string]string

func (*EnvironmentEvent) GetMessage added in v0.19.80 

func (e *EnvironmentEvent) GetMessage() string

func (*EnvironmentEvent) GetName added in v0.19.80 

func (e *EnvironmentEvent) GetName() string

func (*EnvironmentEvent) GetRun added in v0.19.80 

func (e *EnvironmentEvent) GetRun() uint32

func (*EnvironmentEvent) GetState added in v0.19.80 

func (e *EnvironmentEvent) GetState() string

func (*EnvironmentEvent) GetTimestamp added in v0.19.80 

func (e *EnvironmentEvent) GetTimestamp() string

func (*EnvironmentEvent) SetLabels added in v0.48.0 

func (e *EnvironmentEvent) SetLabels(labels map[string]string)

type Event added in v0.17.80 

type Event interface {
	GetName() string
	GetTimestamp() string
	GetLabels() map[string]string
	SetLabels(map[string]string)
}

type ExecutorFailedEvent added in v0.68.0 

type ExecutorFailedEvent struct {
	ExecutorId mesos.ExecutorID `json:"executorId"`
	// contains filtered or unexported fields
}

func NewExecutorFailedEvent added in v0.68.0 

func NewExecutorFailedEvent(executorId *mesos.ExecutorID) *ExecutorFailedEvent

func (*ExecutorFailedEvent) GetId added in v0.68.0 

func (e *ExecutorFailedEvent) GetId() mesos.ExecutorID

func (*ExecutorFailedEvent) GetLabels added in v0.68.0 

func (e *ExecutorFailedEvent) GetLabels() map[string]string

func (*ExecutorFailedEvent) GetName added in v0.68.0 

func (e *ExecutorFailedEvent) GetName() string

func (*ExecutorFailedEvent) GetTimestamp added in v0.68.0 

func (e *ExecutorFailedEvent) GetTimestamp() string

func (*ExecutorFailedEvent) SetLabels added in v0.68.0 

func (e *ExecutorFailedEvent) SetLabels(labels map[string]string)

type IntegratedServiceEvent added in v0.75.0 

type IntegratedServiceEvent interface {
	Event
	GetServiceName() string
}

type IntegratedServiceEventBase added in v0.75.0 

type IntegratedServiceEventBase struct {
	ServiceName string `json:"serviceName"`
	// contains filtered or unexported fields
}

func (*IntegratedServiceEventBase) GetLabels added in v0.75.0 

func (e *IntegratedServiceEventBase) GetLabels() map[string]string

func (*IntegratedServiceEventBase) GetServiceName added in v0.75.0 

func (b *IntegratedServiceEventBase) GetServiceName() string

func (*IntegratedServiceEventBase) GetTimestamp added in v0.75.0 

func (e *IntegratedServiceEventBase) GetTimestamp() string

func (*IntegratedServiceEventBase) SetLabels added in v0.75.0 

func (e *IntegratedServiceEventBase) SetLabels(labels map[string]string)

type KafkaWriter added in v1.9.1 

type KafkaWriter struct {
	*kafka.Writer
}

func NewWriterWithTopic added in v1.7.0 

func NewWriterWithTopic(topic topic.Topic) *KafkaWriter

func (*KafkaWriter) Close added in v1.9.1 

func (w *KafkaWriter) Close()

func (*KafkaWriter) WriteEvent added in v1.9.1 

func (w *KafkaWriter) WriteEvent(e interface{})

func (*KafkaWriter) WriteEventWithTimestamp added in v1.9.1 

func (w *KafkaWriter) WriteEventWithTimestamp(e interface{}, timestamp time.Time)

type RoleEvent added in v0.19.80 

type RoleEvent struct {
	Name     string
	Status   string
	State    string
	RolePath string
	// contains filtered or unexported fields
}

func (*RoleEvent) GetLabels added in v0.48.0 

func (e *RoleEvent) GetLabels() map[string]string

func (*RoleEvent) GetName added in v0.19.80 

func (r *RoleEvent) GetName() string

func (*RoleEvent) GetRolePath added in v0.19.80 

func (r *RoleEvent) GetRolePath() string

func (*RoleEvent) GetState added in v0.19.80 

func (r *RoleEvent) GetState() string

func (*RoleEvent) GetStatus added in v0.19.80 

func (r *RoleEvent) GetStatus() string

func (*RoleEvent) GetTimestamp added in v0.19.80 

func (e *RoleEvent) GetTimestamp() string

func (*RoleEvent) SetLabels added in v0.48.0 

func (e *RoleEvent) SetLabels(labels map[string]string)

type TaskEvent added in v0.19.80 

type TaskEvent struct {
	Name      string
	TaskID    string
	Status    string
	State     string
	Hostname  string
	ClassName string
	// contains filtered or unexported fields
}

func (*TaskEvent) GetClassName added in v0.19.80 

func (r *TaskEvent) GetClassName() string

func (*TaskEvent) GetHostname added in v0.19.80 

func (r *TaskEvent) GetHostname() string

func (*TaskEvent) GetLabels added in v0.48.0 

func (e *TaskEvent) GetLabels() map[string]string

func (*TaskEvent) GetName added in v0.19.80 

func (r *TaskEvent) GetName() string

func (*TaskEvent) GetState added in v0.19.80 

func (r *TaskEvent) GetState() string

func (*TaskEvent) GetStatus added in v0.19.80 

func (r *TaskEvent) GetStatus() string

func (*TaskEvent) GetTaskID added in v0.19.80 

func (r *TaskEvent) GetTaskID() string

func (*TaskEvent) GetTimestamp added in v0.19.80 

func (e *TaskEvent) GetTimestamp() string

func (*TaskEvent) SetLabels added in v0.48.0 

func (e *TaskEvent) SetLabels(labels map[string]string)

type TaskInternalError added in v0.67.0 

type TaskInternalError struct {
	DeviceEventBase
}

func (*TaskInternalError) GetLabels added in v0.67.0 

func (e *TaskInternalError) GetLabels() map[string]string

func (*TaskInternalError) GetName added in v0.67.0 

func (e *TaskInternalError) GetName() string

func (*TaskInternalError) GetTimestamp added in v0.67.0 

func (e *TaskInternalError) GetTimestamp() string

func (*TaskInternalError) SetLabels added in v0.67.0 

func (e *TaskInternalError) SetLabels(labels map[string]string)

type TasksReleasedEvent added in v0.17.80 

type TasksReleasedEvent struct {
	EnvironmentId     uid.ID           `json:"environmentId"`
	TaskIdsReleased   []string         `json:"taskIdsReleased"`
	TaskReleaseErrors map[string]error `json:"taskReleaseErrors"`
	// contains filtered or unexported fields
}

func NewTasksReleasedEvent added in v0.17.80 

func NewTasksReleasedEvent(envId uid.ID, taskIdsReleased []string, taskReleaseErrors map[string]error) (tr *TasksReleasedEvent)

func (*TasksReleasedEvent) GetEnvironmentId added in v0.17.80 

func (tr *TasksReleasedEvent) GetEnvironmentId() uid.ID

func (*TasksReleasedEvent) GetLabels added in v0.48.0 

func (e *TasksReleasedEvent) GetLabels() map[string]string

func (*TasksReleasedEvent) GetName added in v0.17.80 

func (tr *TasksReleasedEvent) GetName() string

func (*TasksReleasedEvent) GetTaskIds added in v0.17.80 

func (tr *TasksReleasedEvent) GetTaskIds() []string

func (*TasksReleasedEvent) GetTaskReleaseErrors added in v0.17.80 

func (tr *TasksReleasedEvent) GetTaskReleaseErrors() map[string]error

func (*TasksReleasedEvent) GetTimestamp added in v0.17.80 

func (e *TasksReleasedEvent) GetTimestamp() string

func (*TasksReleasedEvent) SetLabels added in v0.48.0 

func (e *TasksReleasedEvent) SetLabels(labels map[string]string)

type TasksStateChangedEvent added in v0.17.81 

type TasksStateChangedEvent struct {
	EnvironmentId       uid.ID   `json:"environmentId"`
	TaskIdsStateChanged []string `json:"taskIdsStatesChanged"`
	TaskStateChangedErr error    `json:"taskStateChangedErr"`
	// contains filtered or unexported fields
}

func NewTasksStateChangedEvent added in v0.17.81 

func NewTasksStateChangedEvent(envId uid.ID, taskIdsChangeState []string, taskStateChangedErr error) (tr *TasksStateChangedEvent)

func (*TasksStateChangedEvent) GetEnvironmentId added in v0.17.81 

func (tr *TasksStateChangedEvent) GetEnvironmentId() uid.ID

func (*TasksStateChangedEvent) GetLabels added in v0.48.0 

func (e *TasksStateChangedEvent) GetLabels() map[string]string

func (*TasksStateChangedEvent) GetName added in v0.17.81 

func (tr *TasksStateChangedEvent) GetName() string

func (*TasksStateChangedEvent) GetTaskIds added in v0.17.81 

func (tr *TasksStateChangedEvent) GetTaskIds() []string

func (*TasksStateChangedEvent) GetTasksStateChangedError added in v0.17.81 

func (tr *TasksStateChangedEvent) GetTasksStateChangedError() error

func (*TasksStateChangedEvent) GetTimestamp added in v0.17.81 

func (e *TasksStateChangedEvent) GetTimestamp() string

func (*TasksStateChangedEvent) SetLabels added in v0.48.0 

func (e *TasksStateChangedEvent) SetLabels(labels map[string]string)

type Writer added in v1.7.0 

type Writer interface {
	WriteEvent(e interface{})
	WriteEventWithTimestamp(e interface{}, timestamp time.Time)
	Close()
}

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.