agent

package

Go to main page

Versions in this module

v0

v0.4.0

Dec 6, 2024

Changes in this version

+ var ErrAttestationFailed = errors.New("failed to get raw quote")

+ type AgentEvent int

+ const AlgorithmReceived

+ const DataReceived

+ const ManifestReceived

+ const ResultsConsumed

+ const RunComplete

+ const RunFailed

+ const Start

+ func (i AgentEvent) String() string

+ type AgentService_AttestationClient = grpc.ServerStreamingClient[AttestationResponse]

+ type AgentService_AttestationServer = grpc.ServerStreamingServer[AttestationResponse]

+ type AgentState int

+ const Complete

+ const ConsumingResults

+ const Failed

+ const Idle

+ const ReceivingAlgorithm

+ const ReceivingData

+ const ReceivingManifest

+ const Running

+ func (i AgentState) String() string

+ type Status uint8

+ const Completed

+ const IdleState

+ const InProgress

+ const Ready

+ const Starting

+ const Terminated

+ const Warning

+ func (i Status) String() string

v0.3.1

Aug 26, 2024

v0.3.0

Aug 23, 2024

Changes in this version

+ const DecompressKey

+ var ErrAllResultsConsumed = errors.New("all results have been consumed by declared consumers")

+ var ErrFileNameMismatch = errors.New("malformed data, filename does not match manifest")

+ func DecompressFromContext(ctx context.Context) bool

+ func DecompressToContext(ctx context.Context, decompress bool) context.Context

type DataRequest

+ Filename string

+ func (x *DataRequest) GetFilename() string

type Dataset

+ Filename string

v0.2.0

Jul 31, 2024

Changes in this version

+ var ErrAllManifestItemsReceived = errors.New("all expected manifest Items have been received")

+ var ErrHashMismatch = errors.New("malformed data, hash does not match manifest")

+ var ErrResultsNotReady = errors.New("computation results are not yet ready")

+ var ErrStateNotReady = errors.New("agent not expecting this operation in the current state")

+ var ErrUndeclaredConsumer = errors.New("result consumer is undeclared in computation manifest")

+ var ErrUndeclaredDataset = errors.New("dataset not declared in computation manifest")

+ func IndexFromContext(ctx context.Context) (int, bool)

+ func IndexToContext(ctx context.Context, index int) context.Context

+ type AgentService_AlgoClient interface

+ CloseAndRecv func() (*AlgoResponse, error)

+ Send func(*AlgoRequest) error

+ type AgentService_AlgoServer interface

+ Recv func() (*AlgoRequest, error)

+ SendAndClose func(*AlgoResponse) error

+ type AgentService_DataClient interface

+ CloseAndRecv func() (*DataResponse, error)

+ Send func(*DataRequest) error

+ type AgentService_DataServer interface

+ Recv func() (*DataRequest, error)

+ SendAndClose func(*DataResponse) error

+ type AgentService_ResultClient interface

+ Recv func() (*ResultResponse, error)

+ type AgentService_ResultServer interface

+ Send func(*ResultResponse) error

type AlgoRequest

+ Requirements []byte

+ func (x *AlgoRequest) GetRequirements() []byte

type Algorithm

+ Requirements []byte

+ UserKey []byte

type Dataset

+ UserKey []byte

+ type ManifestIndexKey struct

+ type ResultConsumer struct

+ UserKey []byte

v0.1.0

Apr 17, 2024

Changes in this version

+ const ReportDataSize

type AgentConfig

+ AttestedTls bool

type Computation

+ Algorithm Algorithm

v0.0.2

Mar 15, 2024

Changes in this version

+ type AgentConfig struct

+ CertFile string

+ ClientCAFile string

+ Host string

+ KeyFile string

+ LogLevel string

+ Port string

+ ServerCAFile string

type Algorithm

+ Hash [32]byte

type AttestationRequest

+ ReportData []byte

+ func (x *AttestationRequest) GetReportData() []byte

type Computation

+ AgentConfig AgentConfig

type Dataset

+ Hash [32]byte

v0.0.1

Jan 12, 2024

Changes in this version

+ const AgentService_Algo_FullMethodName

+ const AgentService_Attestation_FullMethodName

+ const AgentService_Data_FullMethodName

+ const AgentService_Result_FullMethodName

