Documentation ¶
Index ¶
- func NewEventStoreApiProvider(estore eventstore.Store) (store.EventstoreServiceServer, error)
- type EventStoreProvider
- func (svc *EventStoreProvider) Append(ctx context.Context, request *store.AppendEventRequest) (*store.AppendEventResponse, error)
- func (svc *EventStoreProvider) GetEvents(ctx context.Context, request *store.GetEventsRequest) (*store.GetEventsResponse, error)
- func (svc *EventStoreProvider) Healtz(ctx context.Context, request *store.HealthRequest) (*store.HealthResponse, error)
- func (svc *EventStoreProvider) Logs(ctx context.Context, request *store.AppLogRequest) (*store.AppLogResponse, error)
- func (svc *EventStoreProvider) LogsPoll(request *store.AppLogRequest, stream store.EventstoreService_LogsPollServer) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewEventStoreApiProvider ¶
func NewEventStoreApiProvider(estore eventstore.Store) (store.EventstoreServiceServer, error)
Types ¶
type EventStoreProvider ¶
type EventStoreProvider struct {
// contains filtered or unexported fields
}
func (*EventStoreProvider) Append ¶
func (svc *EventStoreProvider) Append(ctx context.Context, request *store.AppendEventRequest) (*store.AppendEventResponse, error)
func (*EventStoreProvider) GetEvents ¶
func (svc *EventStoreProvider) GetEvents(ctx context.Context, request *store.GetEventsRequest) (*store.GetEventsResponse, error)
func (*EventStoreProvider) Healtz ¶
func (svc *EventStoreProvider) Healtz(ctx context.Context, request *store.HealthRequest) (*store.HealthResponse, error)
func (*EventStoreProvider) Logs ¶
func (svc *EventStoreProvider) Logs(ctx context.Context, request *store.AppLogRequest) (*store.AppLogResponse, error)
func (*EventStoreProvider) LogsPoll ¶
func (svc *EventStoreProvider) LogsPoll(request *store.AppLogRequest, stream store.EventstoreService_LogsPollServer) error
Click to show internal directories.
Click to hide internal directories.