client

type ChronoQueueClient struct {
	// contains filtered or unexported fields
}

type ClientOptions struct {
	MaxRetries               int
	InitialBackoff           time.Duration
	MaxBackoff               time.Duration
	MaxHeartBeatWorkers      int
	DefaultRPCTimeout        time.Duration
	TLSCredentials           credentials.TransportCredentials // Define as per your gRPC setup
	Connector                Connector                        // User-provided Connector
	MaxHeartbeatRetryCount   int
	SendMessageHeartbeatFunc func(context.Context, string, string) (*queueservice_pb.SendMessageHeartBeatResponse, error)
}

type Connector func(address string, opts ClientOptions) (queueservice_pb.QueueServiceClient, *grpc.ClientConn, error)

type DLQStats struct {
	Name         string `json:"name"`
	MessageCount int64  `json:"message_count"`
	CreatedAt    int64  `json:"created_at"`
	UpdatedAt    int64  `json:"updated_at"`
}

type MessageOptions struct {
	Payload            Payload    `json:"payload,omitempty"`
	AttemptsLeft       int32      `json:"attemptsLeft,omitempty"`
	MaxAttempts        int32      `json:"maxAttempts,omitempty"`
	ScheduledTime      *time.Time `json:"scheduledTime,omitempty"`
	LeaseDuration      string     `json:"leaseDuration"`
	LeaseExpiry        int64      `json:"leaseExpiry,omitempty"`
	State              State      `json:"state,omitempty"`
	InvisibilityExpiry int64      `json:"invisibilityExpiry,omitempty"`
	Priority           int64      `json:"Priority,omitempty"`
}

type Payload struct {
	Metadata      map[string]*structpb.Value `json:"metadata,omitempty"`
	Data          *structpb.Struct           `json:"data,omitempty"`
	ContentType   string                     `json:"contentType,omitempty"`   // NEW: MIME type
	SchemaID      string                     `json:"schemaId,omitempty"`      // NEW: Schema reference
	SchemaVersion int32                      `json:"schemaVersion,omitempty"` // NEW: Schema version
}

type QueueOptions struct {
	DequeueAttempts     int32  `json:"dequeueAttempts,omitempty"`
	ExclusivityKey      string `json:"exclusivityKey,omitempty"`
	LeaseDuration       string `json:"leaseDuration"`
	Type                int32  `json:"type,omitempty"`
	DeadLetterQueueName string `json:"deadLetterQueueName,omitempty"`
	AutoCreateDLQ       bool   `json:"autoCreateDLQ,omitempty"`
}

type ScheduleOptions struct {
	Payload          Payload                       `json:"payload,omitempty"`
	State            State                         `json:"state,omitempty"`
	CronSchedule     string                        `json:"cronSchedule,omitempty"`
	CalendarSchedule *schedule_pb.CalendarSchedule `json:"calendarSchedule,omitempty"` // New: for calendar-based scheduling
	QueueName        string                        `json:"queueName,omitempty"`
	ExclusivityKey   string                        `json:"exclusivityKey,omitempty"`
	MaxMessages      int64                         `json:"maxMessages,omitempty"`
	LeaseDuration    string                        `json:"leaseDuration,omitempty"`
}

type SchemaOptions struct {
	Name        string            // Human-readable schema name
	Description string            // Schema description
	Content     string            // JSON Schema content
	ContentType string            // Schema type (default: "json-schema")
	Metadata    map[string]string // Additional metadata
}

type State int32

type TimeRangeOption struct {
	Min int64 `json:"min,omitempty"`
	Max int64 `json:"max,omitempty"`
}

type WorkItem struct {
	// contains filtered or unexported fields
}