proto

package
v0.1.2 Latest Latest
Warning

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

 Go to latest Published: Sep 13, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Enum value maps for FsEventsFilter_Order.

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

Enum value maps for ProviderEventsFilter_Order.

View Source 
var File_eventsearcher_proto_search_proto protoreflect.FileDescriptor

Functions

func RegisterSearcherServer 

func RegisterSearcherServer(s *grpc.Server, srv SearcherServer)

Types

type FsEventsFilter 

type FsEventsFilter struct {
	StartTimestamp int64                `protobuf:"varint,1,opt,name=start_timestamp,json=startTimestamp,proto3" json:"start_timestamp,omitempty"`
	EndTimestamp   int64                `protobuf:"varint,2,opt,name=end_timestamp,json=endTimestamp,proto3" json:"end_timestamp,omitempty"`
	Actions        []string             `protobuf:"bytes,3,rep,name=actions,proto3" json:"actions,omitempty"`
	Username       string               `protobuf:"bytes,4,opt,name=username,proto3" json:"username,omitempty"`
	Ip             string               `protobuf:"bytes,5,opt,name=ip,proto3" json:"ip,omitempty"`
	SshCmd         string               `protobuf:"bytes,6,opt,name=ssh_cmd,json=sshCmd,proto3" json:"ssh_cmd,omitempty"`
	Protocols      []string             `protobuf:"bytes,7,rep,name=protocols,proto3" json:"protocols,omitempty"`
	Statuses       []int32              `protobuf:"varint,8,rep,packed,name=statuses,proto3" json:"statuses,omitempty"`
	InstanceIds    []string             `protobuf:"bytes,9,rep,name=instance_ids,json=instanceIds,proto3" json:"instance_ids,omitempty"`
	Limit          int32                `protobuf:"varint,10,opt,name=limit,proto3" json:"limit,omitempty"`
	ExcludeIds     []string             `protobuf:"bytes,11,rep,name=exclude_ids,json=excludeIds,proto3" json:"exclude_ids,omitempty"`
	FsProvider     int32                `protobuf:"varint,12,opt,name=fs_provider,json=fsProvider,proto3" json:"fs_provider,omitempty"`
	Bucket         string               `protobuf:"bytes,13,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Endpoint       string               `protobuf:"bytes,14,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Order          FsEventsFilter_Order `protobuf:"varint,15,opt,name=order,proto3,enum=proto.FsEventsFilter_Order" json:"order,omitempty"`
	// contains filtered or unexported fields
}

func (*FsEventsFilter) Descriptor deprecated 

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

Deprecated: Use FsEventsFilter.ProtoReflect.Descriptor instead.

func (*FsEventsFilter) GetActions 

func (x *FsEventsFilter) GetActions() []string

func (*FsEventsFilter) GetBucket 

func (x *FsEventsFilter) GetBucket() string

func (*FsEventsFilter) GetEndTimestamp 

func (x *FsEventsFilter) GetEndTimestamp() int64

func (*FsEventsFilter) GetEndpoint 

func (x *FsEventsFilter) GetEndpoint() string

func (*FsEventsFilter) GetExcludeIds 

func (x *FsEventsFilter) GetExcludeIds() []string

func (*FsEventsFilter) GetFsProvider 

func (x *FsEventsFilter) GetFsProvider() int32

func (*FsEventsFilter) GetInstanceIds 

func (x *FsEventsFilter) GetInstanceIds() []string

func (*FsEventsFilter) GetIp 

func (x *FsEventsFilter) GetIp() string

func (*FsEventsFilter) GetLimit 

func (x *FsEventsFilter) GetLimit() int32

func (*FsEventsFilter) GetOrder 

func (x *FsEventsFilter) GetOrder() FsEventsFilter_Order

func (*FsEventsFilter) GetProtocols 

func (x *FsEventsFilter) GetProtocols() []string

func (*FsEventsFilter) GetSshCmd 

func (x *FsEventsFilter) GetSshCmd() string

func (*FsEventsFilter) GetStartTimestamp 

func (x *FsEventsFilter) GetStartTimestamp() int64

func (*FsEventsFilter) GetStatuses 

func (x *FsEventsFilter) GetStatuses() []int32

func (*FsEventsFilter) GetUsername 

