internal

Documentation

Overview

Package internal contains internal helper types and functions.

Index

• func GetImageVersionFromDockerfile() (string, error)
• func ParseJSON(reader io.ReadCloser, v any) error
• func Ptr[T any](value T) *T
• func UnmarshalNDJSON(ctx context.Context, r io.Reader) iter.Seq2[Line, error]
• type CloudEvent
• type Error
• type Line
• type StreamEventType
• type StreamSubject

Functions

func GetImageVersionFromDockerfile

func GetImageVersionFromDockerfile() (string, error)

func ParseJSON

func ParseJSON(reader io.ReadCloser, v any) error

func Ptr

func Ptr[T any](value T) *T

func UnmarshalNDJSON

func UnmarshalNDJSON(ctx context.Context, r io.Reader) iter.Seq2[Line, error]

Types

type CloudEvent

type CloudEvent struct {
	SpecVersion     string          `json:"specversion"`
	ID              string          `json:"id"`
	Time            string          `json:"time"`
	Source          string          `json:"source"`
	Subject         string          `json:"subject"`
	Type            string          `json:"type"`
	DataContentType string          `json:"datacontenttype"`
	Data            json.RawMessage `json:"data"`
	Hash            string          `json:"hash"`
	PredecessorHash string          `json:"predecessorhash"`
	TraceParent     *string         `json:"traceparent"`
	TraceState      *string         `json:"tracestate"`
	Signature       *string         `json:"signature"`
}

type Error

type Error struct {
	Error string `json:"error"`
}

type Line

type Line struct {
	Type    string
	Payload json.RawMessage
}

type StreamEventType

type StreamEventType struct {
	EventType string          `json:"eventType"`
	IsPhantom bool            `json:"isPhantom"`
	Schema    *map[string]any `json:"schema,omitempty"`
}

type StreamSubject

type StreamSubject struct {
	Subject string `json:"subject"`
}