datasource

package
v0.27.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 27, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const DataSourcePluginName = "data_source"

DataSourcePluginName is the name that should be used in the plugin map.

Variables

This section is empty.

Functions

This section is empty.

Types

type DataSource 

type DataSource interface {
	validator.Validator

	AddTrustZone(trustZone *trust_zone_proto.TrustZone) (*trust_zone_proto.TrustZone, error)
	DestroyTrustZone(id string) error
	GetTrustZone(id string) (*trust_zone_proto.TrustZone, error)
	GetTrustZoneByName(name string) (*trust_zone_proto.TrustZone, error)
	ListTrustZones() ([]*trust_zone_proto.TrustZone, error)
	UpdateTrustZone(trustZone *trust_zone_proto.TrustZone) (*trust_zone_proto.TrustZone, error)

	AddCluster(cluster *clusterpb.Cluster) (*clusterpb.Cluster, error)
	DestroyCluster(id string) error
	GetCluster(id string) (*clusterpb.Cluster, error)
	GetClusterByName(name, trustZoneID string) (*clusterpb.Cluster, error)
	ListClusters(filter *datasourcepb.ListClustersRequest_Filter) ([]*clusterpb.Cluster, error)
	UpdateCluster(cluster *clusterpb.Cluster) (*clusterpb.Cluster, error)

	AddAttestationPolicy(policy *attestation_policy_proto.AttestationPolicy) (*attestation_policy_proto.AttestationPolicy, error)
	DestroyAttestationPolicy(id string) error
	GetAttestationPolicy(id string) (*attestation_policy_proto.AttestationPolicy, error)
	GetAttestationPolicyByName(name string) (*attestation_policy_proto.AttestationPolicy, error)
	ListAttestationPolicies() ([]*attestation_policy_proto.AttestationPolicy, error)

	AddAPBinding(binding *ap_binding_proto.APBinding) (*ap_binding_proto.APBinding, error)
	DestroyAPBinding(id string) error
	ListAPBindings(filter *datasourcepb.ListAPBindingsRequest_Filter) ([]*ap_binding_proto.APBinding, error)

	AddFederation(federation *federation_proto.Federation) (*federation_proto.Federation, error)
	DestroyFederation(id string) error
	ListFederations(filter *datasourcepb.ListFederationsRequest_Filter) ([]*federation_proto.Federation, error)
}

DataSource is the interface data source plugins have to implement.

type DataSourcePlugin 

type DataSourcePlugin struct {
	go_plugin.Plugin
	Impl DataSource
}

DataSourcePlugin implements the plugin.Plugin interface to provide the GRPC server or client back to the plugin machinery. The server side should proved the Impl field with a concrete implementation of the DataSource interface.

func (*DataSourcePlugin) GRPCClient 