func (x *FsEventsFilter) GetUsername() string

func (*FsEventsFilter) ProtoMessage 

func (*FsEventsFilter) ProtoMessage()

func (*FsEventsFilter) ProtoReflect 

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

func (*FsEventsFilter) Reset 

func (x *FsEventsFilter) Reset()

func (*FsEventsFilter) String 

func (x *FsEventsFilter) String() string

type FsEventsFilter_Order 

type FsEventsFilter_Order int32
const (
	FsEventsFilter_DESC FsEventsFilter_Order = 0
	FsEventsFilter_ASC  FsEventsFilter_Order = 1
)

func (FsEventsFilter_Order) Descriptor 

func (FsEventsFilter_Order) Descriptor() protoreflect.EnumDescriptor

func (FsEventsFilter_Order) Enum 

func (x FsEventsFilter_Order) Enum() *FsEventsFilter_Order

func (FsEventsFilter_Order) EnumDescriptor deprecated 

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

Deprecated: Use FsEventsFilter_Order.Descriptor instead.

func (FsEventsFilter_Order) Number 

func (x FsEventsFilter_Order) Number() protoreflect.EnumNumber

func (FsEventsFilter_Order) String 

func (x FsEventsFilter_Order) String() string

func (FsEventsFilter_Order) Type 

func (FsEventsFilter_Order) Type() protoreflect.EnumType

type ProviderEventsFilter 

type ProviderEventsFilter struct {
	StartTimestamp int64                      `protobuf:"varint,1,opt,name=start_timestamp,json=startTimestamp,proto3" json:"start_timestamp,omitempty"`
	EndTimestamp   int64                      `protobuf:"varint,2,opt,name=end_timestamp,json=endTimestamp,proto3" json:"end_timestamp,omitempty"`
	Actions        []string                   `protobuf:"bytes,3,rep,name=actions,proto3" json:"actions,omitempty"`
	Username       string                     `protobuf:"bytes,4,opt,name=username,proto3" json:"username,omitempty"`
	Ip             string                     `protobuf:"bytes,5,opt,name=ip,proto3" json:"ip,omitempty"`
	ObjectTypes    []string                   `protobuf:"bytes,6,rep,name=object_types,json=objectTypes,proto3" json:"object_types,omitempty"`
	ObjectName     string                     `protobuf:"bytes,7,opt,name=object_name,json=objectName,proto3" json:"object_name,omitempty"`
	InstanceIds    []string                   `protobuf:"bytes,8,rep,name=instance_ids,json=instanceIds,proto3" json:"instance_ids,omitempty"`
	Limit          int32                      `protobuf:"varint,9,opt,name=limit,proto3" json:"limit,omitempty"`
	ExcludeIds     []string                   `protobuf:"bytes,10,rep,name=exclude_ids,json=excludeIds,proto3" json:"exclude_ids,omitempty"`
	Order          ProviderEventsFilter_Order `protobuf:"varint,11,opt,name=order,proto3,enum=proto.ProviderEventsFilter_Order" json:"order,omitempty"`
	// contains filtered or unexported fields
}

func (*ProviderEventsFilter) Descriptor deprecated 

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

Deprecated: Use ProviderEventsFilter.ProtoReflect.Descriptor instead.

func (*ProviderEventsFilter) GetActions 

func (x *ProviderEventsFilter) GetActions() []string

func (*ProviderEventsFilter) GetEndTimestamp 

func (x *ProviderEventsFilter) GetEndTimestamp() int64

func (*ProviderEventsFilter) GetExcludeIds 

func (x *ProviderEventsFilter) GetExcludeIds() []string

func (*ProviderEventsFilter) GetInstanceIds 

func (x *ProviderEventsFilter) GetInstanceIds() []string

func (*ProviderEventsFilter) GetIp 

func (x *ProviderEventsFilter) GetIp() string

func (*ProviderEventsFilter) GetLimit 

func (x *ProviderEventsFilter) GetLimit() int32

func (*ProviderEventsFilter) GetObjectName 

func (x *ProviderEventsFilter) GetObjectName() string

func (*ProviderEventsFilter) GetObjectTypes 

func (x *ProviderEventsFilter) GetObjectTypes() []string

func (*ProviderEventsFilter) GetOrder 

func (x *ProviderEventsFilter) GetOrder() ProviderEventsFilter_Order

