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

v0

package
v0.2.48 Latest Latest
Warning

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

Go to latest
Published: Jul 28, 2026 License: MIT Imports: 6 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	GraphNode_Type_name = map[int32]string{
		0: "MODULE",
		1: "SERVICE",
		2: "ENDPOINT",
	}
	GraphNode_Type_value = map[string]int32{
		"MODULE":   0,
		"SERVICE":  1,
		"ENDPOINT": 2,
	}
)

Enum value maps for GraphNode_Type.

View Source
var File_codefly_observability_v0_dependencies_proto protoreflect.FileDescriptor
View Source
var File_codefly_observability_v0_inventory_proto protoreflect.FileDescriptor
View Source
var File_codefly_observability_v0_logs_proto protoreflect.FileDescriptor
View Source
var File_codefly_observability_v0_metrics_proto protoreflect.FileDescriptor
View Source
var File_codefly_observability_v0_sessions_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type CPU

type CPU struct {

	// timestamp is when the event, call, or record was produced.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// usage is CPU utilization as a fraction or percentage, depending on the collector.
	Usage float64 `protobuf:"fixed64,2,opt,name=usage,proto3" json:"usage,omitempty"`
	// contains filtered or unexported fields
}

CPU records point-in-time CPU utilization for a running Codefly process or service.

func (*CPU) Descriptor deprecated

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

Deprecated: Use CPU.ProtoReflect.Descriptor instead.

func (*CPU) GetTimestamp

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

func (*CPU) GetUsage

func (x *CPU) GetUsage() float64

func (*CPU) ProtoMessage

func (*CPU) ProtoMessage()

func (*CPU) ProtoReflect

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

func (*CPU) Reset

func (x *CPU) Reset()

func (*CPU) String

func (x *CPU) String() string

type GraphEdge

type GraphEdge struct {

	// from is the source node id.
	From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	// to is the target node id.
	To string `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"`
	// contains filtered or unexported fields
}

GraphEdge connects two nodes in a workspace architecture graph.

func (*GraphEdge) Descriptor deprecated

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

Deprecated: Use GraphEdge.ProtoReflect.Descriptor instead.

func (*GraphEdge) GetFrom

func (x *GraphEdge) GetFrom() string

func (*GraphEdge) GetTo

func (x *GraphEdge) GetTo() string

func (*GraphEdge) ProtoMessage

func (*GraphEdge) ProtoMessage()

func (*GraphEdge) ProtoReflect

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

func (*GraphEdge) Reset

func (x *GraphEdge) Reset()

func (*GraphEdge) String

func (x *GraphEdge) String() string

type GraphNode

type GraphNode struct {

	// id is the stable identifier for this record.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// type identifies whether this graph node is a module, service, or endpoint.
	Type GraphNode_Type `protobuf:"varint,2,opt,name=type,proto3,enum=codefly.observability.v0.GraphNode_Type" json:"type,omitempty"`
	// contains filtered or unexported fields
}

GraphNode represents a node in an architecture graph Type can be "module", "service" or "endpoint"

func (*GraphNode) Descriptor deprecated

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

Deprecated: Use GraphNode.ProtoReflect.Descriptor instead.

func (*GraphNode) GetId

func (x *GraphNode) GetId() string

func (*GraphNode) GetType

func (x *GraphNode) GetType() GraphNode_Type

func (*GraphNode) ProtoMessage

func (*GraphNode) ProtoMessage()

func (*GraphNode) ProtoReflect

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

func (*GraphNode) Reset

func (x *GraphNode) Reset()

func (*GraphNode) String

func (x *GraphNode) String() string

type GraphNode_Type

type GraphNode_Type int32

Type enumerates supported types.

const (
	// MODULE nodes represent Codefly modules.
	GraphNode_MODULE GraphNode_Type = 0
	// SERVICE nodes represent Codefly services.
	GraphNode_SERVICE GraphNode_Type = 1
	// ENDPOINT nodes represent service endpoints.
	GraphNode_ENDPOINT GraphNode_Type = 2
)

func (GraphNode_Type) Descriptor

func (GraphNode_Type) Enum

func (x GraphNode_Type) Enum() *GraphNode_Type

func (GraphNode_Type) EnumDescriptor deprecated