func (dsp *DataSourcePlugin) GRPCClient(ctx context.Context, broker *go_plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

func (*DataSourcePlugin) GRPCServer 

func (dsp *DataSourcePlugin) GRPCServer(broker *go_plugin.GRPCBroker, s *grpc.Server) error

type DataSourcePluginClientGRPC 

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

DataSourcePluginClientGRPC is used by clients (main application) to translate the DataSource interface of plugins to GRPC calls.

func NewDataSourcePluginClientGRPC 

func NewDataSourcePluginClientGRPC(ctx context.Context, client cofidectl_proto.DataSourcePluginServiceClient) *DataSourcePluginClientGRPC

func (*DataSourcePluginClientGRPC) AddAPBinding 

func (c *DataSourcePluginClientGRPC) AddAPBinding(binding *ap_binding_proto.APBinding) (*ap_binding_proto.APBinding, error)

func (*DataSourcePluginClientGRPC) AddAttestationPolicy 

func (c *DataSourcePluginClientGRPC) AddAttestationPolicy(policy *attestation_policy_proto.AttestationPolicy) (*attestation_policy_proto.AttestationPolicy, error)

func (*DataSourcePluginClientGRPC) AddCluster added in v0.7.1 

func (c *DataSourcePluginClientGRPC) AddCluster(cluster *clusterpb.Cluster) (*clusterpb.Cluster, error)

func (*DataSourcePluginClientGRPC) AddFederation 

func (c *DataSourcePluginClientGRPC) AddFederation(federation *federation_proto.Federation) (*federation_proto.Federation, error)

func (*DataSourcePluginClientGRPC) AddTrustZone 

func (c *DataSourcePluginClientGRPC) AddTrustZone(trustZone *trust_zone_proto.TrustZone) (*trust_zone_proto.TrustZone, error)

func (*DataSourcePluginClientGRPC) DestroyAPBinding 

func (c *DataSourcePluginClientGRPC) DestroyAPBinding(id string) error

func (*DataSourcePluginClientGRPC) DestroyAttestationPolicy added in v0.12.0 

func (c *DataSourcePluginClientGRPC) DestroyAttestationPolicy(id string) error

func (*DataSourcePluginClientGRPC) DestroyCluster added in v0.12.0 

func (c *DataSourcePluginClientGRPC) DestroyCluster(id string) error

func (*DataSourcePluginClientGRPC) DestroyFederation added in v0.12.0 

func (c *DataSourcePluginClientGRPC) DestroyFederation(id string) error

func (*DataSourcePluginClientGRPC) DestroyTrustZone added in v0.12.0 

func (c *DataSourcePluginClientGRPC) DestroyTrustZone(id string) error

func (*DataSourcePluginClientGRPC) GetAttestationPolicy 

func (c *DataSourcePluginClientGRPC) GetAttestationPolicy(id string) (*attestation_policy_proto.AttestationPolicy, error)

func (*DataSourcePluginClientGRPC) GetAttestationPolicyByName added in v0.15.0 

func (c *DataSourcePluginClientGRPC) GetAttestationPolicyByName(name string) (*attestation_policy_proto.AttestationPolicy, error)

func (*DataSourcePluginClientGRPC) GetCluster added in v0.7.1 

func (c *DataSourcePluginClientGRPC) GetCluster(id string) (*clusterpb.Cluster, error)

func (*DataSourcePluginClientGRPC) GetClusterByName added in v0.15.0 

func (c *DataSourcePluginClientGRPC) GetClusterByName(name, trustZoneID string) (*clusterpb.Cluster, error)

func (*DataSourcePluginClientGRPC) GetTrustZone 

func (c *DataSourcePluginClientGRPC) GetTrustZone(id string) (*trust_zone_proto.TrustZone, error)

func (*DataSourcePluginClientGRPC) GetTrustZoneByName added in v0.15.0 

func (c *DataSourcePluginClientGRPC) GetTrustZoneByName(name string) (*trust_zone_proto.TrustZone, error)

func (*DataSourcePluginClientGRPC) ListAPBindings added in v0.10.1 

func (c *DataSourcePluginClientGRPC) ListAPBindings(filter *cofidectl_proto.ListAPBindingsRequest_Filter) ([]*ap_binding_proto.APBinding, error)

func (*DataSourcePluginClientGRPC) ListAttestationPolicies 

func (c *DataSourcePluginClientGRPC) ListAttestationPolicies() ([]*attestation_policy_proto.AttestationPolicy, error)

func (*DataSourcePluginClientGRPC) ListClusters added in v0.7.1 

func (c *DataSourcePluginClientGRPC) ListClusters(filter *cofidectl_proto.ListClustersRequest_Filter) ([]*clusterpb.Cluster, error)

func (*DataSourcePluginClientGRPC) ListFederations 

func (c *DataSourcePluginClientGRPC) ListFederations(filter *cofidectl_proto.ListFederationsRequest_Filter) ([]*federation_proto.Federation, error)

func (*DataSourcePluginClientGRPC) ListTrustZones 

func (c *DataSourcePluginClientGRPC) ListTrustZones() ([]*trust_zone_proto.TrustZone, error)

func (*DataSourcePluginClientGRPC) UpdateCluster added in v0.7.1 

func (c *DataSourcePluginClientGRPC) UpdateCluster(cluster *clusterpb.Cluster) (*clusterpb.Cluster, error)

func (*DataSourcePluginClientGRPC) UpdateTrustZone 

func (c *DataSourcePluginClientGRPC) UpdateTrustZone(trustZone *trust_zone_proto.TrustZone) (*trust_zone_proto.TrustZone, error)

func (*DataSourcePluginClientGRPC) Validate 

func (c *DataSourcePluginClientGRPC) Validate(ctx context.Context) error

type GRPCServer 

type GRPCServer struct {
	cofidectl_proto.UnimplementedDataSourcePluginServiceServer
	Impl DataSource
}

func (*GRPCServer) AddAPBinding 

func (s *GRPCServer) AddAPBinding(_ context.Context, req *cofidectl_proto.AddAPBindingRequest) (*cofidectl_proto.AddAPBindingResponse, error)

func (*GRPCServer) AddAttestationPolicy 

func (s *GRPCServer) AddAttestationPolicy(_ context.Context, req *cofidectl_proto.AddAttestationPolicyRequest) (*cofidectl_proto.AddAttestationPolicyResponse, error)

func (*GRPCServer) AddCluster added in v0.7.1 

func (s *GRPCServer) AddCluster(_ context.Context, req *cofidectl_proto.AddClusterRequest) (*cofidectl_proto.AddClusterResponse, error)

func (*GRPCServer) AddFederation 

func (s *GRPCServer) AddFederation(_ context.Context, req *cofidectl_proto.AddFederationRequest) (*cofidectl_proto.AddFederationResponse, error)

func (*GRPCServer) AddTrustZone 

func (s *GRPCServer) AddTrustZone(_ context.Context, req *cofidectl_proto.AddTrustZoneRequest) (*cofidectl_proto.AddTrustZoneResponse, error)

func (*GRPCServer) DestroyAPBinding 

func (s *GRPCServer) DestroyAPBinding(_ context.Context, req *cofidectl_proto.DestroyAPBindingRequest) (*cofidectl_proto.DestroyAPBindingResponse, error)

func (*GRPCServer) DestroyAttestationPolicy added in v0.12.0 

func (s *GRPCServer) DestroyAttestationPolicy(_ context.Context, req *cofidectl_proto.DestroyAttestationPolicyRequest) (*cofidectl_proto.DestroyAttestationPolicyResponse, error)

func (*GRPCServer) DestroyCluster added in v0.12.0 

func (s *GRPCServer) DestroyCluster(_ context.Context, req *cofidectl_proto.DestroyClusterRequest) (*cofidectl_proto.DestroyClusterResponse, error)

func (*GRPCServer) DestroyFederation added in v0.12.0 

func (s *GRPCServer) DestroyFederation(_ context.Context, req *cofidectl_proto.DestroyFederationRequest) (*cofidectl_proto.DestroyFederationResponse, error)

func (*GRPCServer) DestroyTrustZone added in v0.12.0 

func (s *GRPCServer) DestroyTrustZone(_ context.Context, req *cofidectl_proto.DestroyTrustZoneRequest) (*cofidectl_proto.DestroyTrustZoneResponse, error)

func (*GRPCServer) GetAttestationPolicy 

func (s *GRPCServer) GetAttestationPolicy(_ context.Context, req *cofidectl_proto.GetAttestationPolicyRequest) (*cofidectl_proto.GetAttestationPolicyResponse, error)

func (*GRPCServer) GetAttestationPolicyByName added in v0.15.0 

func (s *GRPCServer) GetAttestationPolicyByName(_ context.Context, req *cofidectl_proto.GetAttestationPolicyByNameRequest) (*cofidectl_proto.GetAttestationPolicyByNameResponse, error)

func (*GRPCServer) GetCluster added in v0.7.1 

func (s *GRPCServer) GetCluster(_ context.Context, req *cofidectl_proto.GetClusterRequest) (*cofidectl_proto.GetClusterResponse, error)

func (*GRPCServer) GetClusterByName added in v0.15.0 

func (s *GRPCServer) GetClusterByName(_ context.Context, req *cofidectl_proto.GetClusterByNameRequest) (*cofidectl_proto.GetClusterByNameResponse, error)

func (*GRPCServer) GetTrustZone 

func (s *GRPCServer) GetTrustZone(_ context.Context, req *cofidectl_proto.GetTrustZoneRequest) (*cofidectl_proto.GetTrustZoneResponse, error)

func (*GRPCServer) GetTrustZoneByName added in v0.15.0 

func (s *GRPCServer) GetTrustZoneByName(_ context.Context, req *cofidectl_proto.GetTrustZoneByNameRequest) (*cofidectl_proto.GetTrustZoneByNameResponse, error)

func (*GRPCServer) ListAPBindings added in v0.10.1 

func (s *GRPCServer) ListAPBindings(_ context.Context, req *cofidectl_proto.ListAPBindingsRequest) (*cofidectl_proto.ListAPBindingsResponse, error)

func (*GRPCServer) ListAttestationPolicies 

func (s *GRPCServer) ListAttestationPolicies(_ context.Context, req *cofidectl_proto.ListAttestationPoliciesRequest) (*cofidectl_proto.ListAttestationPoliciesResponse, error)

func (*GRPCServer) ListClusters added in v0.7.1 

func (s *GRPCServer) ListClusters(_ context.Context, req *cofidectl_proto.ListClustersRequest) (*cofidectl_proto.ListClustersResponse, error)

func (*GRPCServer) ListFederations 

func (s *GRPCServer) ListFederations(_ context.Context, req *cofidectl_proto.ListFederationsRequest) (*cofidectl_proto.ListFederationsResponse, error)

func (*GRPCServer) ListTrustZones 

func (s *GRPCServer) ListTrustZones(_ context.Context, req *cofidectl_proto.ListTrustZonesRequest) (*cofidectl_proto.ListTrustZonesResponse, error)

func (*GRPCServer) UpdateCluster added in v0.7.1 

func (s *GRPCServer) UpdateCluster(_ context.Context, req *cofidectl_proto.UpdateClusterRequest) (*cofidectl_proto.UpdateClusterResponse, error)

func (*GRPCServer) UpdateTrustZone 

func (s *GRPCServer) UpdateTrustZone(_ context.Context, req *cofidectl_proto.UpdateTrustZoneRequest) (*cofidectl_proto.UpdateTrustZoneResponse, error)

func (*GRPCServer) Validate 

func (s *GRPCServer) Validate(ctx context.Context, req *cofidectl_proto.ValidateRequest) (*cofidectl_proto.ValidateResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.