agentpb

package
v0.0.0-...-60373ff Latest Latest
Warning

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

 Go to latest Published: Nov 26, 2024 License: Apache-2.0 Imports: 9 Imported by: 2

Documentation

Index

Constants

View Source 
const (
	LogMetadataService_List_FullMethodName  = "/agentpb.LogMetadataService/List"
	LogMetadataService_Watch_FullMethodName = "/agentpb.LogMetadataService/Watch"
)

Variables

View Source 
var File_agent_proto protoreflect.FileDescriptor
View Source 
var LogMetadataService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "agentpb.LogMetadataService",
	HandlerType: (*LogMetadataServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "List",
			Handler:    _LogMetadataService_List_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Watch",
			Handler:       _LogMetadataService_Watch_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "agent.proto",
}

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

Functions

func RegisterLogMetadataServiceServer 

func RegisterLogMetadataServiceServer(s grpc.ServiceRegistrar, srv LogMetadataServiceServer)

Types

type LogMetadata 

type LogMetadata struct {
	Id       string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Spec     *LogMetadataSpec     `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	FileInfo *LogMetadataFileInfo `protobuf:"bytes,3,opt,name=fileInfo,proto3" json:"fileInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*LogMetadata) Descriptor deprecated 

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

Deprecated: Use LogMetadata.ProtoReflect.Descriptor instead.

func (*LogMetadata) GetFileInfo 

func (x *LogMetadata) GetFileInfo() *LogMetadataFileInfo

func (*LogMetadata) GetId 

func (x *LogMetadata) GetId() string

func (*LogMetadata) GetSpec 

func (x *LogMetadata) GetSpec() *LogMetadataSpec

func (*LogMetadata) ProtoMessage 

func (*LogMetadata) ProtoMessage()

func (*LogMetadata) ProtoReflect 

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

func (*LogMetadata) Reset 

func (x *LogMetadata) Reset()

func (*LogMetadata) String 

func (x *LogMetadata) String() string

type LogMetadataFileInfo 

type LogMetadataFileInfo struct {
	Size           int64                  `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	LastModifiedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=last_modified_at,json=lastModifiedAt,proto3" json:"last_modified_at,omitempty"`
	// contains filtered or unexported fields
}

func (*LogMetadataFileInfo) Descriptor deprecated 

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

Deprecated: Use LogMetadataFileInfo.ProtoReflect.Descriptor instead.

func (*LogMetadataFileInfo) GetLastModifiedAt 

func (x *LogMetadataFileInfo) GetLastModifiedAt() *timestamppb.Timestamp

func (*LogMetadataFileInfo) GetSize 

func (x *LogMetadataFileInfo) GetSize() int64

func (*LogMetadataFileInfo) ProtoMessage 

func (*LogMetadataFileInfo) ProtoMessage()

func (*LogMetadataFileInfo) ProtoReflect 

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

func (*LogMetadataFileInfo) Reset 

func (x *LogMetadataFileInfo) Reset()

func (*LogMetadataFileInfo) String 

func (x *LogMetadataFileInfo) String() string

type LogMetadataList 

type LogMetadataList struct {
	Items []*LogMetadata `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*LogMetadataList) Descriptor deprecated 

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

Deprecated: Use LogMetadataList.ProtoReflect.Descriptor instead.

func (*LogMetadataList) GetItems 

func (x *LogMetadataList) GetItems() []*LogMetadata

func (*LogMetadataList) ProtoMessage 

func (*LogMetadataList) ProtoMessage()

func (*LogMetadataList) ProtoReflect 

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

func (*LogMetadataList) Reset 

func (x *LogMetadataList) Reset()

func (*LogMetadataList) String 

func (x *LogMetadataList) String() string

type LogMetadataListRequest 

type LogMetadataListRequest struct {
	Namespaces []string `protobuf:"bytes,1,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	// contains filtered or unexported fields
}

func (*LogMetadataListRequest) Descriptor deprecated 

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

Deprecated: Use LogMetadataListRequest.ProtoReflect.Descriptor instead.

func (*LogMetadataListRequest) GetNamespaces 

func (x *LogMetadataListRequest) GetNamespaces() []string

func (*LogMetadataListRequest) ProtoMessage 

func (*LogMetadataListRequest) ProtoMessage()

func (*LogMetadataListRequest) ProtoReflect 

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

func (*LogMetadataListRequest) Reset 

func (x *LogMetadataListRequest) Reset()

func (*LogMetadataListRequest) String 

func (x *LogMetadataListRequest) String() string

type LogMetadataServiceClient 

type LogMetadataServiceClient interface {
	List(ctx context.Context, in *LogMetadataListRequest, opts ...grpc.CallOption) (*LogMetadataList, error)
	Watch(ctx context.Context, in *LogMetadataWatchRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[LogMetadataWatchEvent], error)
}

LogMetadataServiceClient is the client API for LogMetadataService 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 NewLogMetadataServiceClient 

func NewLogMetadataServiceClient(cc grpc.ClientConnInterface) LogMetadataServiceClient

type LogMetadataServiceServer 

type LogMetadataServiceServer interface {
	List(context.Context, *LogMetadataListRequest) (*LogMetadataList, error)
	Watch(*LogMetadataWatchRequest, grpc.ServerStreamingServer[LogMetadataWatchEvent]) error
	// contains filtered or unexported methods
}

LogMetadataServiceServer is the server API for LogMetadataService service. All implementations must embed UnimplementedLogMetadataServiceServer for forward compatibility.

type LogMetadataService_WatchClient 

type LogMetadataService_WatchClient = grpc.ServerStreamingClient[LogMetadataWatchEvent]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type LogMetadataService_WatchServer 

type LogMetadataService_WatchServer = grpc.ServerStreamingServer[LogMetadataWatchEvent]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type LogMetadataSpec 

type LogMetadataSpec struct {
	NodeName      string `protobuf:"bytes,1,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	Namespace     string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	PodName       string `protobuf:"bytes,3,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
	ContainerName string `protobuf:"bytes,4,opt,name=container_name,json=containerName,proto3" json:"container_name,omitempty"`
	ContainerId   string `protobuf:"bytes,5,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// contains filtered or unexported fields
}

func (*LogMetadataSpec) Descriptor deprecated 

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

Deprecated: Use LogMetadataSpec.ProtoReflect.Descriptor instead.

func (*LogMetadataSpec) GetContainerId 

func (x *LogMetadataSpec) GetContainerId() string

func (*LogMetadataSpec) GetContainerName 

func (x *LogMetadataSpec) GetContainerName() string

func (*LogMetadataSpec) GetNamespace 

func (x *LogMetadataSpec) GetNamespace() string

func (*LogMetadataSpec) GetNodeName 

func (x *LogMetadataSpec) GetNodeName() string

func (*LogMetadataSpec) GetPodName 

func (x *LogMetadataSpec) GetPodName() string

func (*LogMetadataSpec) ProtoMessage 

func (*LogMetadataSpec) ProtoMessage()

func (*LogMetadataSpec) ProtoReflect 

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

func (*LogMetadataSpec) Reset 

func (x *LogMetadataSpec) Reset()

func (*LogMetadataSpec) String 

func (x *LogMetadataSpec) String() string

type LogMetadataWatchEvent 

type LogMetadataWatchEvent struct {
	Type   string       `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Object *LogMetadata `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"`
	// contains filtered or unexported fields
}

func (*LogMetadataWatchEvent) Descriptor deprecated 

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

Deprecated: Use LogMetadataWatchEvent.ProtoReflect.Descriptor instead.

func (*LogMetadataWatchEvent) GetObject 

func (x *LogMetadataWatchEvent) GetObject() *LogMetadata

func (*LogMetadataWatchEvent) GetType 

func (x *LogMetadataWatchEvent) GetType() string

func (*LogMetadataWatchEvent) ProtoMessage 

func (*LogMetadataWatchEvent) ProtoMessage()

func (*LogMetadataWatchEvent) ProtoReflect 

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

func (*LogMetadataWatchEvent) Reset 

func (x *LogMetadataWatchEvent) Reset()

func (*LogMetadataWatchEvent) String 

func (x *LogMetadataWatchEvent) String() string

type LogMetadataWatchRequest 

type LogMetadataWatchRequest struct {
	Namespaces []string `protobuf:"bytes,1,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	// contains filtered or unexported fields
}

func (*LogMetadataWatchRequest) Descriptor deprecated 

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

Deprecated: Use LogMetadataWatchRequest.ProtoReflect.Descriptor instead.

func (*LogMetadataWatchRequest) GetNamespaces 

func (x *LogMetadataWatchRequest) GetNamespaces() []string

func (*LogMetadataWatchRequest) ProtoMessage 

func (*LogMetadataWatchRequest) ProtoMessage()

func (*LogMetadataWatchRequest) ProtoReflect 

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

func (*LogMetadataWatchRequest) Reset 

func (x *LogMetadataWatchRequest) Reset()

func (*LogMetadataWatchRequest) String 

func (x *LogMetadataWatchRequest) String() string

type UnimplementedLogMetadataServiceServer 

type UnimplementedLogMetadataServiceServer struct{}

UnimplementedLogMetadataServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedLogMetadataServiceServer) List 

func (UnimplementedLogMetadataServiceServer) List(context.Context, *LogMetadataListRequest) (*LogMetadataList, error)

func (UnimplementedLogMetadataServiceServer) Watch 

func (UnimplementedLogMetadataServiceServer) Watch(*LogMetadataWatchRequest, grpc.ServerStreamingServer[LogMetadataWatchEvent]) error

type UnsafeLogMetadataServiceServer 

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

UnsafeLogMetadataServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LogMetadataServiceServer 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.