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

write

package
v0.1.58 Latest Latest
Warning

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

 Go to latest Published: Oct 26, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const MaxErrorMessageBytes = 60000
View Source 
const WriterDatlyResourceNamespace = "datly_toolcall_write_writer"

DatlyResourceNamespace identifies this package's generated resource filesystem.

Variables

View Source 
var (
	LifecycleHooks = new(Lifecycle)
	LifecycleDatly = LifecycleDatlyType()
)
View Source 
var WriterDatly = new(WriterComponent)

The public value supports explicit component wiring.

View Source 
var WriterDatlyResources embed.FS

Functions

func LifecycleDatlyType 

func LifecycleDatlyType() reflect.Type

func SanitizeErrorMessage 

func SanitizeErrorMessage(value string) string

SanitizeErrorMessage returns a DB-safe, UTF-8-valid tool error summary.

func WriterDatlyType 

func WriterDatlyType() reflect.Type

WriterDatlyType returns the public component type.

func WriterHandlerCurrentWriterIndexByAttemptKey 

func WriterHandlerCurrentWriterIndexByAttemptKey(value *CurrentWriterView) (int, bool)

func WriterHandlerCurrentWriterIndexByCompletedAtKey 

func WriterHandlerCurrentWriterIndexByCompletedAtKey(value *CurrentWriterView) (time.Time, bool)

func WriterHandlerCurrentWriterIndexByCostKey 

func WriterHandlerCurrentWriterIndexByCostKey(value *CurrentWriterView) (float64, bool)

func WriterHandlerCurrentWriterIndexByErrorCodeKey 

func WriterHandlerCurrentWriterIndexByErrorCodeKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByErrorMessageKey 

func WriterHandlerCurrentWriterIndexByErrorMessageKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByIterationKey 

func WriterHandlerCurrentWriterIndexByIterationKey(value *CurrentWriterView) (int, bool)

func WriterHandlerCurrentWriterIndexByLatencyMsKey 

func WriterHandlerCurrentWriterIndexByLatencyMsKey(value *CurrentWriterView) (int, bool)

func WriterHandlerCurrentWriterIndexByMessageIdKey 

func WriterHandlerCurrentWriterIndexByMessageIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByOpIdKey 

func WriterHandlerCurrentWriterIndexByOpIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByRequestHashKey 

func WriterHandlerCurrentWriterIndexByRequestHashKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByRequestPayloadIdKey 

func WriterHandlerCurrentWriterIndexByRequestPayloadIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByResponseOverflowKey 

func WriterHandlerCurrentWriterIndexByResponseOverflowKey(value *CurrentWriterView) (bool, bool)

func WriterHandlerCurrentWriterIndexByResponsePayloadIdKey 

func WriterHandlerCurrentWriterIndexByResponsePayloadIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByRetriableKey 

func WriterHandlerCurrentWriterIndexByRetriableKey(value *CurrentWriterView) (int, bool)

func WriterHandlerCurrentWriterIndexByRunIdKey 

func WriterHandlerCurrentWriterIndexByRunIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexBySpanIdKey 

func WriterHandlerCurrentWriterIndexBySpanIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByStartedAtKey 

func WriterHandlerCurrentWriterIndexByStartedAtKey(value *CurrentWriterView) (time.Time, bool)

func WriterHandlerCurrentWriterIndexByStatusKey 

func WriterHandlerCurrentWriterIndexByStatusKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByToolKindKey 

func WriterHandlerCurrentWriterIndexByToolKindKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByToolNameKey 

func WriterHandlerCurrentWriterIndexByToolNameKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByTraceIdKey 

func WriterHandlerCurrentWriterIndexByTraceIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByTurnIdKey 

func WriterHandlerCurrentWriterIndexByTurnIdKey(value *CurrentWriterView) (string, bool)

Types

type CurrentWriterView 

