service

Documentation

Index

• type Service
  • func Serve() (*Service, error)
  • func (s *Service) Attach(mux *http.ServeMux)
  • func (s *Service) Commit(ctx context.Context, req *connect.Request[pb.Config]) (*connect.Response[pb.Empty], error)
  • func (s *Service) Do(ctx context.Context, req *connect.Request[pb.Op]) (*connect.Response[pb.Return], error)
  • func (s *Service) Download(ctx context.Context, req *connect.Request[pb.BundleConfig], ...) (rerr error)
  • func (s *Service) Free(ctx context.Context, in *connect.Request[pb.Config]) (*connect.Response[pb.Empty], error)
  • func (s *Service) Load(ctx context.Context, req *connect.Request[pb.Source]) (*connect.Response[pb.Config], error)
  • func (s *Service) Lookup(id string) (config.Parser, error)
  • func (s *Service) New(context.Context, *connect.Request[pb.Empty]) (*connect.Response[pb.Config], error)
  • func (s *Service) Upload(ctx context.Context, stream *connect.ClientStream[pb.SourceUpload]) (*connect.Response[pb.Config], error)

Types

type Service

type Service struct {
	pbconnect.UnimplementedConfigServiceHandler
	// contains filtered or unexported fields
}

server is used to implement pb.ConfigServiceServer.

func Serve

func Serve() (*Service, error)

func (*Service) Attach

func (s *Service) Attach(mux *http.ServeMux)

func (*Service) Commit

func (s *Service) Commit(ctx context.Context, req *connect.Request[pb.Config]) (*connect.Response[pb.Empty], error)

func (*Service) Do

func (s *Service) Do(ctx context.Context, req *connect.Request[pb.Op]) (*connect.Response[pb.Return], error)

func (*Service) Download

func (s *Service) Download(ctx context.Context, req *connect.Request[pb.BundleConfig], stream *connect.ServerStream[pb.Bundle]) (rerr error)

func (*Service) Free

func (s *Service) Free(ctx context.Context, in *connect.Request[pb.Config]) (*connect.Response[pb.Empty], error)

func (*Service) Load

func (s *Service) Load(ctx context.Context, req *connect.Request[pb.Source]) (*connect.Response[pb.Config], error)

func (*Service) Lookup

func (s *Service) Lookup(id string) (config.Parser, error)

func (*Service) New

func (s *Service) New(context.Context, *connect.Request[pb.Empty]) (*connect.Response[pb.Config], error)

func (*Service) Upload

func (s *Service) Upload(ctx context.Context, stream *connect.ClientStream[pb.SourceUpload]) (*connect.Response[pb.Config], error)