resource

type Manager ¶

type Manager struct {
	SharedCalls SharedCalls
	// contains filtered or unexported fields
}

func NewManager() *Manager

func (m *Manager) Close() error

func (m *Manager) Get(key string, create func() (io.Closer, error)) (io.Closer, error)

type SharedCalls ¶

type SharedCalls interface {
	Do(key string, fn func() (interface{}, error)) (interface{}, error)
	DoEx(key string, fn func() (interface{}, error)) (interface{}, bool, error)
}

SharedCalls lets the concurrent calls with the same key to share the call result. When A and B concurrently request the same key, A and B will share the same result. Before the end of A request, B request comes, B will not execute, only wait for the result of A,

func NewSharedCalls() SharedCalls