type CurrentWriterView struct {
	ResponseOverflow  bool       `sqlx:"response_overflow" json:"responseOverflow,omitempty"`
	MessageId         string     `validate:"required" sqlx:"message_id,primaryKey,refTable=message,refColumn=id" json:"messageId"`
	OpId              string     `validate:"required" json:"opId" sqlx:"op_id,required=true"`
	Attempt           int        `json:"attempt" sqlx:"attempt,required=true"`
	ToolName          string     `validate:"required" json:"toolName" sqlx:"tool_name,required=true"`
	ToolKind          string     `validate:"required" json:"toolKind" sqlx:"tool_kind,required=true"`
	Status            string     `validate:"required" json:"status" sqlx:"status,required=true"`
	Cost              *float64   `sqlx:"cost" json:"cost,omitempty"`
	RequestPayloadId  *string    `json:"requestPayloadId" sqlx:"request_payload_id,refTable=call_payload,refColumn=id"`
	ResponsePayloadId *string    `json:"responsePayloadId" sqlx:"response_payload_id,refTable=call_payload,refColumn=id"`
	TurnId            *string    `sqlx:"turn_id,refTable=turn,refColumn=id" json:"turnId,omitempty"`
	RequestHash       *string    `sqlx:"request_hash" json:"requestHash,omitempty"`
	ErrorCode         *string    `sqlx:"error_code" json:"errorCode,omitempty"`
	ErrorMessage      *string    `sqlx:"error_message" json:"errorMessage,omitempty"`
	Retriable         *int       `sqlx:"retriable" json:"retriable,omitempty"`
	StartedAt         *time.Time `sqlx:"started_at" json:"startedAt,omitempty"`
	CompletedAt       *time.Time `sqlx:"completed_at" json:"completedAt,omitempty"`
	LatencyMs         *int       `sqlx:"latency_ms" json:"latencyMs,omitempty"`
	TraceId           *string    `sqlx:"trace_id" json:"traceId,omitempty"`
	SpanId            *string    `sqlx:"span_id" json:"spanId,omitempty"`
	RunId             *string    `sqlx:"run_id" json:"runId,omitempty"`
	Iteration         *int       `sqlx:"iteration" json:"iteration,omitempty"`
}

CurrentWriterView is generated canonical view metadata for writer.

type Input 

type Input struct {
	OrphanDetach  bool                 `parameter:"OrphanDetach,kind=orphandetach,in=enabledDetach,dataType=bool,required=false"`
	OrphanColumn  string               `parameter:"OrphanColumn,kind=orphandetach,in=column,dataType=string,required=false"`
	ToolCalls     []*ToolCall          `` /* 203-byte string literal not displayed */
	WriterKeys    []WriterKeysRow      `` /* 134-byte string literal not displayed */
	CurrentWriter []*CurrentWriterView `` /* 167-byte string literal not displayed */

	Has *InputHas `setMarker:"true" typeName:"InputHas" json:"-" sqlx:"-"`
	// contains filtered or unexported fields
}

Input is the generated input scaffold for writer.

func (*Input) Init 

func (input *Input) Init(context.Context) error

func (*Input) PrepareReadIndexes 

func (input *Input) PrepareReadIndexes(ctx context.Context) error

func (*Input) ReadIndexes 

func (input *Input) ReadIndexes(ctx context.Context) (*WriterHandlerReadIndexes, error)

func (*Input) SetCurrentWriter 

func (input *Input) SetCurrentWriter(value []*CurrentWriterView)

func (*Input) SetOrphanColumn 

func (input *Input) SetOrphanColumn(value string)

func (*Input) SetOrphanDetach 

func (input *Input) SetOrphanDetach(value bool)

func (*Input) SetToolCalls 

func (input *Input) SetToolCalls(value []*ToolCall)

func (*Input) SetWriterKeys 

func (input *Input) SetWriterKeys(value []WriterKeysRow)

type InputHas 

type InputHas struct {
	OrphanDetach  bool
	OrphanColumn  bool
	ToolCalls     bool
	WriterKeys    bool
	CurrentWriter bool
}

type Lifecycle 

type Lifecycle struct {
	Input *Input `bind:"kind=input"`
}

Lifecycle customizes role Input.ToolCalls.

func (*Lifecycle) AfterQueue 

func (hooks *Lifecycle) AfterQueue(ctx context.Context, entity *ToolCall, state xhandler.LifecycleContext[ToolCall, xhandler.NoParent, Output]) error

func (*Lifecycle) AfterSequence 

func (hooks *Lifecycle) AfterSequence(ctx context.Context, entity *ToolCall, state xhandler.LifecycleContext[ToolCall, xhandler.NoParent, Output]) error

func (*Lifecycle) Finalize 

func (hooks *Lifecycle) Finalize(ctx context.Context, input *Input, output *Output, outcome xhandler.Outcome) error

func (*Lifecycle) Init 

func (hooks *Lifecycle) Init(ctx context.Context, entity *ToolCall, state xhandler.LifecycleContext[ToolCall, xhandler.NoParent, Output]) error

func (*Lifecycle) Validate 

func (hooks *Lifecycle) Validate(ctx context.Context, entity *ToolCall, state xhandler.LifecycleContext[ToolCall, xhandler.NoParent, Output]) error

type Output 

type Output struct {
	Data []*ToolCall `parameter:"Data,kind=output,in=body,dataType=[]*ToolCall" json:"data,omitempty"`
}

Output is the generated output scaffold for writer.

type ToolCall 

