events

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Dec 6, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Overview

Copyright (c) Ultraviolet SPDX-License-Identifier: Apache-2.0

Index

Constants

This section is empty.

Variables

View Source 
var File_agent_events_events_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AgentEvent 

type AgentEvent struct {
	EventType     string                 `protobuf:"bytes,1,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
	Timestamp     *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	ComputationId string                 `protobuf:"bytes,3,opt,name=computation_id,json=computationId,proto3" json:"computation_id,omitempty"`
	Details       []byte                 `protobuf:"bytes,4,opt,name=details,proto3" json:"details,omitempty"`
	Originator    string                 `protobuf:"bytes,5,opt,name=originator,proto3" json:"originator,omitempty"`
	Status        string                 `protobuf:"bytes,6,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentEvent) Descriptor deprecated added in v0.4.0 

func (*AgentEvent) Descriptor() ([]byte, []int)

Deprecated: Use AgentEvent.ProtoReflect.Descriptor instead.

func (*AgentEvent) GetComputationId added in v0.4.0 

func (x *AgentEvent) GetComputationId() string

func (*AgentEvent) GetDetails added in v0.4.0 

func (x *AgentEvent) GetDetails() []byte

func (*AgentEvent) GetEventType added in v0.4.0 

func (x *AgentEvent) GetEventType() string

func (*AgentEvent) GetOriginator added in v0.4.0 

func (x *AgentEvent) GetOriginator() string

func (*AgentEvent) GetStatus added in v0.4.0 

func (x *AgentEvent) GetStatus() string

func (*AgentEvent) GetTimestamp added in v0.4.0 

func (x *AgentEvent) GetTimestamp() *timestamppb.Timestamp

func (*AgentEvent) ProtoMessage added in v0.4.0 

func (*AgentEvent) ProtoMessage()

func (*AgentEvent) ProtoReflect added in v0.4.0 

func (x *AgentEvent) ProtoReflect() protoreflect.Message

func (*AgentEvent) Reset added in v0.4.0 

func (x *AgentEvent) Reset()

func (*AgentEvent) String added in v0.4.0 

func (x *AgentEvent) String() string

type AgentLog added in v0.4.0 

type AgentLog struct {
	Message       string                 `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	ComputationId string                 `protobuf:"bytes,2,opt,name=computation_id,json=computationId,proto3" json:"computation_id,omitempty"`
	Level         string                 `protobuf:"bytes,3,opt,name=level,proto3" json:"level,omitempty"`
	Timestamp     *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentLog) Descriptor deprecated added in v0.4.0 

func (*AgentLog) Descriptor() ([]byte, []int)

Deprecated: Use AgentLog.ProtoReflect.Descriptor instead.

func (*AgentLog) GetComputationId added in v0.4.0 

func (x *AgentLog) GetComputationId() string

func (*AgentLog) GetLevel added in v0.4.0 

func (x *AgentLog) GetLevel() string

func (*AgentLog) GetMessage added in v0.4.0 

func (x *AgentLog) GetMessage() string

func (*AgentLog) GetTimestamp added in v0.4.0 

func (x *AgentLog) GetTimestamp() *timestamppb.Timestamp

func (*AgentLog) ProtoMessage added in v0.4.0 

func (*AgentLog) ProtoMessage()

func (*AgentLog) ProtoReflect added in v0.4.0 

func (x *AgentLog) ProtoReflect() protoreflect.Message

func (*AgentLog) Reset added in v0.4.0 

func (x *AgentLog) Reset()

func (*AgentLog) String added in v0.4.0 

func (x *AgentLog) String() string

type EventsLogs added in v0.4.0 

type EventsLogs struct {

	// Types that are assignable to Message:
	//
	//	*EventsLogs_AgentLog
	//	*EventsLogs_AgentEvent
	Message isEventsLogs_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

func (*EventsLogs) Descriptor deprecated added in v0.4.0 

func (*EventsLogs) Descriptor() ([]byte, []int)

Deprecated: Use EventsLogs.ProtoReflect.Descriptor instead.

func (*EventsLogs) GetAgentEvent added in v0.4.0 

func (x *EventsLogs) GetAgentEvent() *AgentEvent

func (*EventsLogs) GetAgentLog added in v0.4.0 

func (x *EventsLogs) GetAgentLog() *AgentLog

func (*EventsLogs) GetMessage added in v0.4.0 

func (m *EventsLogs) GetMessage() isEventsLogs_Message

func (*EventsLogs) ProtoMessage added in v0.4.0 

func (*EventsLogs) ProtoMessage()

func (*EventsLogs) ProtoReflect added in v0.4.0 

func (x *EventsLogs) ProtoReflect() protoreflect.Message

func (*EventsLogs) Reset added in v0.4.0 

func (x *EventsLogs) Reset()

func (*EventsLogs) String added in v0.4.0 

func (x *EventsLogs) String() string

type EventsLogs_AgentEvent added in v0.4.0 

type EventsLogs_AgentEvent struct {
	AgentEvent *AgentEvent `protobuf:"bytes,2,opt,name=agent_event,json=agentEvent,proto3,oneof"`
}

type EventsLogs_AgentLog added in v0.4.0 

type EventsLogs_AgentLog struct {
	AgentLog *AgentLog `protobuf:"bytes,1,opt,name=agent_log,json=agentLog,proto3,oneof"`
}

type Service 

type Service interface {
	SendEvent(event, status string, details json.RawMessage) error
}

func New 

func New(svc, computationID string, conn io.Writer) (Service, error)

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.