admin

package

v0.0.0-...-e082e2d Latest Latest Go to latest Published: Feb 20, 2024 License: MIT Imports: 16 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var ConditionAlreadyExists = errors.Errorf("condition already exists")

View Source

var ServerNotRunningError = errors.New("server not running")

This section is empty.

type ConditionServer struct {
	api.UnimplementedConditionServiceServer
	// contains filtered or unexported fields
}

func NewConditionServer(condRepo db.ConditionRepository, notifRepo db.NotificationRepository) *ConditionServer

func (c *ConditionServer) AddCondition(ctx context.Context, request *api.AddConditionRequest) (*api.ConditionResponse, error)

func (c *ConditionServer) DeleteCondition(ctx context.Context, request *api.GetConditionRequest) (*api.ConditionResponse, error)

func (c *ConditionServer) GetCondition(ctx context.Context, request *api.GetConditionRequest) (*api.ConditionResponse, error)

func (c *ConditionServer) GetConditions(ctx context.Context, request *api.GetConditionsRequest) (*api.ConditionsListResponse, error)

type OfferServer struct {
	api.UnimplementedOfferServiceServer
	// contains filtered or unexported fields
}

func NewOfferServer(repo db.OfferRepository) *OfferServer

func (o *OfferServer) GetOffer(ctx context.Context, request *api.GetOfferRequest) (*api.OfferResponse, error)

func (o *OfferServer) GetOffers(ctx context.Context, request *api.GetOffersRequest) (*api.OfferListResponse, error)

type ProcessorControl interface {
	RunProcessing() error
	StopProcessing() error
	GetProcessingState() (ProcessorState, error)
}

type ProcessorServer struct {
	api.UnimplementedProcessorServiceServer
	// contains filtered or unexported fields
}

func NewProcessorServer(control ProcessorControl) *ProcessorServer

func (p *ProcessorServer) GetProcessingStatus(ctx context.Context, empty *emptypb.Empty) (*api.ProcessingStatus, error)

func (p *ProcessorServer) StartProcessing(ctx context.Context, empty *emptypb.Empty) (*emptypb.Empty, error)

func (p *ProcessorServer) StopProcessing(ctx context.Context, empty *emptypb.Empty) (*emptypb.Empty, error)

type ProcessorState struct {
	LastRun   time.Time
	NextRun   time.Time
	IsRunning bool
}

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

func NewServer(port int, ip string, db db.DB, control ProcessorControl) *Server

func (s *Server) Close() error

func (s *Server) Run() error

type WatchUrlServer struct {
	api.UnimplementedWatchUrlServiceServer
	// contains filtered or unexported fields
}

func NewWatchUrlServer(repo db.WatchUrlRepository) *WatchUrlServer

func (w *WatchUrlServer) AddUrl(ctx context.Context, request *api.AddUrlRequest) (*api.UrlResponse, error)

func (w *WatchUrlServer) GetUrls(ctx context.Context, request *api.GetUrlsRequest) (*api.UrlListResponse, error)

func (w *WatchUrlServer) SetState(ctx context.Context, request *api.SetStateRequest) (*api.UrlResponse, error)