+ var AgentService_ServiceDesc = grpc.ServiceDesc

+ var ErrMalformedEntity = errors.New("malformed entity specification")

+ var ErrUnauthorizedAccess = errors.New("missing or invalid credentials provided")

+ var File_agent_agent_proto protoreflect.FileDescriptor

+ func RegisterAgentServiceServer(s grpc.ServiceRegistrar, srv AgentServiceServer)

+ type AgentServiceClient interface

+ Algo func(ctx context.Context, in *AlgoRequest, opts ...grpc.CallOption) (*AlgoResponse, error)

+ Attestation func(ctx context.Context, in *AttestationRequest, opts ...grpc.CallOption) (*AttestationResponse, error)

+ Data func(ctx context.Context, in *DataRequest, opts ...grpc.CallOption) (*DataResponse, error)

+ Result func(ctx context.Context, in *ResultRequest, opts ...grpc.CallOption) (*ResultResponse, error)

+ func NewAgentServiceClient(cc grpc.ClientConnInterface) AgentServiceClient

+ type AgentServiceServer interface

+ Algo func(context.Context, *AlgoRequest) (*AlgoResponse, error)

+ Attestation func(context.Context, *AttestationRequest) (*AttestationResponse, error)

+ Data func(context.Context, *DataRequest) (*DataResponse, error)

+ Result func(context.Context, *ResultRequest) (*ResultResponse, error)

+ type AlgoRequest struct

+ Algorithm []byte

+ Id string

+ Provider string

+ func (*AlgoRequest) Descriptor() ([]byte, []int)

+ func (*AlgoRequest) ProtoMessage()

+ func (x *AlgoRequest) GetAlgorithm() []byte

+ func (x *AlgoRequest) GetId() string

+ func (x *AlgoRequest) GetProvider() string

+ func (x *AlgoRequest) ProtoReflect() protoreflect.Message

+ func (x *AlgoRequest) Reset()

+ func (x *AlgoRequest) String() string

+ type AlgoResponse struct

+ AlgorithmID string

+ func (*AlgoResponse) Descriptor() ([]byte, []int)

+ func (*AlgoResponse) ProtoMessage()

+ func (x *AlgoResponse) GetAlgorithmID() string

+ func (x *AlgoResponse) ProtoReflect() protoreflect.Message

+ func (x *AlgoResponse) Reset()

+ func (x *AlgoResponse) String() string

+ type Algorithm struct

+ Algorithm []byte

+ ID string

+ Provider string

+ type AlgorithmReq struct

+ Id string

+ Provider string

+ func (*AlgorithmReq) Descriptor() ([]byte, []int)

+ func (*AlgorithmReq) ProtoMessage()

+ func (x *AlgorithmReq) GetId() string

+ func (x *AlgorithmReq) GetProvider() string

+ func (x *AlgorithmReq) ProtoReflect() protoreflect.Message

+ func (x *AlgorithmReq) Reset()

+ func (x *AlgorithmReq) String() string

+ type Algorithms []Algorithm

+ func (a *Algorithms) String() string

+ type AttestationRequest struct

+ func (*AttestationRequest) Descriptor() ([]byte, []int)

+ func (*AttestationRequest) ProtoMessage()

+ func (x *AttestationRequest) ProtoReflect() protoreflect.Message

+ func (x *AttestationRequest) Reset()

+ func (x *AttestationRequest) String() string

+ type AttestationResponse struct

+ File []byte

+ func (*AttestationResponse) Descriptor() ([]byte, []int)

+ func (*AttestationResponse) ProtoMessage()

+ func (x *AttestationResponse) GetFile() []byte

+ func (x *AttestationResponse) ProtoReflect() protoreflect.Message

+ func (x *AttestationResponse) Reset()

+ func (x *AttestationResponse) String() string

+ type Computation struct

+ Algorithms Algorithms

+ Datasets Datasets

+ Description string

+ ID string

+ Name string

+ ResultConsumers []string

+ type ComputationReq struct

+ Algorithms []*AlgorithmReq

+ Datasets []*DatasetReq

+ Description string

+ Id string

+ Name string

+ ResultConsumers []string

+ func (*ComputationReq) Descriptor() ([]byte, []int)

+ func (*ComputationReq) ProtoMessage()

