Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

slave

package

Go to main page

Versions in this module

v1

v1.0.2

Jan 14, 2025

v1.0.1

Jan 14, 2025

v1.0.0

Jan 13, 2025

Changes in this version

+ var ErrCommandNotFound = fmt.Errorf("command not found")

+ var ErrFailedToSendLoaderResourceRequest = fmt.Errorf("failed to send loader resource request")

+ var ErrInvalidCommandID = fmt.Errorf("invalid command ID")

+ var ErrInvalidConnectionID = fmt.Errorf("invalid connection ID")

+ var ErrInvalidEnvironment = fmt.Errorf("must connect to the same environment")

+ var ErrLoaderNotFound = fmt.Errorf("loader not found")

+ var ErrRequestNotFound = fmt.Errorf("request not found")

+ func Run(ctr *container.Container) error

+ func StreamServerInterceptor(encrypter encrypt.Encrypter) grpc.StreamServerInterceptor

+ func UnaryServerEncryptInterceptor(encrypter encrypt.Encrypter) grpc.UnaryServerInterceptor

+ type AuthenticatorFactor struct

+ func (s *AuthenticatorFactor) Factorize(ctx context.Context, authID string, isDefault bool) (auth.SetAuthor, error)

+ func (s *AuthenticatorFactor) IsDefault(authID string) bool

+ type Output struct

+ OutputID string

+ func NewSlaveOutput(outputID string, outputChan chan<- *pb.CallExecResponse) Output

+ func (o Output) HTTPDataWriteFactory(ctx context.Context, _ logger.Logger, enabled bool, uniqueName string, ...) (output.HTTPDataWrite, output.Close, error)

+ type OutputFactor struct

+ func (f *OutputFactor) Factorize(_ context.Context, outputID string) (output.Output, error)

+ type Server struct

+ func NewServer(ctr *container.Container, slaveConCtr *runner.ConnectionContainer) *Server

+ func (s *Server) CallExec(req *pb.CallExecRequest, ...) error

+ func (s *Server) Connect(_ context.Context, req *pb.ConnectRequest) (*pb.ConnectResponse, error)

+ func (s *Server) Disconnect(_ context.Context, req *pb.DisconnectRequest) (*pb.DisconnectResponse, error)

+ func (s *Server) ReceiveChanelConnect(req *pb.ReceiveChanelConnectRequest, ...) error

+ func (s *Server) ReceiveLoadTermChannel(ctx context.Context, req *pb.ReceiveLoadTermChannelRequest) (*pb.ReceiveLoadTermChannelResponse, error)

+ func (s *Server) SendAuth(_ context.Context, req *pb.SendAuthRequest) (*pb.SendAuthResponse, error)

+ func (s *Server) SendLoader(stream grpc.ClientStreamingServer[pb.SendLoaderRequest, pb.SendLoaderResponse]) error

+ func (s *Server) SendStoreData(...) error

+ func (s *Server) SendStoreOk(_ context.Context, req *pb.SendStoreOkRequest) (*pb.SendStoreOkResponse, error)

+ func (s *Server) SendTarget(_ context.Context, req *pb.SendTargetRequest) (*pb.SendTargetResponse, error)

+ func (s *Server) SlaveCommand(ctx context.Context, req *pb.SlaveCommandRequest) (*pb.SlaveCommandResponse, error)

+ func (s *Server) SlaveCommandDefaultStore(stream ...) error

+ type Store struct

+ func (s *Store) Import(ctx context.Context, data []runner.ValidStoreImportData, ...) error

+ func (s *Store) Store(ctx context.Context, data []runner.ValidStoreValueData, ...) error

+ func (s *Store) StoreWithExtractor(ctx context.Context, res any, data []runner.ValidExecRequestStoreData, ...) error

+ type TargetFactor struct

+ func (s *TargetFactor) Factorize(ctx context.Context, targetID string) (target.Target, error)

+ type TmplFactor struct

+ func (s *TmplFactor) TmplFactorize(ctx context.Context, path string) (string, error)