service

Documentation

Index

• type Server
  • func (s *Server) Check(ctx context.Context, req *healthpb.HealthCheckRequest) (*healthpb.HealthCheckResponse, error)
  • func (s *Server) CreateEvent(ctx context.Context, in *pb.EventRequest) (*pb.EventResponse, error)
  • func (s *Server) GetEvent(ctx context.Context, filter *pb.GetEventFilter) (*pb.GetEventResponse, error)
  • func (s *Server) Watch(req *healthpb.HealthCheckRequest, ws healthpb.Health_WatchServer) error

Types

type Server

type Server struct {
	pb.UnimplementedEventServer
	Repo repository.Repository
	Nats nats.JetStreamContext
}

func (*Server) Check

func (s *Server) Check(ctx context.Context, req *healthpb.HealthCheckRequest) (*healthpb.HealthCheckResponse, error)

func (*Server) CreateEvent

func (s *Server) CreateEvent(ctx context.Context, in *pb.EventRequest) (*pb.EventResponse, error)

CreateEvent creates a new Event

func (*Server) GetEvent

func (s *Server) GetEvent(ctx context.Context, filter *pb.GetEventFilter) (*pb.GetEventResponse, error)

func (*Server) Watch

func (s *Server) Watch(req *healthpb.HealthCheckRequest, ws healthpb.Health_WatchServer) error