conceptions

Documentation

Index

• Variables
• type Cache
  • func NewCache(size int) *Cache
  • func (m *Cache) Add(key, value interface{})
  • func (m *Cache) Get(key interface{}) (value interface{}, ok bool)
  • func (m *Cache) Size() int
• type CloakCache
  • func NewCloakCache() *CloakCache
  • func (m *CloakCache) Add(key, value interface{})
  • func (m *CloakCache) Get(key interface{}) (value interface{}, ok bool)
• type CycleError
  • func (e *CycleError) Error() string
• type DanglingedgeError
  • func (e *DanglingedgeError) Error() string
• type Graph
  • func (g *Graph) AddVertex(name string, tag interface{}, subset []string) error
  • func (g *Graph) Finalize(duplicateTag bool) error
  • func (g *Graph) Tags(name string) []interface{}
• type GraphFinalizedError
  • func (e *GraphFinalizedError) Error() string
• type NestedProxy
  • func InitProxies() *NestedProxy
  • func (np *NestedProxy) AddGlobalProxy(uri *url.URL, ep *common.Endpoint)
  • func (np *NestedProxy) AddProxy(uri *url.URL, ep *common.Endpoint)
  • func (np *NestedProxy) GetDialContext() ProxyDialContext
  • func (np *NestedProxy) HasValue() bool
  • func (np *NestedProxy) Merge(peer *NestedProxy) *NestedProxy
  • func (np *NestedProxy) UDPProxies() bool
• type NodeRedeclarationError
  • func (e *NodeRedeclarationError) Error() string
• type ProxyDialContext
• type SemaGroup
  • func NewSemaGroup(threshold uint32) *SemaGroup
  • func (sg *SemaGroup) Acquire(wait bool) error
  • func (sg *SemaGroup) BeginExclusive() bool
  • func (sg *SemaGroup) EndExclusive()
  • func (sg *SemaGroup) Payload() uint32
  • func (sg *SemaGroup) Release()

Variables

var (
	ErrSemaBoundary = &errSemaBoundary{}
	ErrSemaExcEntry = &errSemaExcEntry{}
)

var (
	ErrFinalized = &GraphFinalizedError{}
)

Types

type Cache

type Cache struct {
	*sync.RWMutex
	// contains filtered or unexported fields
}

func NewCache

func NewCache(size int) *Cache

func (*Cache) Add

func (m *Cache) Add(key, value interface{})

func (*Cache) Get

func (m *Cache) Get(key interface{}) (value interface{}, ok bool)

func (*Cache) Size

func (m *Cache) Size() int

type CloakCache

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

func NewCloakCache

func NewCloakCache() *CloakCache

func (*CloakCache) Add

func (m *CloakCache) Add(key, value interface{})

func (*CloakCache) Get

func (m *CloakCache) Get(key interface{}) (value interface{}, ok bool)

type CycleError

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

func (*CycleError) Error

func (e *CycleError) Error() string

type DanglingedgeError

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

func (*DanglingedgeError) Error

func (e *DanglingedgeError) Error() string

type Graph

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

A minimal implementation of ASG or DAG (not too fast compare to direct mathematic formula on adjacency matrix) Since go do not provide such detailed reference design (godoc.org) Things must be done by myself, this's so called BoringALG

func (*Graph) AddVertex

func (g *Graph) AddVertex(name string, tag interface{}, subset []string) error

func (*Graph) Finalize

func (g *Graph) Finalize(duplicateTag bool) error

func (*Graph) Tags

func (g *Graph) Tags(name string) []interface{}

type GraphFinalizedError

type GraphFinalizedError struct {
}

func (*GraphFinalizedError) Error

func (e *GraphFinalizedError) Error() string

type NestedProxy

type NestedProxy struct {
	*list.List
}

socks5 and http(s) proxy chain

func InitProxies

func InitProxies() *NestedProxy

func (*NestedProxy) AddGlobalProxy

func (np *NestedProxy) AddGlobalProxy(uri *url.URL, ep *common.Endpoint)

first 'ProxyURI' in toml then global proxy stamps by order

func (*NestedProxy) AddProxy

func (np *NestedProxy) AddProxy(uri *url.URL, ep *common.Endpoint)

func (*NestedProxy) GetDialContext

func (np *NestedProxy) GetDialContext() ProxyDialContext

func (*NestedProxy) HasValue

func (np *NestedProxy) HasValue() bool

func (*NestedProxy) Merge

func (np *NestedProxy) Merge(peer *NestedProxy) *NestedProxy

global proxy stamps and non-global individual proxy stamps binding to resolvers Ex

func (*NestedProxy) UDPProxies

func (np *NestedProxy) UDPProxies() bool

type NodeRedeclarationError

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

func (*NodeRedeclarationError) Error

func (e *NodeRedeclarationError) Error() string

type ProxyDialContext

type ProxyDialContext func(ctx context.Context, ifi *string, network, addr string) (net.Conn, error)

type SemaGroup

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

func NewSemaGroup

func NewSemaGroup(threshold uint32) *SemaGroup

func (*SemaGroup) Acquire

func (sg *SemaGroup) Acquire(wait bool) error

func (*SemaGroup) BeginExclusive

func (sg *SemaGroup) BeginExclusive() bool

func (*SemaGroup) EndExclusive

func (sg *SemaGroup) EndExclusive()

func (*SemaGroup) Payload

func (sg *SemaGroup) Payload() uint32

func (*SemaGroup) Release

func (sg *SemaGroup) Release()