type ToolCall struct {
	ShouldDelete      bool         `sqlx:"-" writer:"delete" json:"shouldDelete,omitempty"`
	ResponseOverflow  bool         `sqlx:"-" json:"responseOverflow,omitempty"`
	MessageId         string       `validate:"required" sqlx:"message_id,primaryKey,refTable=message,refColumn=id" json:"messageId"`
	OpId              string       `validate:"required" json:"opId" sqlx:"op_id,required=true"`
	Attempt           int          `json:"attempt" sqlx:"attempt,required=true"`
	ToolName          string       `validate:"required" json:"toolName" sqlx:"tool_name,required=true"`
	ToolKind          string       `validate:"required" json:"toolKind" sqlx:"tool_kind,required=true"`
	Status            string       `validate:"required" json:"status" sqlx:"status,required=true"`
	Cost              *float64     `sqlx:"cost" json:"cost,omitempty"`
	RequestPayloadId  *string      `json:"requestPayloadId" sqlx:"request_payload_id,refTable=call_payload,refColumn=id"`
	ResponsePayloadId *string      `json:"responsePayloadId" sqlx:"response_payload_id,refTable=call_payload,refColumn=id"`
	TurnId            *string      `sqlx:"turn_id,refTable=turn,refColumn=id" json:"turnId,omitempty"`
	RequestHash       *string      `sqlx:"request_hash" json:"requestHash,omitempty"`
	ErrorCode         *string      `sqlx:"error_code" json:"errorCode,omitempty"`
	ErrorMessage      *string      `sqlx:"error_message" json:"errorMessage,omitempty"`
	Retriable         *int         `sqlx:"retriable" json:"retriable,omitempty"`
	StartedAt         *time.Time   `sqlx:"started_at" json:"startedAt,omitempty"`
	CompletedAt       *time.Time   `sqlx:"completed_at" json:"completedAt,omitempty"`
	LatencyMs         *int         `sqlx:"latency_ms" json:"latencyMs,omitempty"`
	TraceId           *string      `sqlx:"trace_id" json:"traceId,omitempty"`
	SpanId            *string      `sqlx:"span_id" json:"spanId,omitempty"`
	RunId             *string      `sqlx:"run_id" json:"runId,omitempty"`
	Iteration         *int         `sqlx:"iteration" json:"iteration,omitempty"`
	Has               *ToolCallHas `setMarker:"true" format:"-" sqlx:"-" diff:"-" json:"-" typeName:"ToolCallHas"`
}

ToolCall is generated canonical view metadata for writer.

func (*ToolCall) GetAttempt 

func (entity *ToolCall) GetAttempt() int

func (*ToolCall) GetCompletedAt 

func (entity *ToolCall) GetCompletedAt() *time.Time

func (*ToolCall) GetCost 

func (entity *ToolCall) GetCost() *float64

func (*ToolCall) GetErrorCode 

func (entity *ToolCall) GetErrorCode() *string

func (*ToolCall) GetErrorMessage 

func (entity *ToolCall) GetErrorMessage() *string

func (*ToolCall) GetIteration 

func (entity *ToolCall) GetIteration() *int

func (*ToolCall) GetLatencyMs 

func (entity *ToolCall) GetLatencyMs() *int

func (*ToolCall) GetMessageId 

func (entity *ToolCall) GetMessageId() string

func (*ToolCall) GetOpId 

func (entity *ToolCall) GetOpId() string

func (*ToolCall) GetRequestHash 

func (entity *ToolCall) GetRequestHash() *string

func (*ToolCall) GetRequestPayloadId 

func (entity *ToolCall) GetRequestPayloadId() *string

func (*ToolCall) GetResponseOverflow 

func (entity *ToolCall) GetResponseOverflow() bool

func (*ToolCall) GetResponsePayloadId 

func (entity *ToolCall) GetResponsePayloadId() *string

func (*ToolCall) GetRetriable 

func (entity *ToolCall) GetRetriable() *int

func (*ToolCall) GetRunId 

func (entity *ToolCall) GetRunId() *string

func (*ToolCall) GetShouldDelete 

func (entity *ToolCall) GetShouldDelete() bool

func (*ToolCall) GetSpanId 

func (entity *ToolCall) GetSpanId() *string

func (*ToolCall) GetStartedAt 

func (entity *ToolCall) GetStartedAt() *time.Time

func (*ToolCall) GetStatus 

func (entity *ToolCall) GetStatus() string

func (*ToolCall) GetToolKind 

func (entity *ToolCall) GetToolKind() string

func (*ToolCall) GetToolName 

func (entity *ToolCall) GetToolName() string

func (*ToolCall) GetTraceId 

func (entity *ToolCall) GetTraceId() *string

