gadgetservice

Documentation

Index

• type Logger
  • func (l *Logger) GetLevel() logger.Level
  • func (l *Logger) Log(severity logger.Level, params ...any)
  • func (l *Logger) Logf(severity logger.Level, format string, params ...any)
  • func (l *Logger) SetLevel(level logger.Level)
• type RunConfig
• type Service
  • func NewService(defaultLogger logger.Logger) *Service
  • func (s *Service) Close()
  • func (s *Service) CreateGadgetInstance(ctx context.Context, request *api.CreateGadgetInstanceRequest) (*api.CreateGadgetInstanceResponse, error)
  • func (s *Service) GetGadgetInfo(ctx context.Context, req *api.GetGadgetInfoRequest) (*api.GetGadgetInfoResponse, error)
  • func (s *Service) GetGadgetInstance(ctx context.Context, id *api.GadgetInstanceId) (*api.GadgetInstance, error)
  • func (s *Service) GetInfo(ctx context.Context, request *api.InfoRequest) (*api.InfoResponse, error)
  • func (s *Service) GetOperatorMap() map[operators.DataOperator]*params.Params
  • func (s *Service) ListGadgetInstances(ctx context.Context, request *api.ListGadgetInstancesRequest) (*api.ListGadgetInstanceResponse, error)
  • func (s *Service) RemoveGadgetInstance(ctx context.Context, id *api.GadgetInstanceId) (*api.StatusResponse, error)
  • func (s *Service) Run(runConfig RunConfig, serverOptions ...grpc.ServerOption) error
  • func (s *Service) RunBuiltInGadget(runGadget api.BuiltInGadgetManager_RunBuiltInGadgetServer) error
  • func (s *Service) RunGadget(runGadget api.GadgetManager_RunGadgetServer) error
  • func (s *Service) SetEventBufferLength(val uint64)
  • func (s *Service) SetInstanceManager(mgr *instancemanager.Manager)
  • func (s *Service) SetStore(store store.Store)

Types

type Logger

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

Logger sends log messages through grpc

func (*Logger) GetLevel

func (l *Logger) GetLevel() logger.Level

func (*Logger) Log

func (l *Logger) Log(severity logger.Level, params ...any)

func (*Logger) Logf

func (l *Logger) Logf(severity logger.Level, format string, params ...any)

func (*Logger) SetLevel

func (l *Logger) SetLevel(level logger.Level)

type RunConfig

type RunConfig struct {
	// SocketType can be either unix or tcp
	SocketType string

	// SocketPath must be the path to a unix socket or ip:port, depending on
	// SocketType
	SocketPath string

	// If SocketGID != 0 and a unix socket is used, the ownership of that socket
	// will be changed to the given SocketGID
	SocketGID int
}

type Service

type Service struct {
	api.UnimplementedBuiltInGadgetManagerServer
	api.UnimplementedGadgetManagerServer
	api.UnimplementedGadgetInstanceManagerServer
	// contains filtered or unexported fields
}

func NewService

func NewService(defaultLogger logger.Logger) *Service

func (*Service) Close

func (s *Service) Close()

func (*Service) CreateGadgetInstance

func (s *Service) CreateGadgetInstance(ctx context.Context, request *api.CreateGadgetInstanceRequest) (*api.CreateGadgetInstanceResponse, error)

func (*Service) GetGadgetInfo

func (s *Service) GetGadgetInfo(ctx context.Context, req *api.GetGadgetInfoRequest) (*api.GetGadgetInfoResponse, error)

func (*Service) GetGadgetInstance

func (s *Service) GetGadgetInstance(ctx context.Context, id *api.GadgetInstanceId) (*api.GadgetInstance, error)

func (*Service) GetInfo

func (s *Service) GetInfo(ctx context.Context, request *api.InfoRequest) (*api.InfoResponse, error)

func (*Service) GetOperatorMap

func (s *Service) GetOperatorMap() map[operators.DataOperator]*params.Params

func (*Service) ListGadgetInstances

func (s *Service) ListGadgetInstances(ctx context.Context, request *api.ListGadgetInstancesRequest) (*api.ListGadgetInstanceResponse, error)

func (*Service) RemoveGadgetInstance

func (s *Service) RemoveGadgetInstance(ctx context.Context, id *api.GadgetInstanceId) (*api.StatusResponse, error)

func (*Service) Run

func (s *Service) Run(runConfig RunConfig, serverOptions ...grpc.ServerOption) error

func (*Service) RunBuiltInGadget

func (s *Service) RunBuiltInGadget(runGadget api.BuiltInGadgetManager_RunBuiltInGadgetServer) error

func (*Service) RunGadget

func (s *Service) RunGadget(runGadget api.GadgetManager_RunGadgetServer) error

func (*Service) SetEventBufferLength

func (s *Service) SetEventBufferLength(val uint64)

func (*Service) SetInstanceManager

func (s *Service) SetInstanceManager(mgr *instancemanager.Manager)

func (*Service) SetStore

func (s *Service) SetStore(store store.Store)