eventfeed

Documentation

Index

• type EventFeedAggregate
  • func NewEventFeedAggregate(cfgMgmtClient cmsService.CfgMgmtClient, feedClient ccFeed.FeedServiceClient) *EventFeedAggregate
  • func (eventFeedAggregate *EventFeedAggregate) CollectEventFeed(ctx context.Context, request *agReq.EventFilter) (*agRes.Events, error)
  • func (eventFeedAggregate *EventFeedAggregate) CollectEventGuitarStrings(ctx context.Context, request *agReq.EventStrings) (*agRes.EventStrings, error)
  • func (eventFeedAggregate *EventFeedAggregate) CollectEventTaskCounts(ctx context.Context, request *agReq.EventCountsFilter) (*agRes.EventCounts, error)
  • func (eventFeedAggregate *EventFeedAggregate) CollectEventTypeCounts(ctx context.Context, request *agReq.EventCountsFilter) (*agRes.EventCounts, error)

Types

type EventFeedAggregate

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

func NewEventFeedAggregate

func NewEventFeedAggregate(cfgMgmtClient cmsService.CfgMgmtClient,
	feedClient ccFeed.FeedServiceClient) *EventFeedAggregate

func (*EventFeedAggregate) CollectEventFeed

func (eventFeedAggregate *EventFeedAggregate) CollectEventFeed(ctx context.Context,
	request *agReq.EventFilter) (*agRes.Events, error)

CollectEventFeed - collection the events from all the components

It is important to mention that we will be able to survive if one of the components return an error but the rest of them don't, the reason why is because the gateway is just collecting information from the downstream services and it should be able to handle errors.

func (*EventFeedAggregate) CollectEventGuitarStrings

func (eventFeedAggregate *EventFeedAggregate) CollectEventGuitarStrings(ctx context.Context,
	request *agReq.EventStrings) (*agRes.EventStrings, error)

CollectEventGuitarStrings - collect the guitar strings from all the componets

It is important to mention that we will be able to survive if one of the components return an error but the rest of them don't, the reason why is because the gateway is just collecting information from the downstream services and it should be able to handle errors.

func (*EventFeedAggregate) CollectEventTaskCounts

func (eventFeedAggregate *EventFeedAggregate) CollectEventTaskCounts(
	ctx context.Context, request *agReq.EventCountsFilter) (*agRes.EventCounts, error)

CollectEventTaskCounts - collect the event task counts from all the components

func (*EventFeedAggregate) CollectEventTypeCounts

func (eventFeedAggregate *EventFeedAggregate) CollectEventTypeCounts(
	ctx context.Context, request *agReq.EventCountsFilter) (*agRes.EventCounts, error)

CollectEventTypeCounts - collect the event type counts from all the components