broadcast

Documentation

Index

• type BroadcastServer
  • func NewBroadcastServer(ctx context.Context, serviceEventSource <-chan commons.ServiceEvent, ...) BroadcastServer

Types

type BroadcastServer

type BroadcastServer interface {
	SubscribeServiceEvent() <-chan commons.ServiceEvent
	CancelSubscriptionServiceEvent(<-chan commons.ServiceEvent)
	SubscribeHtlcEvent() <-chan commons.HtlcEvent
	CancelSubscriptionHtlcEvent(<-chan commons.HtlcEvent)
	SubscribeForwardEvent() <-chan commons.ForwardEvent
	CancelSubscriptionForwardEvent(<-chan commons.ForwardEvent)
	SubscribeChannelBalanceEvent() <-chan commons.ChannelBalanceEvent
	CancelSubscriptionChannelBalanceEvent(<-chan commons.ChannelBalanceEvent)
	SubscribeChannelEvent() <-chan commons.ChannelEvent
	CancelSubscriptionChannelEvent(<-chan commons.ChannelEvent)
	SubscribeNodeGraphEvent() <-chan commons.NodeGraphEvent
	CancelSubscriptionNodeGraphEvent(<-chan commons.NodeGraphEvent)
	SubscribeChannelGraphEvent() <-chan commons.ChannelGraphEvent
	CancelSubscriptionChannelGraphEvent(<-chan commons.ChannelGraphEvent)
	SubscribeInvoiceEvent() <-chan commons.InvoiceEvent
	CancelSubscriptionInvoiceEvent(<-chan commons.InvoiceEvent)
	SubscribePaymentEvent() <-chan commons.PaymentEvent
	CancelSubscriptionPaymentEvent(<-chan commons.PaymentEvent)
	SubscribeTransactionEvent() <-chan commons.TransactionEvent
	CancelSubscriptionTransactionEvent(<-chan commons.TransactionEvent)
	SubscribePeerEvent() <-chan commons.PeerEvent
	CancelSubscriptionPeerEvent(<-chan commons.PeerEvent)
	SubscribeBlockEvent() <-chan commons.BlockEvent
	CancelSubscriptionBlockEvent(<-chan commons.BlockEvent)
	SubscribeWebSocketResponse() <-chan interface{}
	CancelSubscriptionWebSocketResponse(<-chan interface{})
	SubscribeLightningRequest() <-chan interface{}
	CancelSubscriptionLightningRequest(<-chan interface{})
	SubscribeRebalanceRequest() <-chan commons.RebalanceRequest
	CancelSubscriptionRebalanceRequest(<-chan commons.RebalanceRequest)
}

func NewBroadcastServer

func NewBroadcastServer(ctx context.Context,
	serviceEventSource <-chan commons.ServiceEvent,
	htlcEventSource <-chan commons.HtlcEvent,
	forwardEventSource <-chan commons.ForwardEvent,
	channelBalanceEventSource <-chan commons.ChannelBalanceEvent,
	channelEventSource <-chan commons.ChannelEvent,
	nodeGraphEventSource <-chan commons.NodeGraphEvent,
	channelGraphEventSource <-chan commons.ChannelGraphEvent,
	invoiceEventSource <-chan commons.InvoiceEvent,
	paymentEventSource <-chan commons.PaymentEvent,
	transactionEventSource <-chan commons.TransactionEvent,
	peerEventSource <-chan commons.PeerEvent,
	blockEventSource <-chan commons.BlockEvent,
	webSocketResponseSource <-chan interface{},
	lightningRequestSource <-chan interface{},
	rebalanceRequestSource <-chan commons.RebalanceRequest) BroadcastServer