func (*ToolCall) GetTurnId 

func (entity *ToolCall) GetTurnId() *string

func (*ToolCall) SetAttempt 

func (entity *ToolCall) SetAttempt(value int)

func (*ToolCall) SetCompletedAt 

func (entity *ToolCall) SetCompletedAt(value *time.Time)

func (*ToolCall) SetCost 

func (entity *ToolCall) SetCost(value *float64)

func (*ToolCall) SetErrorCode 

func (entity *ToolCall) SetErrorCode(value *string)

func (*ToolCall) SetErrorMessage 

func (entity *ToolCall) SetErrorMessage(value *string)

func (*ToolCall) SetIteration 

func (entity *ToolCall) SetIteration(value *int)

func (*ToolCall) SetLatencyMs 

func (entity *ToolCall) SetLatencyMs(value *int)

func (*ToolCall) SetMessageId 

func (entity *ToolCall) SetMessageId(value string)

func (*ToolCall) SetOpId 

func (entity *ToolCall) SetOpId(value string)

func (*ToolCall) SetRequestHash 

func (entity *ToolCall) SetRequestHash(value *string)

func (*ToolCall) SetRequestPayloadId 

func (entity *ToolCall) SetRequestPayloadId(value *string)

func (*ToolCall) SetResponseOverflow 

func (entity *ToolCall) SetResponseOverflow(value bool)

func (*ToolCall) SetResponsePayloadId 

func (entity *ToolCall) SetResponsePayloadId(value *string)

func (*ToolCall) SetRetriable 

func (entity *ToolCall) SetRetriable(value *int)

func (*ToolCall) SetRunId 

func (entity *ToolCall) SetRunId(value *string)

func (*ToolCall) SetShouldDelete 

func (entity *ToolCall) SetShouldDelete(value bool)

func (*ToolCall) SetSpanId 

func (entity *ToolCall) SetSpanId(value *string)

func (*ToolCall) SetStartedAt 

func (entity *ToolCall) SetStartedAt(value *time.Time)

func (*ToolCall) SetStatus 

func (entity *ToolCall) SetStatus(value string)

func (*ToolCall) SetToolKind 

func (entity *ToolCall) SetToolKind(value string)

func (*ToolCall) SetToolName 

func (entity *ToolCall) SetToolName(value string)

func (*ToolCall) SetTraceId 

func (entity *ToolCall) SetTraceId(value *string)

func (*ToolCall) SetTurnId 

func (entity *ToolCall) SetTurnId(value *string)

type ToolCallHas 

type ToolCallHas struct {
	ShouldDelete      bool
	ResponseOverflow  bool
	MessageId         bool
	OpId              bool
	Attempt           bool
	ToolName          bool
	ToolKind          bool
	Status            bool
	Cost              bool
	RequestPayloadId  bool
	ResponsePayloadId bool
	TurnId            bool
	RequestHash       bool
	ErrorCode         bool
	ErrorMessage      bool
	Retriable         bool
	StartedAt         bool
	CompletedAt       bool
	LatencyMs         bool
	TraceId           bool
	SpanId            bool
	RunId             bool
	Iteration         bool
}

type WriterComponent 

type WriterComponent struct {
	Contract xdatly.Component[Input, Output] "" /* 165-byte string literal not displayed */
}

Component is the generated component scaffold for writer.

func (WriterComponent) EmbedFS 

func (WriterComponent) EmbedFS() *embed.FS

func (WriterComponent) EmbedNamespace 

func (WriterComponent) EmbedNamespace() string

type WriterHandlerCurrentWriterGroupedByAttempt 

type WriterHandlerCurrentWriterGroupedByAttempt map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByAttempt) Has 

func (index WriterHandlerCurrentWriterGroupedByAttempt) Has(key int) bool

type WriterHandlerCurrentWriterGroupedByCompletedAt 

type WriterHandlerCurrentWriterGroupedByCompletedAt map[time.Time][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByCompletedAt) Has 

func (index WriterHandlerCurrentWriterGroupedByCompletedAt) Has(key time.Time) bool

type WriterHandlerCurrentWriterGroupedByCost 

type WriterHandlerCurrentWriterGroupedByCost map[float64][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByCost) Has 

func (index WriterHandlerCurrentWriterGroupedByCost) Has(key float64) bool

type WriterHandlerCurrentWriterGroupedByErrorCode 

type WriterHandlerCurrentWriterGroupedByErrorCode map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByErrorCode) Has 

func (index WriterHandlerCurrentWriterGroupedByErrorCode) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByErrorMessage 

type WriterHandlerCurrentWriterGroupedByErrorMessage map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByErrorMessage) Has 

func (index WriterHandlerCurrentWriterGroupedByErrorMessage) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByIteration 

