proxy

type CosMsgKey struct {
	Format         string   `json:"format"`
	RequestId      string   `json:"request_id"`
	NotificationId string   `json:"notification_id"`
	Recipients     []string `json:"recipients"`
}

type CosPayload struct {
	Notification json.RawMessage `json:"notification"`
}

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

type ProxyConfig struct {
	RetryTimeToLive  int    `required:"true" envconfig:"cos_proxy_env_retry_time_to_live"`
	ProxyName        string `required:"true" envconfig:"cos_proxy_env_pod_name"`
	ProxyNamespace   string `required:"true" envconfig:"cos_proxy_env_pod_namespace"`
	ProxyStatefulSet string `required:"true" envconfig:"cos_proxy_env_pod_statefulset"`
}

type RetryCache interface {
	Add(value ...interface{}) error
}

type RetryEntry struct {
	Recipient     string `json:"recipient"`
	Origination   int64  `json:"origination"`
	MsgKey        []byte `json:"msgKey"`
	MsgValue      []byte `json:"msgValue"`
	NextRetryTime int64  `json:"nextRetryTime"`
	Retries       int    `json:"retries"`
}