Documentation
¶
Overview ¶
Package nackoptions provides the shared per-message nack options type for Numaflow SDK components.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ToProto ¶
func ToProto(n *NackOptions) *common.NackOptions
ToProto converts NackOptions to the outgoing proto type. It is nil-safe: a nil input returns nil, leaving the wire field unset.
Types ¶
type NackOptions ¶
type NackOptions struct {
// Delay is the redelivery delay in milliseconds.
Delay *uint64
// MaxDeliveries is the maximum number of redelivery attempts.
MaxDeliveries *uint32
// Reason is a human-readable reason for the nack.
Reason *string
}
NackOptions carries per-message redelivery options for a negative acknowledgement (nack). All fields are optional; a nil pointer means unset.
func FromProto ¶
func FromProto(p *common.NackOptions) *NackOptions
FromProto converts the incoming proto type to NackOptions. It is nil-safe: a nil input returns nil.
Source Files
Click to show internal directories.
Click to hide internal directories.