type WriterHandlerCurrentWriterGroupedByIteration map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByIteration) Has 

func (index WriterHandlerCurrentWriterGroupedByIteration) Has(key int) bool

type WriterHandlerCurrentWriterGroupedByLatencyMs 

type WriterHandlerCurrentWriterGroupedByLatencyMs map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByLatencyMs) Has 

func (index WriterHandlerCurrentWriterGroupedByLatencyMs) Has(key int) bool

type WriterHandlerCurrentWriterGroupedByMessageId 

type WriterHandlerCurrentWriterGroupedByMessageId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByMessageId) Has 

func (index WriterHandlerCurrentWriterGroupedByMessageId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByOpId 

type WriterHandlerCurrentWriterGroupedByOpId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByOpId) Has 

func (index WriterHandlerCurrentWriterGroupedByOpId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByRequestHash 

type WriterHandlerCurrentWriterGroupedByRequestHash map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByRequestHash) Has 

func (index WriterHandlerCurrentWriterGroupedByRequestHash) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByRequestPayloadId 

type WriterHandlerCurrentWriterGroupedByRequestPayloadId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByRequestPayloadId) Has 

func (index WriterHandlerCurrentWriterGroupedByRequestPayloadId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByResponseOverflow 

type WriterHandlerCurrentWriterGroupedByResponseOverflow map[bool][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByResponseOverflow) Has 

func (index WriterHandlerCurrentWriterGroupedByResponseOverflow) Has(key bool) bool

type WriterHandlerCurrentWriterGroupedByResponsePayloadId 

type WriterHandlerCurrentWriterGroupedByResponsePayloadId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByResponsePayloadId) Has 

func (index WriterHandlerCurrentWriterGroupedByResponsePayloadId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByRetriable 

type WriterHandlerCurrentWriterGroupedByRetriable map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByRetriable) Has 

func (index WriterHandlerCurrentWriterGroupedByRetriable) Has(key int) bool

type WriterHandlerCurrentWriterGroupedByRunId 

type WriterHandlerCurrentWriterGroupedByRunId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByRunId) Has 

func (index WriterHandlerCurrentWriterGroupedByRunId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedBySpanId 

type WriterHandlerCurrentWriterGroupedBySpanId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedBySpanId) Has 

func (index WriterHandlerCurrentWriterGroupedBySpanId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByStartedAt 

type WriterHandlerCurrentWriterGroupedByStartedAt map[time.Time][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByStartedAt) Has 

func (index WriterHandlerCurrentWriterGroupedByStartedAt) Has(key time.Time) bool

type WriterHandlerCurrentWriterGroupedByStatus 

type WriterHandlerCurrentWriterGroupedByStatus map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByStatus) Has 

func (index WriterHandlerCurrentWriterGroupedByStatus) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByToolKind 

type WriterHandlerCurrentWriterGroupedByToolKind map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByToolKind) Has 

func (index WriterHandlerCurrentWriterGroupedByToolKind) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByToolName 

type WriterHandlerCurrentWriterGroupedByToolName map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByToolName) Has 

func (index WriterHandlerCurrentWriterGroupedByToolName) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByTraceId 

type WriterHandlerCurrentWriterGroupedByTraceId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByTraceId) Has 

func (index WriterHandlerCurrentWriterGroupedByTraceId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByTurnId 

type WriterHandlerCurrentWriterGroupedByTurnId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByTurnId) Has 

func (index WriterHandlerCurrentWriterGroupedByTurnId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByAttempt 

type WriterHandlerCurrentWriterIndexedByAttempt map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByAttempt) Has 

func (index WriterHandlerCurrentWriterIndexedByAttempt) Has(key int) bool

type WriterHandlerCurrentWriterIndexedByCompletedAt 

type WriterHandlerCurrentWriterIndexedByCompletedAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByCompletedAt) Has 

func (index WriterHandlerCurrentWriterIndexedByCompletedAt) Has(key time.Time) bool

type WriterHandlerCurrentWriterIndexedByCost 

type WriterHandlerCurrentWriterIndexedByCost map[float64]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByCost) Has 

func (index WriterHandlerCurrentWriterIndexedByCost) Has(key float64) bool

type WriterHandlerCurrentWriterIndexedByErrorCode 

type WriterHandlerCurrentWriterIndexedByErrorCode map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByErrorCode) Has 

func (index WriterHandlerCurrentWriterIndexedByErrorCode) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByErrorMessage 

type WriterHandlerCurrentWriterIndexedByErrorMessage map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByErrorMessage) Has 

func (index WriterHandlerCurrentWriterIndexedByErrorMessage) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByIteration 

