collectsub

package
v0.0.1-alpha.1 Latest Latest
Warning

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

 Go to latest Published: May 19, 2023 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	CollectDataType_name = map[int32]string{
		0: "DATATYPE_UNKNOWN",
		1: "DATATYPE_GIT",
		2: "DATATYPE_OCI",
		3: "DATATYPE_PURL",
		4: "DATATYPE_GITHUB_RELEASE",
	}
	CollectDataType_value = map[string]int32{
		"DATATYPE_UNKNOWN":        0,
		"DATATYPE_GIT":            1,
		"DATATYPE_OCI":            2,
		"DATATYPE_PURL":           3,
		"DATATYPE_GITHUB_RELEASE": 4,
	}
)

Enum value maps for CollectDataType.

View Source 
var ColectSubscriberService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "guacsec.guac.collect_subscriber.schema.ColectSubscriberService",
	HandlerType: (*ColectSubscriberServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AddCollectEntries",
			Handler:    _ColectSubscriberService_AddCollectEntries_Handler,
		},
		{
			MethodName: "GetCollectEntries",
			Handler:    _ColectSubscriberService_GetCollectEntries_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/collectsub/collectsub/collectsub.proto",
}

ColectSubscriberService_ServiceDesc is the grpc.ServiceDesc for ColectSubscriberService 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_pkg_collectsub_collectsub_collectsub_proto protoreflect.FileDescriptor

Functions

func RegisterColectSubscriberServiceServer 

func RegisterColectSubscriberServiceServer(s grpc.ServiceRegistrar, srv ColectSubscriberServiceServer)

Types

type AddCollectEntriesRequest 

type AddCollectEntriesRequest struct {
	Entries []*CollectEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

rpc AddCollectEntry

func (*AddCollectEntriesRequest) Descriptor deprecated 

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

Deprecated: Use AddCollectEntriesRequest.ProtoReflect.Descriptor instead.

func (*AddCollectEntriesRequest) GetEntries 

func (x *AddCollectEntriesRequest) GetEntries() []*CollectEntry

func (*AddCollectEntriesRequest) ProtoMessage 

func (*AddCollectEntriesRequest) ProtoMessage()

func (*AddCollectEntriesRequest) ProtoReflect 

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

func (*AddCollectEntriesRequest) Reset 

func (x *AddCollectEntriesRequest) Reset()

func (*AddCollectEntriesRequest) String 

func (x *AddCollectEntriesRequest) String() string

type AddCollectEntriesResponse 

type AddCollectEntriesResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*AddCollectEntriesResponse) Descriptor deprecated 

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

Deprecated: Use AddCollectEntriesResponse.ProtoReflect.Descriptor instead.

func (*AddCollectEntriesResponse) GetSuccess 

func (x *AddCollectEntriesResponse) GetSuccess() bool

func (*AddCollectEntriesResponse) ProtoMessage 

func (*AddCollectEntriesResponse) ProtoMessage()

func (*AddCollectEntriesResponse) ProtoReflect 

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

func (*AddCollectEntriesResponse) Reset 

func (x *AddCollectEntriesResponse) Reset()

func (*AddCollectEntriesResponse) String 

func (x *AddCollectEntriesResponse) String() string

type ColectSubscriberServiceClient 

type ColectSubscriberServiceClient interface {
	AddCollectEntries(ctx context.Context, in *AddCollectEntriesRequest, opts ...grpc.CallOption) (*AddCollectEntriesResponse, error)
	GetCollectEntries(ctx context.Context, in *GetCollectEntriesRequest, opts ...grpc.CallOption) (*GetCollectEntriesResponse, error)
}

ColectSubscriberServiceClient is the client API for ColectSubscriberService 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 NewColectSubscriberServiceClient 

func NewColectSubscriberServiceClient(cc grpc.ClientConnInterface) ColectSubscriberServiceClient

type ColectSubscriberServiceServer 

type ColectSubscriberServiceServer interface {
	AddCollectEntries(context.Context, *AddCollectEntriesRequest) (*AddCollectEntriesResponse, error)
	GetCollectEntries(context.Context, *GetCollectEntriesRequest) (*GetCollectEntriesResponse, error)
	// contains filtered or unexported methods
}

ColectSubscriberServiceServer is the server API for ColectSubscriberService service. All implementations must embed UnimplementedColectSubscriberServiceServer for forward compatibility

type CollectDataType 

type CollectDataType int32
const (
	CollectDataType_DATATYPE_UNKNOWN        CollectDataType = 0
	CollectDataType_DATATYPE_GIT            CollectDataType = 1
	CollectDataType_DATATYPE_OCI            CollectDataType = 2
	CollectDataType_DATATYPE_PURL           CollectDataType = 3
	CollectDataType_DATATYPE_GITHUB_RELEASE CollectDataType = 4
)

func (CollectDataType) Descriptor 

func (CollectDataType) Descriptor() protoreflect.EnumDescriptor

func (CollectDataType) Enum 

func (x CollectDataType) Enum() *CollectDataType

func (CollectDataType) EnumDescriptor deprecated 

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

Deprecated: Use CollectDataType.Descriptor instead.

func (CollectDataType) Number 

