device_agent

Documentation

Index

• func NewStateMachine(ctx context.Context, rc runtimeconfig.RuntimeConfig, cfg config.Config, ...) *statemachine.StateMachine
• type DeviceAgentServer
  • func NewServer(ctx context.Context, log *logrus.Entry, cfg *config.Config, ...) *DeviceAgentServer
  • func (das *DeviceAgentServer) ConfigureJITA(context.Context, *pb.ConfigureJITARequest) (*pb.ConfigureJITAResponse, error)
  • func (das *DeviceAgentServer) GetAgentConfiguration(ctx context.Context, req *pb.GetAgentConfigurationRequest) (*pb.GetAgentConfigurationResponse, error)
  • func (das *DeviceAgentServer) Login(ctx context.Context, request *pb.LoginRequest) (*pb.LoginResponse, error)
  • func (das *DeviceAgentServer) Logout(ctx context.Context, request *pb.LogoutRequest) (*pb.LogoutResponse, error)
  • func (das *DeviceAgentServer) SetActiveTenant(ctx context.Context, req *pb.SetActiveTenantRequest) (*pb.SetActiveTenantResponse, error)
  • func (das *DeviceAgentServer) SetAgentConfiguration(ctx context.Context, req *pb.SetAgentConfigurationRequest) (*pb.SetAgentConfigurationResponse, error)
  • func (das *DeviceAgentServer) Status(request *pb.AgentStatusRequest, statusServer pb.DeviceAgent_StatusServer) error
  • func (das *DeviceAgentServer) UpdateAgentStatus(status *pb.AgentStatus)

Functions

func NewStateMachine

func NewStateMachine(
	ctx context.Context,
	rc runtimeconfig.RuntimeConfig,
	cfg config.Config,
	notifier notify.Notifier,
	deviceHelper pb.DeviceHelperClient,
	statusUpdates chan<- *pb.AgentStatus,
	logger logrus.FieldLogger,
) *statemachine.StateMachine

Types

type DeviceAgentServer

type DeviceAgentServer struct {
	pb.UnimplementedDeviceAgentServer
	Config *config.Config

	AgentStatus *pb.AgentStatus
	// contains filtered or unexported fields
}

func NewServer

func NewServer(ctx context.Context,
	log *logrus.Entry,
	cfg *config.Config,
	rc runtimeconfig.RuntimeConfig,
	notifier notify.Notifier,
	sendEvent func(state.EventWithSpan),
) *DeviceAgentServer

func (*DeviceAgentServer) ConfigureJITA

func (das *DeviceAgentServer) ConfigureJITA(context.Context, *pb.ConfigureJITARequest) (*pb.ConfigureJITAResponse, error)

func (*DeviceAgentServer) GetAgentConfiguration

func (das *DeviceAgentServer) GetAgentConfiguration(ctx context.Context, req *pb.GetAgentConfigurationRequest) (*pb.GetAgentConfigurationResponse, error)

func (*DeviceAgentServer) Login

func (das *DeviceAgentServer) Login(ctx context.Context, request *pb.LoginRequest) (*pb.LoginResponse, error)

func (*DeviceAgentServer) Logout

func (das *DeviceAgentServer) Logout(ctx context.Context, request *pb.LogoutRequest) (*pb.LogoutResponse, error)

func (*DeviceAgentServer) SetActiveTenant

func (das *DeviceAgentServer) SetActiveTenant(ctx context.Context, req *pb.SetActiveTenantRequest) (*pb.SetActiveTenantResponse, error)

func (*DeviceAgentServer) SetAgentConfiguration

func (das *DeviceAgentServer) SetAgentConfiguration(ctx context.Context, req *pb.SetAgentConfigurationRequest) (*pb.SetAgentConfigurationResponse, error)

func (*DeviceAgentServer) Status

func (das *DeviceAgentServer) Status(request *pb.AgentStatusRequest, statusServer pb.DeviceAgent_StatusServer) error

func (*DeviceAgentServer) UpdateAgentStatus

func (das *DeviceAgentServer) UpdateAgentStatus(status *pb.AgentStatus)