type WriterHandlerCurrentWriterIndexedByIteration map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByIteration) Has 

func (index WriterHandlerCurrentWriterIndexedByIteration) Has(key int) bool

type WriterHandlerCurrentWriterIndexedByLatencyMs 

type WriterHandlerCurrentWriterIndexedByLatencyMs map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByLatencyMs) Has 

func (index WriterHandlerCurrentWriterIndexedByLatencyMs) Has(key int) bool

type WriterHandlerCurrentWriterIndexedByMessageId 

type WriterHandlerCurrentWriterIndexedByMessageId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByMessageId) Has 

func (index WriterHandlerCurrentWriterIndexedByMessageId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByOpId 

type WriterHandlerCurrentWriterIndexedByOpId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByOpId) Has 

func (index WriterHandlerCurrentWriterIndexedByOpId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByRequestHash 

type WriterHandlerCurrentWriterIndexedByRequestHash map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByRequestHash) Has 

func (index WriterHandlerCurrentWriterIndexedByRequestHash) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByRequestPayloadId 

type WriterHandlerCurrentWriterIndexedByRequestPayloadId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByRequestPayloadId) Has 

func (index WriterHandlerCurrentWriterIndexedByRequestPayloadId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByResponseOverflow 

type WriterHandlerCurrentWriterIndexedByResponseOverflow map[bool]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByResponseOverflow) Has 

func (index WriterHandlerCurrentWriterIndexedByResponseOverflow) Has(key bool) bool

type WriterHandlerCurrentWriterIndexedByResponsePayloadId 

type WriterHandlerCurrentWriterIndexedByResponsePayloadId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByResponsePayloadId) Has 

func (index WriterHandlerCurrentWriterIndexedByResponsePayloadId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByRetriable 

type WriterHandlerCurrentWriterIndexedByRetriable map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByRetriable) Has 

func (index WriterHandlerCurrentWriterIndexedByRetriable) Has(key int) bool

type WriterHandlerCurrentWriterIndexedByRunId 

type WriterHandlerCurrentWriterIndexedByRunId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByRunId) Has 

func (index WriterHandlerCurrentWriterIndexedByRunId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedBySpanId 

type WriterHandlerCurrentWriterIndexedBySpanId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedBySpanId) Has 

func (index WriterHandlerCurrentWriterIndexedBySpanId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByStartedAt 

type WriterHandlerCurrentWriterIndexedByStartedAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByStartedAt) Has 

func (index WriterHandlerCurrentWriterIndexedByStartedAt) Has(key time.Time) bool

type WriterHandlerCurrentWriterIndexedByStatus 

type WriterHandlerCurrentWriterIndexedByStatus map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByStatus) Has 

func (index WriterHandlerCurrentWriterIndexedByStatus) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByToolKind 

type WriterHandlerCurrentWriterIndexedByToolKind map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByToolKind) Has 

func (index WriterHandlerCurrentWriterIndexedByToolKind) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByToolName 

type WriterHandlerCurrentWriterIndexedByToolName map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByToolName) Has 

func (index WriterHandlerCurrentWriterIndexedByToolName) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByTraceId 

type WriterHandlerCurrentWriterIndexedByTraceId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByTraceId) Has 

func (index WriterHandlerCurrentWriterIndexedByTraceId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByTurnId 

type WriterHandlerCurrentWriterIndexedByTurnId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByTurnId) Has 

func (index WriterHandlerCurrentWriterIndexedByTurnId) Has(key string) bool

type WriterHandlerCurrentWriterSlice 

type WriterHandlerCurrentWriterSlice []*CurrentWriterView

func (WriterHandlerCurrentWriterSlice) GroupByAttempt 

func (rows WriterHandlerCurrentWriterSlice) GroupByAttempt() WriterHandlerCurrentWriterGroupedByAttempt

func (WriterHandlerCurrentWriterSlice) GroupByCompletedAt 

func (rows WriterHandlerCurrentWriterSlice) GroupByCompletedAt() WriterHandlerCurrentWriterGroupedByCompletedAt

func (WriterHandlerCurrentWriterSlice) GroupByCost 

func (rows WriterHandlerCurrentWriterSlice) GroupByCost() WriterHandlerCurrentWriterGroupedByCost

func (WriterHandlerCurrentWriterSlice) GroupByErrorCode 

func (rows WriterHandlerCurrentWriterSlice) GroupByErrorCode() WriterHandlerCurrentWriterGroupedByErrorCode

func (WriterHandlerCurrentWriterSlice) GroupByErrorMessage 

