processes

package
v0.0.0-...-28787c5 Latest Latest
Warning

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

 Go to latest Published: Mar 26, 2023 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Overview

Package processes is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	SortOrderEnums_name = map[int32]string{
		0: "ASC",
		1: "DESC",
	}
	SortOrderEnums_value = map[string]int32{
		"ASC":  0,
		"DESC": 1,
	}
)

Enum value maps for SortOrderEnums.

View Source 
var (
	QueryType_name = map[int32]string{
		0: "Search",
		1: "AdvanceSearch",
	}
	QueryType_value = map[string]int32{
		"Search":        0,
		"AdvanceSearch": 1,
	}
)

Enum value maps for QueryType.

View Source 
var File_api_proto_processDetails_proto protoreflect.FileDescriptor

Functions

func RegisterProcessDetailsServiceHandler 

func RegisterProcessDetailsServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterProcessDetailsServiceHandler registers the http handlers for service ProcessDetailsService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterProcessDetailsServiceHandlerClient 

func RegisterProcessDetailsServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ProcessDetailsServiceClient) error

RegisterProcessDetailsServiceHandlerClient registers the http handlers for service ProcessDetailsService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ProcessDetailsServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ProcessDetailsServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ProcessDetailsServiceClient" to call the correct interceptors.

func RegisterProcessDetailsServiceHandlerFromEndpoint 

func RegisterProcessDetailsServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterProcessDetailsServiceHandlerFromEndpoint is same as RegisterProcessDetailsServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterProcessDetailsServiceHandlerServer 

func RegisterProcessDetailsServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ProcessDetailsServiceServer) error

RegisterProcessDetailsServiceHandlerServer registers the http handlers for service ProcessDetailsService to "mux". UnaryRPC :call ProcessDetailsServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterProcessDetailsServiceHandlerFromEndpoint instead.

func RegisterProcessDetailsServiceServer 

func RegisterProcessDetailsServiceServer(s *grpc.Server, srv ProcessDetailsServiceServer)

Types

type FilterValue 

