resource

Documentation

Index

• type Manager
  • func NewManager() *Manager
  • func (m *Manager) Close() error
  • func (m *Manager) Get(key string, create func() (io.Closer, error)) (io.Closer, error)
• type SharedCalls
  • func NewSharedCalls() SharedCalls

Types

type Manager

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

func NewManager

func NewManager() *Manager

func (*Manager) Close

func (m *Manager) Close() error

func (*Manager) Get

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

func NewSharedCalls() SharedCalls