+ func (x *ComputationReq) GetAlgorithms() []*AlgorithmReq

+ func (x *ComputationReq) GetDatasets() []*DatasetReq

+ func (x *ComputationReq) GetDescription() string

+ func (x *ComputationReq) GetId() string

+ func (x *ComputationReq) GetName() string

+ func (x *ComputationReq) GetResultConsumers() []string

+ func (x *ComputationReq) ProtoReflect() protoreflect.Message

+ func (x *ComputationReq) Reset()

+ func (x *ComputationReq) String() string

+ type DataRequest struct

+ Dataset []byte

+ Id string

+ Provider string

+ func (*DataRequest) Descriptor() ([]byte, []int)

+ func (*DataRequest) ProtoMessage()

+ func (x *DataRequest) GetDataset() []byte

+ func (x *DataRequest) GetId() string

+ func (x *DataRequest) GetProvider() string

+ func (x *DataRequest) ProtoReflect() protoreflect.Message

+ func (x *DataRequest) Reset()

+ func (x *DataRequest) String() string

+ type DataResponse struct

+ DatasetID string

+ func (*DataResponse) Descriptor() ([]byte, []int)

+ func (*DataResponse) ProtoMessage()

+ func (x *DataResponse) GetDatasetID() string

+ func (x *DataResponse) ProtoReflect() protoreflect.Message

+ func (x *DataResponse) Reset()

+ func (x *DataResponse) String() string

+ type Dataset struct

+ Dataset []byte

+ ID string

+ Provider string

+ type DatasetReq struct

+ Id string

+ Provider string

+ func (*DatasetReq) Descriptor() ([]byte, []int)

+ func (*DatasetReq) ProtoMessage()

+ func (x *DatasetReq) GetId() string

+ func (x *DatasetReq) GetProvider() string

+ func (x *DatasetReq) ProtoReflect() protoreflect.Message

+ func (x *DatasetReq) Reset()

+ func (x *DatasetReq) String() string

+ type Datasets []Dataset

+ func (d *Datasets) String() string

+ type ResultRequest struct

+ Consumer string

+ func (*ResultRequest) Descriptor() ([]byte, []int)

+ func (*ResultRequest) ProtoMessage()

+ func (x *ResultRequest) GetConsumer() string

+ func (x *ResultRequest) ProtoReflect() protoreflect.Message

+ func (x *ResultRequest) Reset()

+ func (x *ResultRequest) String() string

+ type ResultResponse struct

+ File []byte

+ func (*ResultResponse) Descriptor() ([]byte, []int)

+ func (*ResultResponse) ProtoMessage()

+ func (x *ResultResponse) GetFile() []byte

+ func (x *ResultResponse) ProtoReflect() protoreflect.Message

+ func (x *ResultResponse) Reset()

+ func (x *ResultResponse) String() string

+ type Service interface

+ Algo func(ctx context.Context, algorithm Algorithm) (string, error)

+ Attestation func(ctx context.Context) ([]byte, error)

+ Data func(ctx context.Context, dataset Dataset) (string, error)

+ Result func(ctx context.Context, consumer string) ([]byte, error)

+ Run func(ctx context.Context, c Computation) (string, error)

+ func New(ctx context.Context, logger mglog.Logger, eventSvc events.Service) Service

+ type StateMachine struct

+ EventChan chan event

+ State state

+ StateFunctions map[state]func()

+ Transitions map[state]map[event]state

+ func NewStateMachine(logger mglog.Logger) *StateMachine

+ func (sm *StateMachine) GetState() state

+ func (sm *StateMachine) SendEvent(event event)

+ func (sm *StateMachine) SetState(state state)

+ func (sm *StateMachine) Start(ctx context.Context)

+ type UnimplementedAgentServiceServer struct

+ func (UnimplementedAgentServiceServer) Algo(context.Context, *AlgoRequest) (*AlgoResponse, error)

+ func (UnimplementedAgentServiceServer) Attestation(context.Context, *AttestationRequest) (*AttestationResponse, error)

+ func (UnimplementedAgentServiceServer) Data(context.Context, *DataRequest) (*DataResponse, error)

+ func (UnimplementedAgentServiceServer) Result(context.Context, *ResultRequest) (*ResultResponse, error)

+ type UnsafeAgentServiceServer interface

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL