proxy

Documentation

Index

• type CosMsgKey
• type CosPayload
• type Proxy
  • func NewProxy(retryCache RetryCache) (*Proxy, error)
  • func (p *Proxy) StartProxy() error
• type ProxyConfig
  • func GetConfig() (ProxyConfig, error)
• type RetryCache
• type RetryEntry

Types

type CosMsgKey

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

type CosPayload

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

type Proxy

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

func NewProxy

func NewProxy(retryCache RetryCache) (*Proxy, error)

func (*Proxy) StartProxy

func (p *Proxy) StartProxy() error

StartProxy starts the HTTP server

type ProxyConfig

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"`
}

func GetConfig

func GetConfig() (ProxyConfig, error)

type RetryCache

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

type RetryEntry

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"`
}