common

Documentation

Index

• type HttpOption
• type Inject
• type Job
• type Values

Types

type HttpOption

type HttpOption struct {
	Url     string                 `json:"url" msgpack:"url"`
	Headers map[string]string      `json:"headers" msgpack:"headers"`
	Body    map[string]interface{} `json:"body" msgpack:"body"`
}

type Inject

type Inject struct {
	V         *Values
	Log       *zap.Logger
	Nats      *nats.Conn
	JetStream nats.JetStreamContext
	Transfer  *transfer.Client
}

type Job

type Job struct {
	Key    string      `msgpack:"key"`
	Index  int         `msgpack:"index"`
	Mode   string      `msgpack:"mode"`
	Option interface{} `msgpack:"option"`
}

type Values

type Values struct {
	Namespace string `env:"NAMESPACE,required"`
	Nats      struct {
		Hosts []string `env:"HOSTS,required" envSeparator:","`
		Nkey  string   `env:"NKEY,required"`
	} `envPrefix:"NATS_"`
}