datasource

package
v0.10.2 Latest Latest
Warning

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

 Go to latest Published: Mar 24, 2025 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(*trust_zone_proto.TrustZone) (*trust_zone_proto.TrustZone, error)
	GetTrustZone(string) (*trust_zone_proto.TrustZone, error)
	ListTrustZones() ([]*trust_zone_proto.TrustZone, error)
	UpdateTrustZone(*trust_zone_proto.TrustZone) (*trust_zone_proto.TrustZone, error)

	AddCluster(*clusterpb.Cluster) (*clusterpb.Cluster, error)
	GetCluster(string, string) (*clusterpb.Cluster, error)
	ListClusters(string) ([]*clusterpb.Cluster, error)
	UpdateCluster(*clusterpb.Cluster) (*clusterpb.Cluster, error)

	AddAttestationPolicy(*attestation_policy_proto.AttestationPolicy) (*attestation_policy_proto.AttestationPolicy, error)
	GetAttestationPolicy(string) (*attestation_policy_proto.AttestationPolicy, error)
	ListAttestationPolicies() ([]*attestation_policy_proto.AttestationPolicy, error)

	AddAPBinding(*ap_binding_proto.APBinding) (*ap_binding_proto.APBinding, error)
	DestroyAPBinding(*ap_binding_proto.APBinding) error
	ListAPBindings(*datasourcepb.ListAPBindingsRequest_Filter) ([]*ap_binding_proto.APBinding, error)

	AddFederation(*federation_proto.Federation) (*federation_proto.Federation, error)
	ListFederations() ([]*federation_proto.Federation, error)
	ListFederationsByTrustZone(string) ([]*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(binding *ap_binding_proto.APBinding) error

func (*DataSourcePluginClientGRPC) GetAttestationPolicy 

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

func (*DataSourcePluginClientGRPC) GetCluster added in v0.7.1 

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

func (*DataSourcePluginClientGRPC) GetTrustZone 

func (c *DataSourcePluginClientGRPC) GetTrustZone(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(trustZone string) ([]*clusterpb.Cluster, error)

func (*DataSourcePluginClientGRPC) ListFederations 

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

func (*DataSourcePluginClientGRPC) ListFederationsByTrustZone 

func (c *DataSourcePluginClientGRPC) ListFederationsByTrustZone(trustZoneName string) ([]*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) GetAttestationPolicy 

func (s *GRPCServer) GetAttestationPolicy(_ context.Context, req *cofidectl_proto.GetAttestationPolicyRequest) (*cofidectl_proto.GetAttestationPolicyResponse, 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) GetTrustZone 

func (s *GRPCServer) GetTrustZone(_ context.Context, req *cofidectl_proto.GetTrustZoneRequest) (*cofidectl_proto.GetTrustZoneResponse, 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) ListFederationsByTrustZone 

func (s *GRPCServer) ListFederationsByTrustZone(_ context.Context, req *cofidectl_proto.ListFederationsByTrustZoneRequest) (*cofidectl_proto.ListFederationsByTrustZoneResponse, 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.