Documentation
¶
Index ¶
- func NewQueryServer(keeper *Keeper) types.QueryServer
- type Keeper
- func (k *Keeper) Dispatcher() *types.Dispatcher
- func (k *Keeper) GetAppContext() context.Context
- func (k *Keeper) Invoker() *types.RouterInvoker
- func (k *Keeper) Logger() log.Logger
- func (k *Keeper) MethodRegistry() *encoding.DynamicRegistry
- func (k *Keeper) Registry() *types.SubscriptionRegistry
- func (k *Keeper) StartDispatcher()
- func (k *Keeper) StopDispatcher()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewQueryServer ¶
func NewQueryServer(keeper *Keeper) types.QueryServer
Types ¶
type Keeper ¶
type Keeper struct {
// contains filtered or unexported fields
}
Keeper defines the stream module keeper
func (*Keeper) Dispatcher ¶
func (k *Keeper) Dispatcher() *types.Dispatcher
Dispatcher returns the event dispatcher for the stream module.
func (*Keeper) GetAppContext ¶
GetAppContext returns the app context used for lifecycle management
func (*Keeper) Invoker ¶
func (k *Keeper) Invoker() *types.RouterInvoker
Invoker returns the router invoker used by the stream module.
func (*Keeper) MethodRegistry ¶
func (k *Keeper) MethodRegistry() *encoding.DynamicRegistry
MethodRegistry returns the dynamically discovered gRPC method registry. First access triggers a one-shot Refresh against the now-fully-wired baseApp router; subsequent calls are pass-through.
func (*Keeper) Registry ¶
func (k *Keeper) Registry() *types.SubscriptionRegistry
Registry returns the subscription registry
func (*Keeper) StartDispatcher ¶
func (k *Keeper) StartDispatcher()
StartDispatcher starts the event dispatcher goroutine
func (*Keeper) StopDispatcher ¶
func (k *Keeper) StopDispatcher()
StopDispatcher stops the event dispatcher
Source Files
Click to show internal directories.
Click to hide internal directories.