fission

package module

v1.0.0 Latest Latest Go to latest Published: Mar 21, 2024 License: MIT Imports: 2 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

README ¶

fission

Fission is an implementation of the publish-subscribe model. It does not care about the implementation details and usage of distribution. Fission only cares about the abstraction itself.

Documentation ¶

Index ¶

type Center
- func NewCenter(key any) *Center
type CenterManager
- func NewCenterManager() *CenterManager
- func (m *CenterManager) Destroy()
- func (m *CenterManager) PutCenter(key any) (c *Center)
type CreateDistributionHandleFunc
type Distribution
type Distributor
- func NewDistributor(ctx context.Context, key any, createDist CreateDistributionHandleFunc) *Distributor
- func (p *Distributor) Close() error
- func (p *Distributor) Push(data any) error
type DistributorManager
- func NewDistributorManager() *DistributorManager
- func (m *DistributorManager) Destroy()
- func (m *DistributorManager) PutDistributor(ctx context.Context, key any, distributionCreator CreateDistributionHandleFunc) (p *Distributor)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Center ¶

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

func NewCenter ¶

func NewCenter(key any) *Center

func (*Center) AddDistributor ¶

func (c *Center) AddDistributor(d *Distributor)

func (*Center) DelDistributor ¶

func (c *Center) DelDistributor(key any)

func (*Center) Fission ¶

func (c *Center) Fission(data any) error

func (*Center) GetDistributors ¶ added in v1.0.0

func (c *Center) GetDistributors() map[any]*Distributor

type CenterManager ¶

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

func NewCenterManager ¶

func NewCenterManager() *CenterManager

func (*CenterManager) Destroy ¶

func (m *CenterManager) Destroy()

func (*CenterManager) PutCenter ¶

func (m *CenterManager) PutCenter(key any) (c *Center)

type CreateDistributionHandleFunc ¶

type CreateDistributionHandleFunc func(ctx context.Context, key any) Distribution

type Distribution ¶

type Distribution interface {
	Dist(data any) error
	Close() error
}

type Distributor ¶ added in v1.0.0

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

func NewDistributor ¶ added in v1.0.0

func NewDistributor(ctx context.Context, key any, createDist CreateDistributionHandleFunc) *Distributor

func (*Distributor) Close ¶ added in v1.0.0

func (p *Distributor) Close() error

func (*Distributor) Push ¶ added in v1.0.0

func (p *Distributor) Push(data any) error

Push push data to the dispatcher, the dispatcher handles the data distribution.

type DistributorManager ¶

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

func NewDistributorManager ¶

func NewDistributorManager() *DistributorManager

func (*DistributorManager) Destroy ¶

func (m *DistributorManager) Destroy()

func (*DistributorManager) PutDistributor ¶

func (m *DistributorManager) PutDistributor(ctx context.Context, key any, distributionCreator CreateDistributionHandleFunc) (p *Distributor)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL