Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

collection

package

Go to main page

Versions in this module

v0

v0.2.0

Aug 12, 2022

Changes in this version

+ var ErrMissingRawConfiguration = errors.New("service configuration is missing")

+ var ErrMissingServiceConfigurationServiceID = errors.New("serviceID in service configuration is invalid")

type AuthenticationSecurityConfig

+ ApiEndpoint string

+ ClientId string

+ ClientSecret string

+ Scopes string

+ func (x *AuthenticationSecurityConfig) GetApiEndpoint() string

+ func (x *AuthenticationSecurityConfig) GetClientId() string

+ func (x *AuthenticationSecurityConfig) GetClientSecret() string

+ func (x *AuthenticationSecurityConfig) GetScopes() string

v0.1.0

Jul 21, 2022

Changes in this version

+ var Collection_ServiceDesc = grpc.ServiceDesc

+ var ErrConversionProtobufToAuthOptions = errors.New("could not convert protobuf value to openstack.authOptions")

+ var ErrConversionProtobufToByteArray = errors.New("could not convert protobuf value to byte array")

+ var ErrInvalidCollectionModule = errors.New("collection module is invalid")

+ var ErrInvalidKubernetesServiceConfiguration = errors.New("kubernetes service configuration is invalid")

+ var ErrInvalidOpenstackServiceConfiguration = errors.New("could not store openstack service configuration")

+ var ErrInvalidRemoteIntegrityRawConfiguration = errors.New("no remote integrity raw configuration")

+ var ErrInvalidServiceID = errors.New("serviceID is invalid")

+ var ErrInvalidWorkloadConfigurationRawConfiguration = errors.New("no workload raw configuration")

+ var ErrKubernetesClientset = errors.New("could not get kubernetes clientset")

+ var ErrMissingEvalManager = errors.New("evaluation manager URL is missing")

+ var ErrMissingServiceConfiguration = errors.New("service configuration is missing")

+ var ErrMissingServiceConfigurationWorkloadServiceIDM = errors.New("serviceID in service configuration is invalid")

+ var ErrMissingServiceID = errors.New("serviceID is missing")

+ var ErrRequestServiceID = errors.New("serviceID in request is invalid")

+ var File_api_collection_collection_proto protoreflect.FileDescriptor

+ var ServiceConfiguration_CollectionModule_name = map[int32]string

+ var ServiceConfiguration_CollectionModule_value = map[string]int32

+ var ServiceConfiguration_Type_name = map[int32]string

+ var ServiceConfiguration_Type_value = map[string]int32

+ func IsValidUUID(u string) bool

+ func RegisterCollectionServer(s grpc.ServiceRegistrar, srv CollectionServer)

+ type AuthenticationSecurityConfig struct

+ Issuer string

+ MetadataDocument string

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

+ func (*AuthenticationSecurityConfig) ProtoMessage()

+ func (x *AuthenticationSecurityConfig) GetIssuer() string

+ func (x *AuthenticationSecurityConfig) GetMetadataDocument() string

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

+ func (x *AuthenticationSecurityConfig) Reset()

+ func (x *AuthenticationSecurityConfig) String() string

+ type CollectionClient interface

+ StartCollecting func(ctx context.Context, in *StartCollectingRequest, opts ...grpc.CallOption) (*StartCollectingResponse, error)

+ StartCollectingStream func(ctx context.Context, opts ...grpc.CallOption) (Collection_StartCollectingStreamClient, error)