type FilterValue struct {
	Key    string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Values []string `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*FilterValue) Descriptor deprecated 

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

Deprecated: Use FilterValue.ProtoReflect.Descriptor instead.

func (*FilterValue) GetKey 

func (x *FilterValue) GetKey() string

func (*FilterValue) GetValues 

func (x *FilterValue) GetValues() []string

func (*FilterValue) ProtoMessage 

func (*FilterValue) ProtoMessage()

func (*FilterValue) ProtoReflect 

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

func (*FilterValue) Reset 

func (x *FilterValue) Reset()

func (*FilterValue) String 

func (x *FilterValue) String() string

type Process 

type Process struct {
	ProcID          string `protobuf:"bytes,1,opt,name=procID,proto3" json:"procID,omitempty"`
	LastSeen        int64  `protobuf:"varint,2,opt,name=lastSeen,proto3" json:"lastSeen,omitempty"`
	FirstSeen       int64  `protobuf:"varint,3,opt,name=firstSeen,proto3" json:"firstSeen,omitempty"`
	Namespace       string `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ApplicationName string `protobuf:"bytes,5,opt,name=applicationName,proto3" json:"applicationName,omitempty"`
	Tags            string `protobuf:"bytes,6,opt,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*Process) Descriptor deprecated 

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

Deprecated: Use Process.ProtoReflect.Descriptor instead.

func (*Process) GetApplicationName 

func (x *Process) GetApplicationName() string

func (*Process) GetFirstSeen 

func (x *Process) GetFirstSeen() int64

func (*Process) GetLastSeen 

func (x *Process) GetLastSeen() int64

func (*Process) GetNamespace 

func (x *Process) GetNamespace() string

func (*Process) GetProcID 

func (x *Process) GetProcID() string

func (*Process) GetTags 

func (x *Process) GetTags() string

func (*Process) ProtoMessage 

func (*Process) ProtoMessage()

func (*Process) ProtoReflect 

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

func (*Process) Reset 

func (x *Process) Reset()

func (*Process) String 

func (x *Process) String() string

type ProcessDetailsServiceClient 

type ProcessDetailsServiceClient interface {
	GetProcesses(ctx context.Context, in *ProcessesRequest, opts ...grpc.CallOption) (*ProcessesResponse, error)
	GetProcessQuery(ctx context.Context, in *ProcessesQueryRequest, opts ...grpc.CallOption) (*ProcessQueryResponse, error)
}

ProcessDetailsServiceClient is the client API for ProcessDetailsService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewProcessDetailsServiceClient 

func NewProcessDetailsServiceClient(cc grpc.ClientConnInterface) ProcessDetailsServiceClient

type ProcessDetailsServiceServer 

type ProcessDetailsServiceServer interface {
	GetProcesses(context.Context, *ProcessesRequest) (*ProcessesResponse, error)
	GetProcessQuery(context.Context, *ProcessesQueryRequest) (*ProcessQueryResponse, error)
}

ProcessDetailsServiceServer is the server API for ProcessDetailsService service.

type ProcessQueryResponse 

type ProcessQueryResponse struct {
	Offset     uint64     `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Count      uint64     `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	TotalCount uint64     `protobuf:"varint,3,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"`
	Processes  []*Process `protobuf:"bytes,4,rep,name=processes,proto3" json:"processes,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessQueryResponse) Descriptor deprecated 

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

Deprecated: Use ProcessQueryResponse.ProtoReflect.Descriptor instead.

func (*ProcessQueryResponse) GetCount 

func (x *ProcessQueryResponse) GetCount() uint64

func (*ProcessQueryResponse) GetOffset 

func (x *ProcessQueryResponse) GetOffset() uint64

func (*ProcessQueryResponse) GetProcesses 

func (x *ProcessQueryResponse) GetProcesses() []*Process

func (*ProcessQueryResponse) GetTotalCount 

func (x *ProcessQueryResponse) GetTotalCount() uint64

func (*ProcessQueryResponse) ProtoMessage 

func (*ProcessQueryResponse) ProtoMessage()

func (*ProcessQueryResponse) ProtoReflect 

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

func (*ProcessQueryResponse) Reset 

func (x *ProcessQueryResponse) Reset()

func (*ProcessQueryResponse) String 

func (x *ProcessQueryResponse) String() string

type ProcessesQueryRequest 

type ProcessesQueryRequest struct {
	Namespace       string         `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ApplicationName string         `protobuf:"bytes,2,opt,name=applicationName,proto3" json:"applicationName,omitempty"`
	Page            uint64         `protobuf:"varint,3,opt,name=page,proto3" json:"page,omitempty"`
	Size            uint64         `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	Sort            *SortOrder     `protobuf:"bytes,5,opt,name=sort,proto3" json:"sort,omitempty"`
	Search          string         `protobuf:"bytes,6,opt,name=search,proto3" json:"search,omitempty"`
	TimestampStart  uint64         `protobuf:"varint,7,opt,name=timestampStart,proto3" json:"timestampStart,omitempty"`
	TimestampEnd    uint64         `protobuf:"varint,8,opt,name=timestampEnd,proto3" json:"timestampEnd,omitempty"`
	Filters         []*FilterValue `protobuf:"bytes,9,rep,name=filters,proto3" json:"filters,omitempty"`
	QType           QueryType      `protobuf:"varint,10,opt,name=qType,proto3,enum=processdetails.QueryType" json:"qType,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessesQueryRequest) Descriptor deprecated 

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

Deprecated: Use ProcessesQueryRequest.ProtoReflect.Descriptor instead.

func (*ProcessesQueryRequest) GetApplicationName 

func (x *ProcessesQueryRequest) GetApplicationName() string

func (*ProcessesQueryRequest) GetFilters 

func (x *ProcessesQueryRequest) GetFilters() []*FilterValue

func (*ProcessesQueryRequest) GetNamespace 

func (x *ProcessesQueryRequest) GetNamespace() string

func (*ProcessesQueryRequest) GetPage 

func (x *ProcessesQueryRequest) GetPage() uint64

func (*ProcessesQueryRequest) GetQType 

func (x *ProcessesQueryRequest) GetQType() QueryType

func (*ProcessesQueryRequest) GetSearch 

func (x *ProcessesQueryRequest) GetSearch() string

func (*ProcessesQueryRequest) GetSize 

func (x *ProcessesQueryRequest) GetSize() uint64

func (*ProcessesQueryRequest) GetSort 

func (x *ProcessesQueryRequest) GetSort() *SortOrder

func (*ProcessesQueryRequest) GetTimestampEnd 

func (x *ProcessesQueryRequest) GetTimestampEnd() uint64

func (*ProcessesQueryRequest) GetTimestampStart 

func (x *ProcessesQueryRequest) GetTimestampStart() uint64

func (*ProcessesQueryRequest) ProtoMessage 

func (*ProcessesQueryRequest) ProtoMessage()

func (*ProcessesQueryRequest) ProtoReflect 

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

func (*ProcessesQueryRequest) Reset 

func (x *ProcessesQueryRequest) Reset()

func (*ProcessesQueryRequest) String 

func (x *ProcessesQueryRequest) String() string

type ProcessesRequest 

type ProcessesRequest struct {
	Namespace       string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ApplicationName string `protobuf:"bytes,2,opt,name=applicationName,proto3" json:"applicationName,omitempty"`
	Page            uint64 `protobuf:"varint,3,opt,name=page,proto3" json:"page,omitempty"`
	Size            uint64 `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	Destination     string `protobuf:"bytes,5,opt,name=destination,proto3" json:"destination,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessesRequest) Descriptor deprecated 

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

Deprecated: Use ProcessesRequest.ProtoReflect.Descriptor instead.

func (*ProcessesRequest) GetApplicationName 

func (x *ProcessesRequest) GetApplicationName() string

func (*ProcessesRequest) GetDestination 

func (x *ProcessesRequest) GetDestination() string

func (*ProcessesRequest) GetNamespace 

func (x *ProcessesRequest) GetNamespace() string

func (*ProcessesRequest) GetPage 

func (x *ProcessesRequest) GetPage() uint64

func (*ProcessesRequest) GetSize 

func (x *ProcessesRequest) GetSize() uint64

func (*ProcessesRequest) ProtoMessage 

func (*ProcessesRequest) ProtoMessage()

func (*ProcessesRequest) ProtoReflect 

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

func (*ProcessesRequest) Reset 

func (x *ProcessesRequest) Reset()

func (*ProcessesRequest) String 

func (x *ProcessesRequest) String() string

type ProcessesResponse 

type ProcessesResponse struct {
	Processes []*Process `protobuf:"bytes,1,rep,name=processes,proto3" json:"processes,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessesResponse) Descriptor deprecated 

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

Deprecated: Use ProcessesResponse.ProtoReflect.Descriptor instead.

func (*ProcessesResponse) GetProcesses 

func (x *ProcessesResponse) GetProcesses() []*Process

func (*ProcessesResponse) ProtoMessage 

func (*ProcessesResponse) ProtoMessage()

func (*ProcessesResponse) ProtoReflect 

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

func (*ProcessesResponse) Reset 

func (x *ProcessesResponse) Reset()

func (*ProcessesResponse) String 

func (x *ProcessesResponse) String() string

type QueryType 

type QueryType int32
const (
	QueryType_Search        QueryType = 0
	QueryType_AdvanceSearch QueryType = 1
)

func (QueryType) Descriptor 

func (QueryType) Descriptor() protoreflect.EnumDescriptor

func (QueryType) Enum 

func (x QueryType) Enum() *QueryType

func (QueryType) EnumDescriptor deprecated 

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

Deprecated: Use QueryType.Descriptor instead.

func (QueryType) Number 

func (x QueryType) Number() protoreflect.EnumNumber

func (QueryType) String 

func (x QueryType) String() string

func (QueryType) Type 

func (QueryType) Type() protoreflect.EnumType

type SortOrder 

type SortOrder struct {
	Attribute string         `protobuf:"bytes,1,opt,name=attribute,proto3" json:"attribute,omitempty"`
	Order     SortOrderEnums `protobuf:"varint,2,opt,name=order,proto3,enum=processdetails.SortOrderEnums" json:"order,omitempty"`
	// contains filtered or unexported fields
}

func (*SortOrder) Descriptor deprecated 

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

Deprecated: Use SortOrder.ProtoReflect.Descriptor instead.

func (*SortOrder) GetAttribute 

func (x *SortOrder) GetAttribute() string

func (*SortOrder) GetOrder 

func (x *SortOrder) GetOrder() SortOrderEnums

func (*SortOrder) ProtoMessage 

func (*SortOrder) ProtoMessage()

func (*SortOrder) ProtoReflect 

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

func (*SortOrder) Reset 

func (x *SortOrder) Reset()

func (*SortOrder) String 

func (x *SortOrder) String() string

type SortOrderEnums 

type SortOrderEnums int32
const (
	SortOrderEnums_ASC  SortOrderEnums = 0
	SortOrderEnums_DESC SortOrderEnums = 1
)

func (SortOrderEnums) Descriptor 

func (SortOrderEnums) Descriptor() protoreflect.EnumDescriptor

func (SortOrderEnums) Enum 

func (x SortOrderEnums) Enum() *SortOrderEnums

func (SortOrderEnums) EnumDescriptor deprecated 

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

Deprecated: Use SortOrderEnums.Descriptor instead.

func (SortOrderEnums) Number 

func (x SortOrderEnums) Number() protoreflect.EnumNumber

func (SortOrderEnums) String 

func (x SortOrderEnums) String() string

func (SortOrderEnums) Type 

func (SortOrderEnums) Type() protoreflect.EnumType

type UnimplementedProcessDetailsServiceServer 

type UnimplementedProcessDetailsServiceServer struct {
}

UnimplementedProcessDetailsServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedProcessDetailsServiceServer) GetProcessQuery 

func (*UnimplementedProcessDetailsServiceServer) GetProcessQuery(context.Context, *ProcessesQueryRequest) (*ProcessQueryResponse, error)

func (*UnimplementedProcessDetailsServiceServer) GetProcesses 

func (*UnimplementedProcessDetailsServiceServer) GetProcesses(context.Context, *ProcessesRequest) (*ProcessesResponse, 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.