Documentation
¶
Index ¶
- Variables
- func SpansToPB(spans []SpanData) []*tracepb.ResourceSpans
- type Client
- func (c *Client) Engine(ctx context.Context, req EngineRequest) (*EngineSpec, error)
- func (c *Client) OrgByName(ctx context.Context, name string) (*OrgResponse, error)
- func (c *Client) StreamLogs(ctx context.Context, orgID string, traceID string, spanID string, ...) error
- func (c *Client) StreamSpans(ctx context.Context, orgID string, traceID string, handler func([]SpanData)) error
- func (c *Client) User(ctx context.Context) (*UserResponse, error)
- type EngineRequest
- type EngineSpec
- type ErrResponse
- type LogMessage
- type OrgResponse
- type SerializableCertificate
- type SpanData
- type SpanEvent
- type SpanLink
- type SpanScope
- type SpanStatus
- type UserResponse
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrNoOrg = errors.New("no org associated with this Engine")
Functions ¶
func SpansToPB ¶ added in v0.20.0
func SpansToPB(spans []SpanData) []*tracepb.ResourceSpans
SpansToPB converts Cloud API SpanData into OTLP ResourceSpans proto, suitable for feeding through telemetry.SpansFromPB and into a SpanExporter.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func (*Client) Engine ¶ added in v0.18.9
func (c *Client) Engine(ctx context.Context, req EngineRequest) (*EngineSpec, error)
func (*Client) StreamLogs ¶ added in v0.20.0
func (c *Client) StreamLogs( ctx context.Context, orgID string, traceID string, spanID string, handler func([]LogMessage), ) error
StreamLogs streams log messages for a trace from Dagger Cloud's GraphQL API.
type EngineRequest ¶ added in v0.19.1
type EngineRequest struct {
Module string `json:"module,omitempty"`
Function string ` json:"function,omitempty"`
ExecCmd []string `json:"exec_cmd,omitempty"`
ClientID string `json:"client_id,omitempty"`
MinimumEngineVersion string `json:"minimum_engine_version,omitempty"`
TraceID string `json:"trace_id,omitempty"`
}
type EngineSpec ¶ added in v0.18.9
type EngineSpec struct {
EngineRequest
Image string `json:"image,omitempty"`
Location string `json:"location,omitempty"`
OrgID string `json:"org_id,omitempty"`
UserID string `json:"user_id,omitempty"`
URL string `json:"url,omitempty"`
CertSerialized *SerializableCertificate `json:"cert,omitempty"`
InstanceID string `json:"instance_id,omitempty"`
}
func (*EngineSpec) TLSCertificate ¶ added in v0.18.9
func (es *EngineSpec) TLSCertificate() (*tls.Certificate, error)
type ErrResponse ¶ added in v0.18.9
type ErrResponse struct {
Message string `json:"message"`
}
type LogMessage ¶ added in v0.20.0
type OrgResponse ¶ added in v0.20.0
type SerializableCertificate ¶ added in v0.18.9
type SpanData ¶ added in v0.20.0
type SpanData struct {
ID string `json:"id"`
TraceID string `json:"traceId"`
TraceState string `json:"traceState"`
Name string `json:"name"`
ParentID *string `json:"parentId"`
Kind string `json:"kind"`
Timestamp time.Time `json:"timestamp"`
EndTime *time.Time `json:"endTime"`
UpdateTime time.Time `json:"updateTime"`
Attributes map[string]any `json:"attributes"`
Status SpanStatus `json:"status"`
Events []SpanEvent `json:"events"`
Links []SpanLink `json:"links"`
Scope SpanScope `json:"scope"`
HasLogs bool `json:"hasLogs"`
ChildCount int `json:"childCount"`
Partial bool `json:"partial"`
}
type SpanStatus ¶ added in v0.20.0
type UserResponse ¶
Click to show internal directories.
Click to hide internal directories.