func (GraphNode_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use GraphNode_Type.Descriptor instead.

func (GraphNode_Type) Number

func (GraphNode_Type) String

func (x GraphNode_Type) String() string

func (GraphNode_Type) Type

type GraphResponse

type GraphResponse struct {

	// nodes are graph vertices representing modules, services, or endpoints.
	Nodes []*GraphNode `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// edges are graph relationships between returned nodes.
	Edges []*GraphEdge `protobuf:"bytes,2,rep,name=edges,proto3" json:"edges,omitempty"`
	// contains filtered or unexported fields
}

GraphResponse contains a workspace or module dependency graph.

func (*GraphResponse) Descriptor deprecated

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

Deprecated: Use GraphResponse.ProtoReflect.Descriptor instead.

func (*GraphResponse) GetEdges

func (x *GraphResponse) GetEdges() []*GraphEdge

func (*GraphResponse) GetNodes

func (x *GraphResponse) GetNodes() []*GraphNode

func (*GraphResponse) ProtoMessage

func (*GraphResponse) ProtoMessage()

func (*GraphResponse) ProtoReflect

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

func (*GraphResponse) Reset

func (x *GraphResponse) Reset()

func (*GraphResponse) String

func (x *GraphResponse) String() string

type Log

type Log struct {

	// at is the timestamp for the log or session snapshot.
	At *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=at,proto3" json:"at,omitempty"`
	// module is the Codefly module name that groups services.
	Module string `protobuf:"bytes,2,opt,name=module,proto3" json:"module,omitempty"`
	// service is the Codefly service name, optionally scoped by module in callers.
	Service string `protobuf:"bytes,3,opt,name=service,proto3" json:"service,omitempty"`
	// kind classifies the log event, such as lifecycle, output, or diagnostic.
	Kind string `protobuf:"bytes,4,opt,name=kind,proto3" json:"kind,omitempty"`
	// message is a human-readable status or diagnostic summary.
	Message string `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

Log is a timestamped workspace event emitted by a Codefly flow or agent.

func (*Log) Descriptor deprecated

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

Deprecated: Use Log.ProtoReflect.Descriptor instead.

func (*Log) GetAt

func (x *Log) GetAt() *timestamppb.Timestamp

func (*Log) GetKind

func (x *Log) GetKind() string

func (*Log) GetMessage

func (x *Log) GetMessage() string

func (*Log) GetModule

func (x *Log) GetModule() string

func (*Log) GetService

func (x *Log) GetService() string

func (*Log) ProtoMessage

func (*Log) ProtoMessage()

func (*Log) ProtoReflect

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

func (*Log) Reset

func (x *Log) Reset()

func (*Log) String

func (x *Log) String() string

type LogRequest

type LogRequest struct {

	// from is the beginning of the requested time range.
	From *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	// to is the end of the requested time range.
	To *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"`
	// contains filtered or unexported fields
}

LogRequest selects a time range for log history.

func (*LogRequest) Descriptor deprecated

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

Deprecated: Use LogRequest.ProtoReflect.Descriptor instead.

func (*LogRequest) GetFrom

func (x *LogRequest) GetFrom() *timestamppb.Timestamp

func (*LogRequest) GetTo

func (x *LogRequest) GetTo() *timestamppb.Timestamp

func (*LogRequest) ProtoMessage

func (*LogRequest) ProtoMessage()

func (*LogRequest) ProtoReflect

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

func (*LogRequest) Reset

func (x *LogRequest) Reset()

func (*LogRequest) String

func (x *LogRequest) String() string

type LogResponse

type LogResponse struct {

	// groups are log events grouped by workspace session.
	Groups []*LogSessionGroup `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,omitempty"`
	// contains filtered or unexported fields
}

LogResponse returns log groups for the requested time range.

func (*LogResponse) Descriptor deprecated

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

Deprecated: Use LogResponse.ProtoReflect.Descriptor instead.

func (*LogResponse) GetGroups

func (x *LogResponse) GetGroups() []*LogSessionGroup

func (*LogResponse) ProtoMessage

func (*LogResponse) ProtoMessage()

func (*LogResponse) ProtoReflect

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

func (*LogResponse) Reset

func (x *LogResponse) Reset()

func (*LogResponse) String

func (x *LogResponse) String() string

type LogSessionGroup

type LogSessionGroup struct {

	// session identifies the workspace snapshot these logs belong to.
	Session *Session `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	// logs are events recorded for this session.
	Logs []*Log `protobuf:"bytes,2,rep,name=logs,proto3" json:"logs,omitempty"`
	// contains filtered or unexported fields
}

LogSessionGroup groups log events under one recorded workspace session.

func (*LogSessionGroup) Descriptor deprecated

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

Deprecated: Use LogSessionGroup.ProtoReflect.Descriptor instead.

func (*LogSessionGroup) GetLogs

func (x *LogSessionGroup) GetLogs() []*Log

func (*LogSessionGroup) GetSession

func (x *LogSessionGroup) GetSession() *Session

func (*LogSessionGroup) ProtoMessage

func (*LogSessionGroup) ProtoMessage()

func (*LogSessionGroup) ProtoReflect

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

func (*LogSessionGroup) Reset

func (x *LogSessionGroup) Reset()

func (*LogSessionGroup) String

func (x *LogSessionGroup) String() string

type Memory

type Memory struct {

	// timestamp is when the event, call, or record was produced.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// usage is memory utilization as reported by the collector.
	Usage float64 `protobuf:"fixed64,2,opt,name=usage,proto3" json:"usage,omitempty"`
	// contains filtered or unexported fields
}

Memory records point-in-time memory utilization for a running Codefly process or service.

func (*Memory) Descriptor deprecated

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

Deprecated: Use Memory.ProtoReflect.Descriptor instead.

func (*Memory) GetTimestamp

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

func (*Memory) GetUsage

func (x *Memory) GetUsage() float64

func (*Memory) ProtoMessage

func (*Memory) ProtoMessage()

func (*Memory) ProtoReflect

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

func (*Memory) Reset

func (x *Memory) Reset()

func (*Memory) String

func (x *Memory) String() string

type ModuleSnapshot

type ModuleSnapshot struct {

	// uuid is the durable identifier for the snapshot or session.
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// name is the module name captured in this snapshot.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// workspace is the Codefly workspace name that scopes modules and services.
	Workspace *WorkspaceSnapshot `protobuf:"bytes,3,opt,name=workspace,proto3" json:"workspace,omitempty"`
	// contains filtered or unexported fields
}

ModuleSnapshot captures module identity and its workspace snapshot.

func (*ModuleSnapshot) Descriptor deprecated

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

Deprecated: Use ModuleSnapshot.ProtoReflect.Descriptor instead.

func (*ModuleSnapshot) GetName

func (x *ModuleSnapshot) GetName() string

func (*ModuleSnapshot) GetUuid

func (x *ModuleSnapshot) GetUuid() string

func (*ModuleSnapshot) GetWorkspace

func (x *ModuleSnapshot) GetWorkspace() *WorkspaceSnapshot

func (*ModuleSnapshot) ProtoMessage

func (*ModuleSnapshot) ProtoMessage()

func (*ModuleSnapshot) ProtoReflect

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

func (*ModuleSnapshot) Reset

func (x *ModuleSnapshot) Reset()

func (*ModuleSnapshot) String

func (x *ModuleSnapshot) String() string

type PartialSnapshot

type PartialSnapshot struct {

	// uuid is the durable identifier for the snapshot or session.
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// name is the snapshot display name.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// workspace is the Codefly workspace name that scopes modules and services.
	Workspace *WorkspaceSnapshot `protobuf:"bytes,3,opt,name=workspace,proto3" json:"workspace,omitempty"`
	// modules are the module snapshots known at this point in time.
	Modules []*ModuleSnapshot `protobuf:"bytes,4,rep,name=modules,proto3" json:"modules,omitempty"`
	// contains filtered or unexported fields
}

PartialSnapshot captures a workspace and the modules known for a recorded session.

func (*PartialSnapshot) Descriptor deprecated

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

Deprecated: Use PartialSnapshot.ProtoReflect.Descriptor instead.

func (*PartialSnapshot) GetModules

func (x *PartialSnapshot) GetModules() []*ModuleSnapshot

func (*PartialSnapshot) GetName

func (x *PartialSnapshot) GetName() string

func (*PartialSnapshot) GetUuid

func (x *PartialSnapshot) GetUuid() string

func (*PartialSnapshot) GetWorkspace

func (x *PartialSnapshot) GetWorkspace() *WorkspaceSnapshot

func (*PartialSnapshot) ProtoMessage

func (*PartialSnapshot) ProtoMessage()

func (*PartialSnapshot) ProtoReflect

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

func (*PartialSnapshot) Reset

func (x *PartialSnapshot) Reset()

func (*PartialSnapshot) String

func (x *PartialSnapshot) String() string

type Session

type Session struct {

	// uuid is the durable identifier for the snapshot or session.
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// at is the timestamp for the log or session snapshot.
	At *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=at,proto3" json:"at,omitempty"`
	// session selects the snapshot granularity recorded for this session.
	//
	// Types that are valid to be assigned to Session:
	//
	//	*Session_Partial
	//	*Session_Module
	Session isSession_Session `protobuf_oneof:"session"`
	// contains filtered or unexported fields
}

Session records a point-in-time workspace/module snapshot.

func (*Session) Descriptor deprecated

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

Deprecated: Use Session.ProtoReflect.Descriptor instead.

func (*Session) GetAt

func (x *Session) GetAt() *timestamppb.Timestamp

func (*Session) GetModule

func (x *Session) GetModule() *ModuleSnapshot

func (*Session) GetPartial

func (x *Session) GetPartial() *PartialSnapshot

func (*Session) GetSession

func (x *Session) GetSession() isSession_Session

func (*Session) GetUuid

func (x *Session) GetUuid() string

func (*Session) ProtoMessage

func (*Session) ProtoMessage()

func (*Session) ProtoReflect

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

func (*Session) Reset

func (x *Session) Reset()

func (*Session) String

func (x *Session) String() string

type Session_Module

type Session_Module struct {
	// module carries a module-level snapshot.
	Module *ModuleSnapshot `protobuf:"bytes,4,opt,name=module,proto3,oneof"`
}

type Session_Partial

type Session_Partial struct {
	// partial carries the PartialSnapshot variant for Session.
	Partial *PartialSnapshot `protobuf:"bytes,3,opt,name=partial,proto3,oneof"`
}

type WorkspaceInformationRequest

type WorkspaceInformationRequest struct {

	// workspace is the Codefly workspace name that scopes modules and services.
	Workspace string `protobuf:"bytes,1,opt,name=workspace,proto3" json:"workspace,omitempty"`
	// contains filtered or unexported fields
}

WorkspaceInformationRequest identifies the workspace whose inventory should be inspected.

func (*WorkspaceInformationRequest) Descriptor deprecated

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

Deprecated: Use WorkspaceInformationRequest.ProtoReflect.Descriptor instead.

func (*WorkspaceInformationRequest) GetWorkspace

func (x *WorkspaceInformationRequest) GetWorkspace() string

func (*WorkspaceInformationRequest) ProtoMessage

func (*WorkspaceInformationRequest) ProtoMessage()

func (*WorkspaceInformationRequest) ProtoReflect

func (*WorkspaceInformationRequest) Reset

func (x *WorkspaceInformationRequest) Reset()

func (*WorkspaceInformationRequest) String

func (x *WorkspaceInformationRequest) String() string

type WorkspaceSnapshot

type WorkspaceSnapshot struct {

	// uuid is the durable identifier for the snapshot or session.
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// name is the workspace name captured in this snapshot.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

WorkspaceSnapshot captures workspace identity at the time a session was recorded.

func (*WorkspaceSnapshot) Descriptor deprecated

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

Deprecated: Use WorkspaceSnapshot.ProtoReflect.Descriptor instead.

func (*WorkspaceSnapshot) GetName

func (x *WorkspaceSnapshot) GetName() string

func (*WorkspaceSnapshot) GetUuid

func (x *WorkspaceSnapshot) GetUuid() string

func (*WorkspaceSnapshot) ProtoMessage

func (*WorkspaceSnapshot) ProtoMessage()

func (*WorkspaceSnapshot) ProtoReflect

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

func (*WorkspaceSnapshot) Reset

func (x *WorkspaceSnapshot) Reset()

func (*WorkspaceSnapshot) String

func (x *WorkspaceSnapshot) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL