Documentation
¶
Index ¶
- type EventServiceImpl
- func (i *EventServiceImpl) AddEvent(ctx context.Context, in *event.EventSpec) (*event.Event, error)
- func (i *EventServiceImpl) Close(ctx context.Context)
- func (i *EventServiceImpl) Init() error
- func (i *EventServiceImpl) Name() string
- func (i *EventServiceImpl) QueryEvent(ctx context.Context, in *event.QueryEventRequest) (*types.Set[*event.Event], error)
- func (i *EventServiceImpl) RunSaveEventConsumer(ctx context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventServiceImpl ¶
type EventServiceImpl struct {
ioc.ObjectImpl
// 当前这个消费者 配置的topic
EventTopic string `toml:"event_topic" json:"event_topic" yaml:"event_topic" env:"EVENT_TOPIC"`
// contains filtered or unexported fields
}
func (*EventServiceImpl) Close ¶ added in v0.0.21
func (i *EventServiceImpl) Close(ctx context.Context)
func (*EventServiceImpl) Init ¶
func (i *EventServiceImpl) Init() error
func (*EventServiceImpl) Name ¶
func (i *EventServiceImpl) Name() string
func (*EventServiceImpl) QueryEvent ¶
func (i *EventServiceImpl) QueryEvent(ctx context.Context, in *event.QueryEventRequest) (*types.Set[*event.Event], error)
QueryEvent implements event.Service.
func (*EventServiceImpl) RunSaveEventConsumer ¶ added in v0.0.21
func (i *EventServiceImpl) RunSaveEventConsumer(ctx context.Context) error
Source Files
Click to show internal directories.
Click to hide internal directories.