+ StopCollecting func(ctx context.Context, in *StopCollectingRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func NewCollectionClient(cc grpc.ClientConnInterface) CollectionClient

+ type CollectionModule struct

+ Address string

+ Description string

+ Id string

+ MetricId string

+ Name string

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

+ func (*CollectionModule) ProtoMessage()

+ func (x *CollectionModule) GetAddress() string

+ func (x *CollectionModule) GetDescription() string

+ func (x *CollectionModule) GetId() string

+ func (x *CollectionModule) GetMetricId() string

+ func (x *CollectionModule) GetName() string

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

+ func (x *CollectionModule) Reset()

+ func (x *CollectionModule) String() string

+ type CollectionServer interface

+ StartCollecting func(context.Context, *StartCollectingRequest) (*StartCollectingResponse, error)

+ StartCollectingStream func(Collection_StartCollectingStreamServer) error

+ StopCollecting func(context.Context, *StopCollectingRequest) (*emptypb.Empty, error)

+ type Collection_StartCollectingStreamClient interface

+ CloseAndRecv func() (*emptypb.Empty, error)

+ Send func(*StartCollectingRequest) error

+ type Collection_StartCollectingStreamServer interface

+ Recv func() (*StartCollectingRequest, error)

+ SendAndClose func(*emptypb.Empty) error

+ type CommunicationSecurityConfig struct

+ Endpoint string

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

+ func (*CommunicationSecurityConfig) ProtoMessage()

+ func (x *CommunicationSecurityConfig) GetEndpoint() string

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

+ func (x *CommunicationSecurityConfig) Reset()

+ func (x *CommunicationSecurityConfig) String() string

+ type ConfigType interface

+ type RemoteIntegrityConfig struct

+ Certificate string

+ Target string

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

+ func (*RemoteIntegrityConfig) ProtoMessage()

+ func (x *RemoteIntegrityConfig) GetCertificate() string

+ func (x *RemoteIntegrityConfig) GetTarget() string

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

+ func (x *RemoteIntegrityConfig) Reset()

+ func (x *RemoteIntegrityConfig) String() string

+ type ServiceConfiguration struct

+ CollectionModule ServiceConfiguration_CollectionModule

+ RawConfiguration isServiceConfiguration_RawConfiguration

+ ServiceId string

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

+ func (*ServiceConfiguration) ProtoMessage()

+ func (m *ServiceConfiguration) GetRawConfiguration() isServiceConfiguration_RawConfiguration

+ func (x *ServiceConfiguration) GetAuthenticationSecurityConfig() *AuthenticationSecurityConfig

+ func (x *ServiceConfiguration) GetCollectionModule() ServiceConfiguration_CollectionModule

+ func (x *ServiceConfiguration) GetCommunicationSecurityConfig() *CommunicationSecurityConfig

+ func (x *ServiceConfiguration) GetRemoteIntegrityConfig() *RemoteIntegrityConfig

+ func (x *ServiceConfiguration) GetServiceId() string

+ func (x *ServiceConfiguration) GetWorkloadSecurityConfig() *WorkloadSecurityConfig

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

+ func (x *ServiceConfiguration) Reset()

+ func (x *ServiceConfiguration) String() string

+ type ServiceConfiguration_AuthenticationSecurityConfig struct

+ AuthenticationSecurityConfig *AuthenticationSecurityConfig

+ type ServiceConfiguration_CollectionModule int32

+ const ServiceConfiguration_AUTHENTICATION_SECURITY

+ const ServiceConfiguration_COLLECTION_MODULE_UNKNOWN

+ const ServiceConfiguration_COMMUNICATION_SECURITY

+ const ServiceConfiguration_PUBLIC_REGISTRY

+ const ServiceConfiguration_REMOTE_INTEGRITY

+ const ServiceConfiguration_WORKLOAD_CONFIGURATION

+ func (ServiceConfiguration_CollectionModule) Descriptor() protoreflect.EnumDescriptor

+ func (ServiceConfiguration_CollectionModule) EnumDescriptor() ([]byte, []int)

+ func (ServiceConfiguration_CollectionModule) Type() protoreflect.EnumType

+ func (x ServiceConfiguration_CollectionModule) Enum() *ServiceConfiguration_CollectionModule

+ func (x ServiceConfiguration_CollectionModule) Number() protoreflect.EnumNumber

+ func (x ServiceConfiguration_CollectionModule) String() string

+ type ServiceConfiguration_CommunicationSecurityConfig struct

+ CommunicationSecurityConfig *CommunicationSecurityConfig

+ type ServiceConfiguration_RemoteIntegrityConfig struct

+ RemoteIntegrityConfig *RemoteIntegrityConfig

+ type ServiceConfiguration_Type int32

+ const ServiceConfiguration_KUBERNETES

+ const ServiceConfiguration_OPENID

+ const ServiceConfiguration_OPENSTACK

+ const ServiceConfiguration_TYPE_UNKNOWN

+ func (ServiceConfiguration_Type) Descriptor() protoreflect.EnumDescriptor

+ func (ServiceConfiguration_Type) EnumDescriptor() ([]byte, []int)

+ func (ServiceConfiguration_Type) Type() protoreflect.EnumType

+ func (x ServiceConfiguration_Type) Enum() *ServiceConfiguration_Type

+ func (x ServiceConfiguration_Type) Number() protoreflect.EnumNumber

+ func (x ServiceConfiguration_Type) String() string

+ type ServiceConfiguration_WorkloadSecurityConfig struct

+ WorkloadSecurityConfig *WorkloadSecurityConfig

+ type StartCollectingRequest struct

+ Configuration *ServiceConfiguration

+ EvalManager string

+ MetricId string

+ ServiceId string

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

+ func (*StartCollectingRequest) ProtoMessage()

+ func (req *StartCollectingRequest) KubeConfig() (config []byte, err error)

+ func (req *StartCollectingRequest) Validate() error

+ func (x *StartCollectingRequest) GetConfiguration() *ServiceConfiguration

+ func (x *StartCollectingRequest) GetEvalManager() string

+ func (x *StartCollectingRequest) GetMetricId() string

+ func (x *StartCollectingRequest) GetServiceId() string

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

+ func (x *StartCollectingRequest) Reset()

+ func (x *StartCollectingRequest) String() string

+ type StartCollectingResponse struct

+ Id string

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

+ func (*StartCollectingResponse) ProtoMessage()

+ func (x *StartCollectingResponse) GetId() string

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

+ func (x *StartCollectingResponse) Reset()

+ func (x *StartCollectingResponse) String() string

+ type StopCollectingRequest struct

+ Id string

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

+ func (*StopCollectingRequest) ProtoMessage()

+ func (x *StopCollectingRequest) GetId() string

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

+ func (x *StopCollectingRequest) Reset()

+ func (x *StopCollectingRequest) String() string

+ type UnimplementedCollectionServer struct

+ func (UnimplementedCollectionServer) StartCollecting(context.Context, *StartCollectingRequest) (*StartCollectingResponse, error)

+ func (UnimplementedCollectionServer) StartCollectingStream(Collection_StartCollectingStreamServer) error

+ func (UnimplementedCollectionServer) StopCollecting(context.Context, *StopCollectingRequest) (*emptypb.Empty, error)

+ type UnsafeCollectionServer interface

+ type WorkloadSecurityConfig struct

+ Kubernetes *structpb.Value

+ Openstack *structpb.Value

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

+ func (*WorkloadSecurityConfig) ProtoMessage()

+ func (x *WorkloadSecurityConfig) GetKubernetes() *structpb.Value

+ func (x *WorkloadSecurityConfig) GetOpenstack() *structpb.Value

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

+ func (x *WorkloadSecurityConfig) Reset()

+ func (x *WorkloadSecurityConfig) String() string