product

type CreateProductReply struct {
	core.ErrorReply
	Setting *ProductSetting `json:"setting"`
}

type CreateProductRequest struct {
	Setting *ProductSetting `json:"setting"`
}

type CreateSnapshotViewReply struct {
	core.ErrorReply

	ID         string    `json:"id"`
	Subscriber string    `json:"subscriber"`
	Product    string    `json:"product"`
	Stream     string    `json:"stream"`
	CreatedAt  time.Time `json:"createAt"`
}

type CreateSnapshotViewRequest struct {
	Subscriber string  `json:"subscriber"`
	Product    string  `json:"product"`
	Partitions []int32 `json:"partitions"`
}

type DeleteProductReply struct {
	core.ErrorReply
}

type DeleteProductRequest struct {
	Name string `json:"name"`
}

type DeleteSnapshotViewReply struct {
	core.ErrorReply

	ID string `json:"id"`
}

type DeleteSnapshotViewRequest struct {
	ID string `json:"id"`
}

type DeleteSubscriptionReply struct {
	core.ErrorReply
}

type DeleteSubscriptionRequest struct {
	Product      string `json:"product"`
	Subscription string `json:"subscription"`
}

type GetSubscriptionReply struct {
	core.ErrorReply
	Setting *subscription.SubscriptionSetting `json:"setting"`
}

type GetSubscriptionRequest struct {
	Product      string `json:"product"`
	Subscription string `json:"subscription"`
}

type HandlerConfig struct {
	Type   string `json:"type"`
	Script string `json:"script"`
}

type InfoProductReply struct {
	core.ErrorReply
	Setting *ProductSetting `json:"setting"`
	State   *ProductState   `json:"state"`
}

type InfoProductRequest struct {
	Name string `json:"name"`
}

type ListProductsReply struct {
	core.ErrorReply

	Products []*ProductInfo `json:"products"`
}

type ListProductsRequest struct {
}

type Options struct {
	Domain  string // Domain specifies the target domain or environment the options apply to.
	Verbose bool   // Verbose indicates whether verbose or detailed logging should be enabled.
}

type PrepareSubscriptionReply struct {
	core.ErrorReply
}

type PrepareSubscriptionRequest struct {
	Product   string                          `json:"product"`
	Consumers []*subscription.ConsumerSetting `json:"consumers"`
}

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

type ProductInfo struct {
	Setting *ProductSetting `json:"setting"` // The configuration settings of the product.
	State   *ProductState   `json:"state"`   // The current operational state of the product.
}

type ProductSetting struct {
	Name            string                 `json:"name"`            // A unique identifier for the product.
	Description     string                 `json:"desc"`            // A brief description of the product.
	Enabled         bool                   `json:"enabled"`         // Flag indicating whether the product is active or not.
	Rules           map[string]*Rule       `json:"rules"`           // A map of event handling rules associated with the product.
	Schema          map[string]interface{} `json:"schema"`          // The data schema defining the structure of the product's data.
	EnabledSnapshot bool                   `json:"enabledSnapshot"` // Flag indicating whether snapshots are enabled for the product.
	Snapshot        *SnapshotSetting       `json:"snapshot"`        // Configuration settings for product snapshots.
	Stream          string                 `json:"stream"`          // The name of the data stream associated with the product.
	CreatedAt       time.Time              `json:"createdAt"`       // Timestamp indicating when the product was created.
	UpdatedAt       time.Time              `json:"updatedAt"`       // Timestamp indicating the last update to the product.
}

type ProductState struct {
	EventCount uint64    `json:"eventCount"` // The total number of events processed by the product.
	Bytes      uint64    `json:"bytes"`      // The total number of bytes processed by the product.
	FirstTime  time.Time `json:"firstTime"`  // Timestamp of the first event processed by the product.
	LastTime   time.Time `json:"lastTime"`   // Timestamp of the most recent event processed by the product.
}

type PullSnapshotViewReply struct {
	core.ErrorReply

	ID      string `json:"id"`
	LastKey string `json:"lastKey"`
	Count   int    `json:"count"`
}

type PullSnapshotViewRequest struct {
	ID           string `json:"id"`
	Partition    int32  `json:"partition"`
	LastKey      string `json:"lastKey"`
	AfterLastKey bool   `json:"afterLastKey"`
}

type PurgeProductReply struct {
	core.ErrorReply
}

type PurgeProductRequest struct {
	Name string `json:"name"`
}

type Rule struct {
	ID            string                 `json:"id"`                // A unique identifier for the rule.
	Name          string                 `json:"name"`              // A human-readable name for the rule.
	Description   string                 `json:"desc"`              // A brief description of what the rule does.
	Event         string                 `json:"event"`             // The type of event that triggers this rule.
	Product       string                 `json:"product"`           // The name of the product associated with this rule.
	Method        string                 `json:"method"`            // The method or action to be performed when the rule is triggered.
	PrimaryKey    []string               `json:"primaryKey"`        // A list of fields used as the primary key in the rule processing.
	SchemaConfig  map[string]interface{} `json:"schema,omitempty"`  // Optional configuration for the data schema related to the rule.
	HandlerConfig *HandlerConfig         `json:"handler,omitempty"` // Optional configuration for the handler responsible for executing the rule.
	Enabled       bool                   `json:"enabled"`           // Flag indicating whether the rule is currently active or not.
	CreatedAt     time.Time              `json:"createdAt"`         // Timestamp indicating when the rule was created.
	UpdatedAt     time.Time              `json:"updatedAt"`         // Timestamp indicating the last update to the rule.
}

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

type SnapshotOpt func(*Snapshot)

type SnapshotSetting struct {
}

type UpdateProductReply struct {
	core.ErrorReply
	Setting *ProductSetting `json:"setting"`
}

type UpdateProductRequest struct {
	Name    string          `json:"name"`
	Setting *ProductSetting `json:"setting"`
}