func (*ProviderEventsFilter) GetStartTimestamp 

func (x *ProviderEventsFilter) GetStartTimestamp() int64

func (*ProviderEventsFilter) GetUsername 

func (x *ProviderEventsFilter) GetUsername() string

func (*ProviderEventsFilter) ProtoMessage 

func (*ProviderEventsFilter) ProtoMessage()

func (*ProviderEventsFilter) ProtoReflect 

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

func (*ProviderEventsFilter) Reset 

func (x *ProviderEventsFilter) Reset()

func (*ProviderEventsFilter) String 

func (x *ProviderEventsFilter) String() string

type ProviderEventsFilter_Order 

type ProviderEventsFilter_Order int32
const (
	ProviderEventsFilter_DESC ProviderEventsFilter_Order = 0
	ProviderEventsFilter_ASC  ProviderEventsFilter_Order = 1
)

func (ProviderEventsFilter_Order) Descriptor 

func (ProviderEventsFilter_Order) Descriptor() protoreflect.EnumDescriptor

func (ProviderEventsFilter_Order) Enum 

func (x ProviderEventsFilter_Order) Enum() *ProviderEventsFilter_Order

func (ProviderEventsFilter_Order) EnumDescriptor deprecated 

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

Deprecated: Use ProviderEventsFilter_Order.Descriptor instead.

func (ProviderEventsFilter_Order) Number 

func (x ProviderEventsFilter_Order) Number() protoreflect.EnumNumber

func (ProviderEventsFilter_Order) String 

func (x ProviderEventsFilter_Order) String() string

func (ProviderEventsFilter_Order) Type 

func (ProviderEventsFilter_Order) Type() protoreflect.EnumType

type SearchResponse 

type SearchResponse struct {
	Data          []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // JSON serialized response to return
	SameTsAtStart []string `protobuf:"bytes,2,rep,name=same_ts_at_start,json=sameTsAtStart,proto3" json:"same_ts_at_start,omitempty"`
	SameTsAtEnd   []string `protobuf:"bytes,3,rep,name=same_ts_at_end,json=sameTsAtEnd,proto3" json:"same_ts_at_end,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchResponse) Descriptor deprecated 

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

Deprecated: Use SearchResponse.ProtoReflect.Descriptor instead.

func (*SearchResponse) GetData 

func (x *SearchResponse) GetData() []byte

func (*SearchResponse) GetSameTsAtEnd 

func (x *SearchResponse) GetSameTsAtEnd() []string

func (*SearchResponse) GetSameTsAtStart 

func (x *SearchResponse) GetSameTsAtStart() []string

func (*SearchResponse) ProtoMessage 

func (*SearchResponse) ProtoMessage()

func (*SearchResponse) ProtoReflect 

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

func (*SearchResponse) Reset 

func (x *SearchResponse) Reset()

func (*SearchResponse) String 

func (x *SearchResponse) String() string

type SearcherClient 

type SearcherClient interface {
	SearchFsEvents(ctx context.Context, in *FsEventsFilter, opts ...grpc.CallOption) (*SearchResponse, error)
	SearchProviderEvents(ctx context.Context, in *ProviderEventsFilter, opts ...grpc.CallOption) (*SearchResponse, error)
}

SearcherClient is the client API for Searcher service.

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

func NewSearcherClient 

func NewSearcherClient(cc grpc.ClientConnInterface) SearcherClient

type SearcherServer 

type SearcherServer interface {
	SearchFsEvents(context.Context, *FsEventsFilter) (*SearchResponse, error)
	SearchProviderEvents(context.Context, *ProviderEventsFilter) (*SearchResponse, error)
}

SearcherServer is the server API for Searcher service.

type UnimplementedSearcherServer 

type UnimplementedSearcherServer struct {
}

UnimplementedSearcherServer can be embedded to have forward compatible implementations.

func (*UnimplementedSearcherServer) SearchFsEvents 

func (*UnimplementedSearcherServer) SearchFsEvents(context.Context, *FsEventsFilter) (*SearchResponse, error)

func (*UnimplementedSearcherServer) SearchProviderEvents 

func (*UnimplementedSearcherServer) SearchProviderEvents(context.Context, *ProviderEventsFilter) (*SearchResponse, 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.