util

Documentation

Index

• func NewLogger(client *etcd.Client, componentName config.ComponentName, ...) (log.Logger, error)
• func NewReidsClient(c *config.ReidsConfig) (*redis.Client, error)
• func NewTestLogger() log.Logger
• func SendHttpRequest(ctx context.Context, method string, url, bodyStr string, ...) (*http.Response, error)
• type EtcdWatcher
  • func NewEtcdWatcher(client *etcd.Client, watchKey TaskEtcdPrefix, logger log.Logger) *EtcdWatcher
  • func (e *EtcdWatcher) WaitUntilWatchKeyChanged(ctx context.Context, key string, baseRev int64) error
  • func (e *EtcdWatcher) Watch(handler func([]*etcd.Event) error, opts ...etcd.OpOption)
• type TaskEtcdPrefix

Functions

func NewLogger

func NewLogger(client *etcd.Client, componentName config.ComponentName, version config.Version) (log.Logger, error)

func NewReidsClient

func NewReidsClient(c *config.ReidsConfig) (*redis.Client, error)

func NewTestLogger

func NewTestLogger() log.Logger

func SendHttpRequest

func SendHttpRequest(ctx context.Context, method string, url, bodyStr string, cookies []*http.Cookie, headers http.Header) (*http.Response, error)

Types

type EtcdWatcher

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

func NewEtcdWatcher

func NewEtcdWatcher(client *etcd.Client, watchKey TaskEtcdPrefix, logger log.Logger) *EtcdWatcher

func (*EtcdWatcher) WaitUntilWatchKeyChanged

func (e *EtcdWatcher) WaitUntilWatchKeyChanged(ctx context.Context, key string, baseRev int64) error

func (*EtcdWatcher) Watch

func (e *EtcdWatcher) Watch(handler func([]*etcd.Event) error, opts ...etcd.OpOption)

type TaskEtcdPrefix

type TaskEtcdPrefix string