v1alpha1

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Jan 4, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Diagnostic_Severity_name = map[int32]string{
		0: "SEVERITY_UNSPECIFIED",
		1: "SEVERITY_ERROR",
		2: "SEVERITY_WARNING",
	}
	Diagnostic_Severity_value = map[string]int32{
		"SEVERITY_UNSPECIFIED": 0,
		"SEVERITY_ERROR":       1,
		"SEVERITY_WARNING":     2,
	}
)

Enum value maps for Diagnostic_Severity.

View Source 
var CollectionManager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "manager.CollectionManager",
	HandlerType: (*CollectionManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PublishContent",
			Handler:    _CollectionManager_PublishContent_Handler,
		},
		{
			MethodName: "RetrieveContent",
			Handler:    _CollectionManager_RetrieveContent_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/services/collectionmanager/v1alpha1/manager.proto",
}

CollectionManager_ServiceDesc is the grpc.ServiceDesc for CollectionManager service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_api_services_collectionmanager_v1alpha1_manager_proto protoreflect.FileDescriptor

Functions

func RegisterCollectionManagerServer 

func RegisterCollectionManagerServer(s grpc.ServiceRegistrar, srv CollectionManagerServer)

Types

type AuthConfig 

type AuthConfig struct {
	Username      string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password      string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	ServerAddress string `protobuf:"bytes,3,opt,name=server_address,json=serverAddress,proto3" json:"server_address,omitempty"`
	AccessToken   string `protobuf:"bytes,4,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"`
	RefreshToken  string `protobuf:"bytes,5,opt,name=refresh_token,json=refreshToken,proto3" json:"refresh_token,omitempty"`
	// contains filtered or unexported fields
}

AuthConfig contains authorization information for connecting to a registry.

func (*AuthConfig) Descriptor deprecated 

func (*AuthConfig) Descriptor() ([]byte, []int)

Deprecated: Use AuthConfig.ProtoReflect.Descriptor instead.

func (*AuthConfig) GetAccessToken 

func (x *AuthConfig) GetAccessToken() string

func (*AuthConfig) GetPassword 

func (x *AuthConfig) GetPassword() string

func (*AuthConfig) GetRefreshToken 

func (x *AuthConfig) GetRefreshToken() string

func (*AuthConfig) GetServerAddress 

func (x *AuthConfig) GetServerAddress() string

func (*AuthConfig) GetUsername 

func (x *AuthConfig) GetUsername() string

func (*AuthConfig) ProtoMessage 

func (*AuthConfig) ProtoMessage()

func (*AuthConfig) ProtoReflect 

func (x *AuthConfig) ProtoReflect() protoreflect.Message

func (*AuthConfig) Reset 

func (x *AuthConfig) Reset()

func (*AuthConfig) String 

func (x *AuthConfig) String() string

type Collection 

type Collection struct {
	SchemaAddress     string   `protobuf:"bytes,1,opt,name=schema_address,json=schemaAddress,proto3" json:"schema_address,omitempty"`
	LinkedCollections []string `protobuf:"bytes,2,rep,name=linked_collections,json=linkedCollections,proto3" json:"linked_collections,omitempty"`
	Files             []*File  `protobuf:"bytes,3,rep,name=files,proto3" json:"files,omitempty"`
	// contains filtered or unexported fields
}

Collection contains configuration information for a collection.

func (*Collection) Descriptor deprecated 

func (*Collection) Descriptor() ([]byte, []int)

Deprecated: Use Collection.ProtoReflect.Descriptor instead.

func (*Collection) GetFiles 

func (x *Collection) GetFiles() []*File

func (*Collection) GetLinkedCollections 

func (x *Collection) GetLinkedCollections() []string

func (*Collection) GetSchemaAddress 

func (x *Collection) GetSchemaAddress() string

func (*Collection) ProtoMessage 

func (*Collection) ProtoMessage()

func (*Collection) ProtoReflect 

func (x *Collection) ProtoReflect() protoreflect.Message

func (*Collection) Reset 

func (x *Collection) Reset()

func (*Collection) String 

func (x *Collection) String() string

type CollectionManagerClient 

type CollectionManagerClient interface {
	// PublishContent publishes content based on the request.
	PublishContent(ctx context.Context, in *Publish_Request, opts ...grpc.CallOption) (*Publish_Response, error)
	// RetrieveContent retrieves content based on the request.
	RetrieveContent(ctx context.Context, in *Retrieve_Request, opts ...grpc.CallOption) (*Retrieve_Response, error)
}

CollectionManagerClient is the client API for CollectionManager service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewCollectionManagerClient 

func NewCollectionManagerClient(cc grpc.ClientConnInterface) CollectionManagerClient

type CollectionManagerServer 

type CollectionManagerServer interface {
	// PublishContent publishes content based on the request.
	PublishContent(context.Context, *Publish_Request) (*Publish_Response, error)
	// RetrieveContent retrieves content based on the request.
	RetrieveContent(context.Context, *Retrieve_Request) (*Retrieve_Response, error)
	// contains filtered or unexported methods
}

