eventstore

package

v0.11.0 Latest Latest Go to latest Published: Mar 20, 2026 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewClient(cc grpc.ClientConnInterface) *Client

func (c *Client) DeleteEvent(ctx context.Context, triggerId string, eventId string) error

func (c *Client) DeleteEventsForTrigger(ctx context.Context, triggerID string) error

func (c *Client) Insert(ctx context.Context, rec capabilities.PendingEvent) error

func (c *Client) List(ctx context.Context) ([]capabilities.PendingEvent, error)

func (c *Client) UpdateDelivery(ctx context.Context, triggerId string, eventId string, lastSentAt time.Time, attempts int) error

type Server struct {
	pb.UnimplementedEventStoreServer
	// contains filtered or unexported fields
}

func NewServer(impl capabilities.EventStore) *Server

func (s *Server) DeleteEvent(ctx context.Context, req *pb.DeleteEventRequest) (*emptypb.Empty, error)

func (s *Server) DeleteEventsForTrigger(ctx context.Context, req *pb.DeleteEventsForTriggerRequest) (*emptypb.Empty, error)

func (s *Server) Insert(ctx context.Context, req *pb.InsertEventRequest) (*emptypb.Empty, error)

func (s *Server) List(ctx context.Context, _ *emptypb.Empty) (*pb.ListEventsResponse, error)

func (s *Server) UpdateDelivery(ctx context.Context, req *pb.UpdateDeliveryRequest) (*emptypb.Empty, error)