heal

Documentation

Index

• type StartGoroutineFn
  • func NewSteward(name string, timeout time.Duration, startGoroutine StartGoroutineFn) StartGoroutineFn

Types

type StartGoroutineFn

type StartGoroutineFn func(ctx context.Context, pulseInterval time.Duration) <-chan struct{}

StartGoroutineFn 创建一个可以监控和重启的goroutine的方式 参数：退出channel,心跳时间 返回值：返回心跳的channel

func NewSteward

func NewSteward(name string, timeout time.Duration, startGoroutine StartGoroutineFn) StartGoroutineFn

NewSteward 新建一个管理员 参数：下游的超时时间，创建一个可以监控和重启的goroutine的方式 返回值：返回一个创建一个受管理的goroutine和其管理者的函数的创建方式