CollectionManagerServer is the server API for CollectionManager service. All implementations must embed UnimplementedCollectionManagerServer for forward compatibility

type Diagnostic 

type Diagnostic struct {
	Severity Diagnostic_Severity `protobuf:"varint,1,opt,name=severity,proto3,enum=manager.Diagnostic_Severity" json:"severity,omitempty"`
	Summary  string              `protobuf:"bytes,2,opt,name=summary,proto3" json:"summary,omitempty"`
	Detail   string              `protobuf:"bytes,3,opt,name=detail,proto3" json:"detail,omitempty"`
	// contains filtered or unexported fields
}

func (*Diagnostic) Descriptor deprecated 

func (*Diagnostic) Descriptor() ([]byte, []int)

Deprecated: Use Diagnostic.ProtoReflect.Descriptor instead.

func (*Diagnostic) GetDetail 

func (x *Diagnostic) GetDetail() string

func (*Diagnostic) GetSeverity 

func (x *Diagnostic) GetSeverity() Diagnostic_Severity

func (*Diagnostic) GetSummary 

func (x *Diagnostic) GetSummary() string

func (*Diagnostic) ProtoMessage 

func (*Diagnostic) ProtoMessage()

func (*Diagnostic) ProtoReflect 

func (x *Diagnostic) ProtoReflect() protoreflect.Message

func (*Diagnostic) Reset 

func (x *Diagnostic) Reset()

func (*Diagnostic) String 

func (x *Diagnostic) String() string

type Diagnostic_Severity 

type Diagnostic_Severity int32
const (
	Diagnostic_SEVERITY_UNSPECIFIED Diagnostic_Severity = 0
	Diagnostic_SEVERITY_ERROR       Diagnostic_Severity = 1
	Diagnostic_SEVERITY_WARNING     Diagnostic_Severity = 2
)

func (Diagnostic_Severity) Descriptor 

func (Diagnostic_Severity) Descriptor() protoreflect.EnumDescriptor

func (Diagnostic_Severity) Enum 

func (x Diagnostic_Severity) Enum() *Diagnostic_Severity

func (Diagnostic_Severity) EnumDescriptor deprecated 

func (Diagnostic_Severity) EnumDescriptor() ([]byte, []int)

Deprecated: Use Diagnostic_Severity.Descriptor instead.

func (Diagnostic_Severity) Number 

func (x Diagnostic_Severity) Number() protoreflect.EnumNumber

func (Diagnostic_Severity) String 

func (x Diagnostic_Severity) String() string

func (Diagnostic_Severity) Type 

func (Diagnostic_Severity) Type() protoreflect.EnumType

type File 

type File struct {
	File       string          `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	Attributes *_struct.Struct `protobuf:"bytes,2,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// contains filtered or unexported fields
}

File contains a regular expression for file name matching and associated attributes to apply the the descriptor for matching file.

func (*File) Descriptor deprecated 

func (*File) Descriptor() ([]byte, []int)

Deprecated: Use File.ProtoReflect.Descriptor instead.

func (*File) GetAttributes 

func (x *File) GetAttributes() *_struct.Struct

func (*File) GetFile 

func (x *File) GetFile() string

func (*File) ProtoMessage 

func (*File) ProtoMessage()

func (*File) ProtoReflect 

func (x *File) ProtoReflect() protoreflect.Message

func (*File) Reset 

func (x *File) Reset()

func (*File) String 

func (x *File) String() string

type Publish 

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

func (*Publish) Descriptor deprecated 

func (*Publish) Descriptor() ([]byte, []int)

Deprecated: Use Publish.ProtoReflect.Descriptor instead.

func (*Publish) ProtoMessage 

func (*Publish) ProtoMessage()

func (*Publish) ProtoReflect 

func (x *Publish) ProtoReflect() protoreflect.Message

func (*Publish) Reset 

func (x *Publish) Reset()

func (*Publish) String 

func (x *Publish) String() string

type Publish_Request 

type Publish_Request struct {
	Source      string      `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Destination string      `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty"`
	Collection  *Collection `protobuf:"bytes,3,opt,name=collection,proto3" json:"collection,omitempty"`
	Auth        *AuthConfig `protobuf:"bytes,4,opt,name=auth,proto3" json:"auth,omitempty"`
	// contains filtered or unexported fields
}

func (*Publish_Request) Descriptor deprecated 

func (*Publish_Request) Descriptor() ([]byte, []int)

Deprecated: Use Publish_Request.ProtoReflect.Descriptor instead.

func (*Publish_Request) GetAuth 

func (x *Publish_Request) GetAuth() *AuthConfig

func (*Publish_Request) GetCollection 

func (x *Publish_Request) GetCollection() *Collection

func (*Publish_Request) GetDestination 

func (x *Publish_Request) GetDestination() string

func (*Publish_Request) GetSource 

func (x *Publish_Request) GetSource() string

func (*Publish_Request) ProtoMessage 

func (*Publish_Request) ProtoMessage()

func (*Publish_Request) ProtoReflect 

func (x *Publish_Request) ProtoReflect() protoreflect.Message

func (*Publish_Request) Reset 

