sub

package

v0.0.51 Latest Latest Go to latest Published: Dec 11, 2024 License: MIT Imports: 1 Imported by: 0

Details

View Source

const (
	RECV_GET_ACK = "RECV_GET_ACK"
	PEERS_PRUNED = "PEERS_PRUNED"
)

This section is empty.

This section is empty.

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

func NewSubscriptionService(bufferSize int) *SubscriptionService

func (s *SubscriptionService) Publish(topic string, event interface{})

func (s *SubscriptionService) Subscribe(topic string) chan interface{}

func (s *SubscriptionService) Unsubscribe(topic string, ch chan interface{})

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