Documentation ¶
Index ¶
- type LocalClient
- func (c *LocalClient) GetEvent(ctx context.Context, req *pbeventsvc.GetEventRequest, _ ...grpc.CallOption) (*pbeventsvc.GetEventResponse, error)
- func (c *LocalClient) GetEventState(ctx context.Context, in *pbeventsvc.GetEventStateRequest, _ ...grpc.CallOption) (*pbeventsvc.GetEventStateResponse, error)
- func (c *LocalClient) GetEventStateForProject(ctx context.Context, req *pbeventsvc.GetEventStateForProjectRequest, ...) (*pbeventsvc.GetEventStateForProjectResponse, error)
- func (c *LocalClient) GetProjectWaitingEvents(ctx context.Context, req *pbeventsvc.GetProjectWaitingEventsRequest, ...) (*pbeventsvc.GetProjectWaitingEventsResponse, error)
- func (c *LocalClient) IngestEvent(ctx context.Context, req *pbeventsvc.IngestEventRequest, _ ...grpc.CallOption) (*pbeventsvc.IngestEventResponse, error)
- func (c *LocalClient) ListEvents(ctx context.Context, req *pbeventsvc.ListEventsRequest, _ ...grpc.CallOption) (*pbeventsvc.ListEventsResponse, error)
- func (c *LocalClient) MonitorProjectEvents(ctx context.Context, in *pbeventsvc.MonitorProjectEventsRequest, ...) (pbeventsvc.Events_MonitorProjectEventsClient, error)
- func (c *LocalClient) TrackIngestEvent(ctx context.Context, req *pbeventsvc.IngestEventRequest, _ ...grpc.CallOption) (pbeventsvc.Events_TrackIngestEventClient, error)
- func (c *LocalClient) UpdateEventState(ctx context.Context, in *pbeventsvc.UpdateEventStateRequest, ...) (*pbeventsvc.UpdateEventStateResponse, error)
- func (c *LocalClient) UpdateEventStateForProject(ctx context.Context, req *pbeventsvc.UpdateEventStateForProjectRequest, ...) (*pbeventsvc.UpdateEventStateForProjectResponse, error)
- type Svc
- func (s *Svc) GetEvent(ctx context.Context, req *pbeventsvc.GetEventRequest) (*pbeventsvc.GetEventResponse, error)
- func (s *Svc) GetEventState(ctx context.Context, req *pbeventsvc.GetEventStateRequest) (*pbeventsvc.GetEventStateResponse, error)
- func (s *Svc) GetEventStateForProject(ctx context.Context, req *pbeventsvc.GetEventStateForProjectRequest) (*pbeventsvc.GetEventStateForProjectResponse, error)
- func (s *Svc) GetProjectWaitingEvents(ctx context.Context, req *pbeventsvc.GetProjectWaitingEventsRequest) (*pbeventsvc.GetProjectWaitingEventsResponse, error)
- func (s *Svc) IngestEvent(ctx context.Context, req *pbeventsvc.IngestEventRequest) (*pbeventsvc.IngestEventResponse, error)
- func (s *Svc) ListEvents(ctx context.Context, req *pbeventsvc.ListEventsRequest) (*pbeventsvc.ListEventsResponse, error)
- func (s *Svc) MonitorProjectEvents(req *pbeventsvc.MonitorProjectEventsRequest, ...) error
- func (s *Svc) Register(ctx context.Context, srv *grpc.Server, gw *runtime.ServeMux)
- func (s *Svc) TrackIngestEvent(req *pbeventsvc.IngestEventRequest, ...) error
- func (s *Svc) UpdateEventState(ctx context.Context, req *pbeventsvc.UpdateEventStateRequest) (*pbeventsvc.UpdateEventStateResponse, error)
- func (s *Svc) UpdateEventStateForProject(ctx context.Context, req *pbeventsvc.UpdateEventStateForProjectRequest) (*pbeventsvc.UpdateEventStateForProjectResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type LocalClient ¶
type LocalClient struct {
Server pbeventsvc.EventsServer
}
func (*LocalClient) GetEvent ¶
func (c *LocalClient) GetEvent(ctx context.Context, req *pbeventsvc.GetEventRequest, _ ...grpc.CallOption) (*pbeventsvc.GetEventResponse, error)
func (*LocalClient) GetEventState ¶
func (c *LocalClient) GetEventState(ctx context.Context, in *pbeventsvc.GetEventStateRequest, _ ...grpc.CallOption) (*pbeventsvc.GetEventStateResponse, error)
func (*LocalClient) GetEventStateForProject ¶
func (c *LocalClient) GetEventStateForProject(ctx context.Context, req *pbeventsvc.GetEventStateForProjectRequest, _ ...grpc.CallOption) (*pbeventsvc.GetEventStateForProjectResponse, error)
func (*LocalClient) GetProjectWaitingEvents ¶
func (c *LocalClient) GetProjectWaitingEvents(ctx context.Context, req *pbeventsvc.GetProjectWaitingEventsRequest, _ ...grpc.CallOption) (*pbeventsvc.GetProjectWaitingEventsResponse, error)
func (*LocalClient) IngestEvent ¶
func (c *LocalClient) IngestEvent(ctx context.Context, req *pbeventsvc.IngestEventRequest, _ ...grpc.CallOption) (*pbeventsvc.IngestEventResponse, error)
func (*LocalClient) ListEvents ¶
func (c *LocalClient) ListEvents(ctx context.Context, req *pbeventsvc.ListEventsRequest, _ ...grpc.CallOption) (*pbeventsvc.ListEventsResponse, error)
func (*LocalClient) MonitorProjectEvents ¶ added in v0.10.0
func (c *LocalClient) MonitorProjectEvents(ctx context.Context, in *pbeventsvc.MonitorProjectEventsRequest, _ ...grpc.CallOption) (pbeventsvc.Events_MonitorProjectEventsClient, error)
func (*LocalClient) TrackIngestEvent ¶ added in v0.6.0
func (c *LocalClient) TrackIngestEvent(ctx context.Context, req *pbeventsvc.IngestEventRequest, _ ...grpc.CallOption) (pbeventsvc.Events_TrackIngestEventClient, error)
func (*LocalClient) UpdateEventState ¶
func (c *LocalClient) UpdateEventState(ctx context.Context, in *pbeventsvc.UpdateEventStateRequest, _ ...grpc.CallOption) (*pbeventsvc.UpdateEventStateResponse, error)
func (*LocalClient) UpdateEventStateForProject ¶
func (c *LocalClient) UpdateEventStateForProject(ctx context.Context, req *pbeventsvc.UpdateEventStateForProjectRequest, _ ...grpc.CallOption) (*pbeventsvc.UpdateEventStateForProjectResponse, error)
type Svc ¶
type Svc struct { pbeventsvc.UnimplementedEventsServer Events *events.Events Store eventsstore.Store L L.Nullable }
func (*Svc) GetEvent ¶
func (s *Svc) GetEvent(ctx context.Context, req *pbeventsvc.GetEventRequest) (*pbeventsvc.GetEventResponse, error)
func (*Svc) GetEventState ¶
func (s *Svc) GetEventState(ctx context.Context, req *pbeventsvc.GetEventStateRequest) (*pbeventsvc.GetEventStateResponse, error)
func (*Svc) GetEventStateForProject ¶
func (s *Svc) GetEventStateForProject(ctx context.Context, req *pbeventsvc.GetEventStateForProjectRequest) (*pbeventsvc.GetEventStateForProjectResponse, error)
func (*Svc) GetProjectWaitingEvents ¶
func (s *Svc) GetProjectWaitingEvents(ctx context.Context, req *pbeventsvc.GetProjectWaitingEventsRequest) (*pbeventsvc.GetProjectWaitingEventsResponse, error)
func (*Svc) IngestEvent ¶
func (s *Svc) IngestEvent(ctx context.Context, req *pbeventsvc.IngestEventRequest) (*pbeventsvc.IngestEventResponse, error)
func (*Svc) ListEvents ¶
func (s *Svc) ListEvents(ctx context.Context, req *pbeventsvc.ListEventsRequest) (*pbeventsvc.ListEventsResponse, error)
func (*Svc) MonitorProjectEvents ¶ added in v0.10.0
func (s *Svc) MonitorProjectEvents(req *pbeventsvc.MonitorProjectEventsRequest, srv pbeventsvc.Events_MonitorProjectEventsServer) error
func (*Svc) TrackIngestEvent ¶ added in v0.6.0
func (s *Svc) TrackIngestEvent(req *pbeventsvc.IngestEventRequest, srv pbeventsvc.Events_TrackIngestEventServer) error
func (*Svc) UpdateEventState ¶
func (s *Svc) UpdateEventState(ctx context.Context, req *pbeventsvc.UpdateEventStateRequest) (*pbeventsvc.UpdateEventStateResponse, error)
func (*Svc) UpdateEventStateForProject ¶
func (s *Svc) UpdateEventStateForProject(ctx context.Context, req *pbeventsvc.UpdateEventStateForProjectRequest) (*pbeventsvc.UpdateEventStateForProjectResponse, error)
Click to show internal directories.
Click to hide internal directories.