fission

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
  • func (c *Center) AddDistributor(d *Distributor)
  • func (c *Center) DelDistributor(key any)
  • func (c *Center) Fission(data any) error
  • func (c *Center) GetDistributors() map[any]*Distributor
• 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)

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

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

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

func NewDistributor

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

func (*Distributor) Close

func (p *Distributor) Close() error

func (*Distributor) Push

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)