process

Documentation

Index

• type Service
  • func Handle(server *chi.Mux, l *zerolog.Logger, envs *utils.Map[string, string]) *Service
  • func (s *Service) Connect(ctx context.Context, req *connect.Request[rpc.ConnectRequest], ...) error
  • func (s *Service) InitializeStartProcess(ctx context.Context, user *user.User, req *rpc.StartRequest) error
  • func (s *Service) List(ctx context.Context, req *connect.Request[rpc.ListRequest]) (*connect.Response[rpc.ListResponse], error)
  • func (s *Service) SendInput(ctx context.Context, req *connect.Request[rpc.SendInputRequest]) (*connect.Response[rpc.SendInputResponse], error)
  • func (s *Service) SendSignal(ctx context.Context, req *connect.Request[rpc.SendSignalRequest]) (*connect.Response[rpc.SendSignalResponse], error)
  • func (s *Service) Start(ctx context.Context, req *connect.Request[rpc.StartRequest], ...) error
  • func (s *Service) StreamInput(ctx context.Context, stream *connect.ClientStream[rpc.StreamInputRequest]) (*connect.Response[rpc.StreamInputResponse], error)
  • func (s *Service) Update(ctx context.Context, req *connect.Request[rpc.UpdateRequest]) (*connect.Response[rpc.UpdateResponse], error)

Types

type Service

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

func Handle

func Handle(server *chi.Mux, l *zerolog.Logger, envs *utils.Map[string, string]) *Service

func (*Service) Connect

func (s *Service) Connect(ctx context.Context, req *connect.Request[rpc.ConnectRequest], stream *connect.ServerStream[rpc.ConnectResponse]) error

func (*Service) InitializeStartProcess

func (s *Service) InitializeStartProcess(ctx context.Context, user *user.User, req *rpc.StartRequest) error

func (*Service) List

func (s *Service) List(ctx context.Context, req *connect.Request[rpc.ListRequest]) (*connect.Response[rpc.ListResponse], error)

func (*Service) SendInput

func (s *Service) SendInput(ctx context.Context, req *connect.Request[rpc.SendInputRequest]) (*connect.Response[rpc.SendInputResponse], error)

func (*Service) SendSignal

func (s *Service) SendSignal(ctx context.Context, req *connect.Request[rpc.SendSignalRequest]) (*connect.Response[rpc.SendSignalResponse], error)

func (*Service) Start

func (s *Service) Start(ctx context.Context, req *connect.Request[rpc.StartRequest], stream *connect.ServerStream[rpc.StartResponse]) error

func (*Service) StreamInput

func (s *Service) StreamInput(ctx context.Context, stream *connect.ClientStream[rpc.StreamInputRequest]) (*connect.Response[rpc.StreamInputResponse], error)

func (*Service) Update

func (s *Service) Update(ctx context.Context, req *connect.Request[rpc.UpdateRequest]) (*connect.Response[rpc.UpdateResponse], error)