func (rows WriterHandlerCurrentWriterSlice) GroupByErrorMessage() WriterHandlerCurrentWriterGroupedByErrorMessage

func (WriterHandlerCurrentWriterSlice) GroupByIteration 

func (rows WriterHandlerCurrentWriterSlice) GroupByIteration() WriterHandlerCurrentWriterGroupedByIteration

func (WriterHandlerCurrentWriterSlice) GroupByLatencyMs 

func (rows WriterHandlerCurrentWriterSlice) GroupByLatencyMs() WriterHandlerCurrentWriterGroupedByLatencyMs

func (WriterHandlerCurrentWriterSlice) GroupByMessageId 

func (rows WriterHandlerCurrentWriterSlice) GroupByMessageId() WriterHandlerCurrentWriterGroupedByMessageId

func (WriterHandlerCurrentWriterSlice) GroupByOpId 

func (rows WriterHandlerCurrentWriterSlice) GroupByOpId() WriterHandlerCurrentWriterGroupedByOpId

func (WriterHandlerCurrentWriterSlice) GroupByRequestHash 

func (rows WriterHandlerCurrentWriterSlice) GroupByRequestHash() WriterHandlerCurrentWriterGroupedByRequestHash

func (WriterHandlerCurrentWriterSlice) GroupByRequestPayloadId 

func (rows WriterHandlerCurrentWriterSlice) GroupByRequestPayloadId() WriterHandlerCurrentWriterGroupedByRequestPayloadId

func (WriterHandlerCurrentWriterSlice) GroupByResponseOverflow 

func (rows WriterHandlerCurrentWriterSlice) GroupByResponseOverflow() WriterHandlerCurrentWriterGroupedByResponseOverflow

func (WriterHandlerCurrentWriterSlice) GroupByResponsePayloadId 

func (rows WriterHandlerCurrentWriterSlice) GroupByResponsePayloadId() WriterHandlerCurrentWriterGroupedByResponsePayloadId

func (WriterHandlerCurrentWriterSlice) GroupByRetriable 

func (rows WriterHandlerCurrentWriterSlice) GroupByRetriable() WriterHandlerCurrentWriterGroupedByRetriable

func (WriterHandlerCurrentWriterSlice) GroupByRunId 

func (rows WriterHandlerCurrentWriterSlice) GroupByRunId() WriterHandlerCurrentWriterGroupedByRunId

func (WriterHandlerCurrentWriterSlice) GroupBySpanId 

func (rows WriterHandlerCurrentWriterSlice) GroupBySpanId() WriterHandlerCurrentWriterGroupedBySpanId

func (WriterHandlerCurrentWriterSlice) GroupByStartedAt 

func (rows WriterHandlerCurrentWriterSlice) GroupByStartedAt() WriterHandlerCurrentWriterGroupedByStartedAt

func (WriterHandlerCurrentWriterSlice) GroupByStatus 

func (rows WriterHandlerCurrentWriterSlice) GroupByStatus() WriterHandlerCurrentWriterGroupedByStatus

func (WriterHandlerCurrentWriterSlice) GroupByToolKind 

func (rows WriterHandlerCurrentWriterSlice) GroupByToolKind() WriterHandlerCurrentWriterGroupedByToolKind

func (WriterHandlerCurrentWriterSlice) GroupByToolName 

func (rows WriterHandlerCurrentWriterSlice) GroupByToolName() WriterHandlerCurrentWriterGroupedByToolName

func (WriterHandlerCurrentWriterSlice) GroupByTraceId 

func (rows WriterHandlerCurrentWriterSlice) GroupByTraceId() WriterHandlerCurrentWriterGroupedByTraceId

func (WriterHandlerCurrentWriterSlice) GroupByTurnId 

func (rows WriterHandlerCurrentWriterSlice) GroupByTurnId() WriterHandlerCurrentWriterGroupedByTurnId

func (WriterHandlerCurrentWriterSlice) IndexByAttempt 

func (rows WriterHandlerCurrentWriterSlice) IndexByAttempt() (WriterHandlerCurrentWriterIndexedByAttempt, error)

func (WriterHandlerCurrentWriterSlice) IndexByCompletedAt 

func (rows WriterHandlerCurrentWriterSlice) IndexByCompletedAt() (WriterHandlerCurrentWriterIndexedByCompletedAt, error)

func (WriterHandlerCurrentWriterSlice) IndexByCost 

func (rows WriterHandlerCurrentWriterSlice) IndexByCost() (WriterHandlerCurrentWriterIndexedByCost, error)

func (WriterHandlerCurrentWriterSlice) IndexByErrorCode 

func (rows WriterHandlerCurrentWriterSlice) IndexByErrorCode() (WriterHandlerCurrentWriterIndexedByErrorCode, error)

