Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AllVaaSubscribers ¶
type AllVaaSubscribers struct {
// contains filtered or unexported fields
}
AllVaaSubscribers represents all VAA subscribers.
func NewAllVaaSubscribers ¶
func NewAllVaaSubscribers(logger *zap.Logger) *AllVaaSubscribers
NewAllVaaSubscribers creates all VAA subscribers.
func (*AllVaaSubscribers) HandleVAA ¶
func (s *AllVaaSubscribers) HandleVAA(vaaBytes []byte) error
HandleVAA sends a VAA to subscribers that filters apply the conditions.
func (*AllVaaSubscribers) Register ¶
func (s *AllVaaSubscribers) Register(fi []*spyv1.FilterEntry) *subscriptionAllVaa
Register registers a new subscriber with a list of filters.
func (*AllVaaSubscribers) Start ¶
func (s *AllVaaSubscribers) Start(ctx context.Context)
func (*AllVaaSubscribers) Unregister ¶
func (s *AllVaaSubscribers) Unregister(sub *subscriptionAllVaa)
Unregister removes a subscriber.
type Handler ¶
type Handler struct {
spyv1.UnimplementedSpyRPCServiceServer
// contains filtered or unexported fields
}
Handler represents a GRPC subscription service handler.
func NewHandler ¶
func NewHandler(svs *SignedVaaSubscribers, avs *AllVaaSubscribers, logger *zap.Logger) *Handler
NewHandler creates a new handler of suscriptions.
func (*Handler) SubscribeSignedVAA ¶
func (h *Handler) SubscribeSignedVAA(req *spyv1.SubscribeSignedVAARequest, resp spyv1.SpyRPCService_SubscribeSignedVAAServer) error
SubscribeSignedVAA implements the suscriptions of signed VAA.
func (*Handler) SubscribeSignedVAAByType ¶
func (h *Handler) SubscribeSignedVAAByType(req *spyv1.SubscribeSignedVAAByTypeRequest, resp spyv1.SpyRPCService_SubscribeSignedVAAByTypeServer) error
SubscribeSignedVAAByType implements the suscriptions of signed VAA by type.
type Publisher ¶
type Publisher struct {
// contains filtered or unexported fields
}
Publisher represents a signed VAA publisher for subscribing customers.
func NewPublisher ¶
func NewPublisher(svs *SignedVaaSubscribers, avs *AllVaaSubscribers, logger *zap.Logger) *Publisher
NewPublisher creates a new publisher for subscribing customers.
type Server ¶
type Server struct {
Runnable supervisor.Runnable
// contains filtered or unexported fields
}
type SignedVaaSubscribers ¶
type SignedVaaSubscribers struct {
// contains filtered or unexported fields
}
SignedVaaSubscribers represents signed VAA subscribers.
func NewSignedVaaSubscribers ¶
func NewSignedVaaSubscribers(logger *zap.Logger) *SignedVaaSubscribers
NewSignedVaaSubscribers creates a signed VAA subscribers.
func (*SignedVaaSubscribers) HandleVAA ¶
func (s *SignedVaaSubscribers) HandleVAA(vaas []byte) error
HandleVAA sends a VAA to subscribers that filters apply the conditions.
func (*SignedVaaSubscribers) Register ¶
func (s *SignedVaaSubscribers) Register(fi []filterSignedVaa) *subscriptionSignedVaa
Register registers a new subscriber with a list of filters.
func (*SignedVaaSubscribers) Start ¶
func (s *SignedVaaSubscribers) Start(ctx context.Context)
func (*SignedVaaSubscribers) Unregister ¶
func (s *SignedVaaSubscribers) Unregister(sub *subscriptionSignedVaa)
Unregister removes a subscriber.
Source Files