func (x CollectDataType) Number() protoreflect.EnumNumber

func (CollectDataType) String 

func (x CollectDataType) String() string

func (CollectDataType) Type 

func (CollectDataType) Type() protoreflect.EnumType

type CollectEntry 

type CollectEntry struct {
	Type  CollectDataType `protobuf:"varint,1,opt,name=type,proto3,enum=guacsec.guac.collect_subscriber.schema.CollectDataType" json:"type,omitempty"`
	Value string          `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Generic types

func (*CollectEntry) Descriptor deprecated 

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

Deprecated: Use CollectEntry.ProtoReflect.Descriptor instead.

func (*CollectEntry) GetType 

func (x *CollectEntry) GetType() CollectDataType

func (*CollectEntry) GetValue 

func (x *CollectEntry) GetValue() string

func (*CollectEntry) ProtoMessage 

func (*CollectEntry) ProtoMessage()

func (*CollectEntry) ProtoReflect 

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

func (*CollectEntry) Reset 

func (x *CollectEntry) Reset()

func (*CollectEntry) String 

func (x *CollectEntry) String() string

type CollectEntryFilter 

type CollectEntryFilter struct {
	Type CollectDataType `protobuf:"varint,1,opt,name=type,proto3,enum=guacsec.guac.collect_subscriber.schema.CollectDataType" json:"type,omitempty"`
	Glob string          `protobuf:"bytes,2,opt,name=glob,proto3" json:"glob,omitempty"`
	// contains filtered or unexported fields
}

rpc GetCollectEntries

func (*CollectEntryFilter) Descriptor deprecated 

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

Deprecated: Use CollectEntryFilter.ProtoReflect.Descriptor instead.

func (*CollectEntryFilter) GetGlob 

func (x *CollectEntryFilter) GetGlob() string

func (*CollectEntryFilter) GetType 

func (x *CollectEntryFilter) GetType() CollectDataType

func (*CollectEntryFilter) ProtoMessage 

func (*CollectEntryFilter) ProtoMessage()

func (*CollectEntryFilter) ProtoReflect 

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

func (*CollectEntryFilter) Reset 

func (x *CollectEntryFilter) Reset()

func (*CollectEntryFilter) String 

func (x *CollectEntryFilter) String() string

type GetCollectEntriesRequest 

type GetCollectEntriesRequest struct {
	Filters []*CollectEntryFilter `protobuf:"bytes,1,rep,name=filters,proto3" json:"filters,omitempty"`
	// since_time in unix epoch
	SinceTime int64 `protobuf:"varint,2,opt,name=since_time,json=sinceTime,proto3" json:"since_time,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCollectEntriesRequest) Descriptor deprecated 

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

Deprecated: Use GetCollectEntriesRequest.ProtoReflect.Descriptor instead.

func (*GetCollectEntriesRequest) GetFilters 

func (x *GetCollectEntriesRequest) GetFilters() []*CollectEntryFilter

func (*GetCollectEntriesRequest) GetSinceTime 

func (x *GetCollectEntriesRequest) GetSinceTime() int64

func (*GetCollectEntriesRequest) ProtoMessage 

func (*GetCollectEntriesRequest) ProtoMessage()

func (*GetCollectEntriesRequest) ProtoReflect 

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

func (*GetCollectEntriesRequest) Reset 

func (x *GetCollectEntriesRequest) Reset()

func (*GetCollectEntriesRequest) String 

func (x *GetCollectEntriesRequest) String() string

type GetCollectEntriesResponse 

type GetCollectEntriesResponse struct {
	Entries []*CollectEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCollectEntriesResponse) Descriptor deprecated 

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

Deprecated: Use GetCollectEntriesResponse.ProtoReflect.Descriptor instead.

func (*GetCollectEntriesResponse) GetEntries 

func (x *GetCollectEntriesResponse) GetEntries() []*CollectEntry

func (*GetCollectEntriesResponse) ProtoMessage 

func (*GetCollectEntriesResponse) ProtoMessage()

func (*GetCollectEntriesResponse) ProtoReflect 

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

func (*GetCollectEntriesResponse) Reset 

func (x *GetCollectEntriesResponse) Reset()

func (*GetCollectEntriesResponse) String 

func (x *GetCollectEntriesResponse) String() string

type UnimplementedColectSubscriberServiceServer 

type UnimplementedColectSubscriberServiceServer struct {
}

UnimplementedColectSubscriberServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedColectSubscriberServiceServer) AddCollectEntries 

func (UnimplementedColectSubscriberServiceServer) AddCollectEntries(context.Context, *AddCollectEntriesRequest) (*AddCollectEntriesResponse, error)

func (UnimplementedColectSubscriberServiceServer) GetCollectEntries 

func (UnimplementedColectSubscriberServiceServer) GetCollectEntries(context.Context, *GetCollectEntriesRequest) (*GetCollectEntriesResponse, error)

type UnsafeColectSubscriberServiceServer 

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

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

Source Files

View all Source files

Directories

Path Synopsis
input defines collectsub structs that can be used for human/application inputs that do not necessarily find it convenient to use protobuf (e.g.
 input defines collectsub structs that can be used for human/application inputs that do not necessarily find it convenient to use protobuf (e.g.

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.