func (WriterHandlerCurrentWriterSlice) IndexByErrorMessage 

func (rows WriterHandlerCurrentWriterSlice) IndexByErrorMessage() (WriterHandlerCurrentWriterIndexedByErrorMessage, error)

func (WriterHandlerCurrentWriterSlice) IndexByIteration 

func (rows WriterHandlerCurrentWriterSlice) IndexByIteration() (WriterHandlerCurrentWriterIndexedByIteration, error)

func (WriterHandlerCurrentWriterSlice) IndexByLatencyMs 

func (rows WriterHandlerCurrentWriterSlice) IndexByLatencyMs() (WriterHandlerCurrentWriterIndexedByLatencyMs, error)

func (WriterHandlerCurrentWriterSlice) IndexByMessageId 

func (rows WriterHandlerCurrentWriterSlice) IndexByMessageId() (WriterHandlerCurrentWriterIndexedByMessageId, error)

func (WriterHandlerCurrentWriterSlice) IndexByOpId 

func (rows WriterHandlerCurrentWriterSlice) IndexByOpId() (WriterHandlerCurrentWriterIndexedByOpId, error)

func (WriterHandlerCurrentWriterSlice) IndexByRequestHash 

func (rows WriterHandlerCurrentWriterSlice) IndexByRequestHash() (WriterHandlerCurrentWriterIndexedByRequestHash, error)

func (WriterHandlerCurrentWriterSlice) IndexByRequestPayloadId 

func (rows WriterHandlerCurrentWriterSlice) IndexByRequestPayloadId() (WriterHandlerCurrentWriterIndexedByRequestPayloadId, error)

func (WriterHandlerCurrentWriterSlice) IndexByResponseOverflow 

func (rows WriterHandlerCurrentWriterSlice) IndexByResponseOverflow() (WriterHandlerCurrentWriterIndexedByResponseOverflow, error)

func (WriterHandlerCurrentWriterSlice) IndexByResponsePayloadId 

func (rows WriterHandlerCurrentWriterSlice) IndexByResponsePayloadId() (WriterHandlerCurrentWriterIndexedByResponsePayloadId, error)

func (WriterHandlerCurrentWriterSlice) IndexByRetriable 

func (rows WriterHandlerCurrentWriterSlice) IndexByRetriable() (WriterHandlerCurrentWriterIndexedByRetriable, error)

func (WriterHandlerCurrentWriterSlice) IndexByRunId 

func (rows WriterHandlerCurrentWriterSlice) IndexByRunId() (WriterHandlerCurrentWriterIndexedByRunId, error)

func (WriterHandlerCurrentWriterSlice) IndexBySpanId 

func (rows WriterHandlerCurrentWriterSlice) IndexBySpanId() (WriterHandlerCurrentWriterIndexedBySpanId, error)

func (WriterHandlerCurrentWriterSlice) IndexByStartedAt 

func (rows WriterHandlerCurrentWriterSlice) IndexByStartedAt() (WriterHandlerCurrentWriterIndexedByStartedAt, error)

func (WriterHandlerCurrentWriterSlice) IndexByStatus 

func (rows WriterHandlerCurrentWriterSlice) IndexByStatus() (WriterHandlerCurrentWriterIndexedByStatus, error)

func (WriterHandlerCurrentWriterSlice) IndexByToolKind 

func (rows WriterHandlerCurrentWriterSlice) IndexByToolKind() (WriterHandlerCurrentWriterIndexedByToolKind, error)

func (WriterHandlerCurrentWriterSlice) IndexByToolName 

func (rows WriterHandlerCurrentWriterSlice) IndexByToolName() (WriterHandlerCurrentWriterIndexedByToolName, error)

func (WriterHandlerCurrentWriterSlice) IndexByTraceId 

func (rows WriterHandlerCurrentWriterSlice) IndexByTraceId() (WriterHandlerCurrentWriterIndexedByTraceId, error)

func (WriterHandlerCurrentWriterSlice) IndexByTurnId 

func (rows WriterHandlerCurrentWriterSlice) IndexByTurnId() (WriterHandlerCurrentWriterIndexedByTurnId, error)

type WriterHandlerReadIndexes 

type WriterHandlerReadIndexes struct {
	CurrentWriter            WriterHandlerCurrentWriterSlice
	CurrentWriterByMessageId WriterHandlerCurrentWriterIndexedByMessageId
}

func BuildWriterHandlerReadIndexes 

func BuildWriterHandlerReadIndexes(ctx context.Context, input *Input) (*WriterHandlerReadIndexes, error)

type WriterKeysRow 

type WriterKeysRow struct {
	MessageId string `sqlx:"message_id"`
}

Source Files

View all Source files

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.