func (x *Publish_Request) Reset()

func (*Publish_Request) String 

func (x *Publish_Request) String() string

type Publish_Response 

type Publish_Response struct {
	Digest      string        `protobuf:"bytes,1,opt,name=digest,proto3" json:"digest,omitempty"`
	Diagnostics []*Diagnostic `protobuf:"bytes,2,rep,name=diagnostics,proto3" json:"diagnostics,omitempty"`
	// contains filtered or unexported fields
}

func (*Publish_Response) Descriptor deprecated 

func (*Publish_Response) Descriptor() ([]byte, []int)

Deprecated: Use Publish_Response.ProtoReflect.Descriptor instead.

func (*Publish_Response) GetDiagnostics 

func (x *Publish_Response) GetDiagnostics() []*Diagnostic

func (*Publish_Response) GetDigest 

func (x *Publish_Response) GetDigest() string

func (*Publish_Response) ProtoMessage 

func (*Publish_Response) ProtoMessage()

func (*Publish_Response) ProtoReflect 

func (x *Publish_Response) ProtoReflect() protoreflect.Message

func (*Publish_Response) Reset 

func (x *Publish_Response) Reset()

func (*Publish_Response) String 

func (x *Publish_Response) String() string

type Retrieve 

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

func (*Retrieve) Descriptor deprecated 

func (*Retrieve) Descriptor() ([]byte, []int)

Deprecated: Use Retrieve.ProtoReflect.Descriptor instead.

func (*Retrieve) ProtoMessage 

func (*Retrieve) ProtoMessage()

func (*Retrieve) ProtoReflect 

func (x *Retrieve) ProtoReflect() protoreflect.Message

func (*Retrieve) Reset 

func (x *Retrieve) Reset()

func (*Retrieve) String 

func (x *Retrieve) String() string

type Retrieve_Request 

type Retrieve_Request struct {
	Source      string          `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Destination string          `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty"`
	Filter      *_struct.Struct `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"`
	Auth        *AuthConfig     `protobuf:"bytes,4,opt,name=auth,proto3" json:"auth,omitempty"`
	// contains filtered or unexported fields
}

func (*Retrieve_Request) Descriptor deprecated 

func (*Retrieve_Request) Descriptor() ([]byte, []int)

Deprecated: Use Retrieve_Request.ProtoReflect.Descriptor instead.

func (*Retrieve_Request) GetAuth 

func (x *Retrieve_Request) GetAuth() *AuthConfig

func (*Retrieve_Request) GetDestination 

func (x *Retrieve_Request) GetDestination() string

func (*Retrieve_Request) GetFilter 

func (x *Retrieve_Request) GetFilter() *_struct.Struct

func (*Retrieve_Request) GetSource 

func (x *Retrieve_Request) GetSource() string

func (*Retrieve_Request) ProtoMessage 

func (*Retrieve_Request) ProtoMessage()

func (*Retrieve_Request) ProtoReflect 

func (x *Retrieve_Request) ProtoReflect() protoreflect.Message

func (*Retrieve_Request) Reset 

func (x *Retrieve_Request) Reset()

func (*Retrieve_Request) String 

func (x *Retrieve_Request) String() string

type Retrieve_Response 

type Retrieve_Response struct {
	Digests     []string      `protobuf:"bytes,1,rep,name=digests,proto3" json:"digests,omitempty"`
	Diagnostics []*Diagnostic `protobuf:"bytes,2,rep,name=diagnostics,proto3" json:"diagnostics,omitempty"`
	// contains filtered or unexported fields
}

func (*Retrieve_Response) Descriptor deprecated 

func (*Retrieve_Response) Descriptor() ([]byte, []int)

Deprecated: Use Retrieve_Response.ProtoReflect.Descriptor instead.

func (*Retrieve_Response) GetDiagnostics 

func (x *Retrieve_Response) GetDiagnostics() []*Diagnostic

func (*Retrieve_Response) GetDigests 

func (x *Retrieve_Response) GetDigests() []string

func (*Retrieve_Response) ProtoMessage 

func (*Retrieve_Response) ProtoMessage()

func (*Retrieve_Response) ProtoReflect 

func (x *Retrieve_Response) ProtoReflect() protoreflect.Message

func (*Retrieve_Response) Reset 

func (x *Retrieve_Response) Reset()

func (*Retrieve_Response) String 

func (x *Retrieve_Response) String() string

type UnimplementedCollectionManagerServer 

type UnimplementedCollectionManagerServer struct {
}

UnimplementedCollectionManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedCollectionManagerServer) PublishContent 

func (UnimplementedCollectionManagerServer) PublishContent(context.Context, *Publish_Request) (*Publish_Response, error)

func (UnimplementedCollectionManagerServer) RetrieveContent 

func (UnimplementedCollectionManagerServer) RetrieveContent(context.Context, *Retrieve_Request) (*Retrieve_Response, error)

type UnsafeCollectionManagerServer 

type UnsafeCollectionManagerServer interface {
	// contains filtered or unexported methods
}

UnsafeCollectionManagerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CollectionManagerServer will result in compilation errors.

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.