protos

package
v0.0.0-...-89602ce Latest Latest
Warning

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

 Go to latest Published: Aug 18, 2020 License: BSD-3-Clause Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_indexer_manager_proto protoreflect.FileDescriptor
View Source 
var File_indexer_proto protoreflect.FileDescriptor

Functions

func RegisterIndexerManagerServer 

func RegisterIndexerManagerServer(s *grpc.Server, srv IndexerManagerServer)

func RegisterIndexerServer 

func RegisterIndexerServer(s *grpc.Server, srv IndexerServer)

Types

type CompleteReindexRequest 

type CompleteReindexRequest struct {

	// indexer_id being reindexed
	IndexerId string `protobuf:"bytes,1,opt,name=indexer_id,json=indexerId,proto3" json:"indexer_id,omitempty"`
	// from_version is the indexer's current (actual) version
	FromVersion uint32 `protobuf:"varint,2,opt,name=from_version,json=fromVersion,proto3" json:"from_version,omitempty"`
	// to_version is the indexer's future (desired) version
	ToVersion uint32 `protobuf:"varint,3,opt,name=to_version,json=toVersion,proto3" json:"to_version,omitempty"`
	// contains filtered or unexported fields
}

func (*CompleteReindexRequest) Descriptor deprecated 

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

Deprecated: Use CompleteReindexRequest.ProtoReflect.Descriptor instead.

func (*CompleteReindexRequest) GetFromVersion 

func (x *CompleteReindexRequest) GetFromVersion() uint32

func (*CompleteReindexRequest) GetIndexerId 

func (x *CompleteReindexRequest) GetIndexerId() string

func (*CompleteReindexRequest) GetToVersion 

func (x *CompleteReindexRequest) GetToVersion() uint32

func (*CompleteReindexRequest) ProtoMessage 

func (*CompleteReindexRequest) ProtoMessage()

func (*CompleteReindexRequest) ProtoReflect 

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

func (*CompleteReindexRequest) Reset 

func (x *CompleteReindexRequest) Reset()

func (*CompleteReindexRequest) String 

func (x *CompleteReindexRequest) String() string

type CompleteReindexResponse 

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

func (*CompleteReindexResponse) Descriptor deprecated 

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

Deprecated: Use CompleteReindexResponse.ProtoReflect.Descriptor instead.

func (*CompleteReindexResponse) ProtoMessage 

func (*CompleteReindexResponse) ProtoMessage()

func (*CompleteReindexResponse) ProtoReflect 

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

func (*CompleteReindexResponse) Reset 

func (x *CompleteReindexResponse) Reset()

func (*CompleteReindexResponse) String 

func (x *CompleteReindexResponse) String() string

type GetIndexerInfoRequest 

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

func (*GetIndexerInfoRequest) Descriptor deprecated 

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

Deprecated: Use GetIndexerInfoRequest.ProtoReflect.Descriptor instead.

func (*GetIndexerInfoRequest) ProtoMessage 

func (*GetIndexerInfoRequest) ProtoMessage()

func (*GetIndexerInfoRequest) ProtoReflect 

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

func (*GetIndexerInfoRequest) Reset 

func (x *GetIndexerInfoRequest) Reset()

func (*GetIndexerInfoRequest) String 

func (x *GetIndexerInfoRequest) String() string

type GetIndexerInfoResponse 

type GetIndexerInfoResponse struct {

	// version of the indexer's current implementation
	Version uint32 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	// state_types is the type of states the indexer will index
	// utilized for pre-filtering
	StateTypes []string `protobuf:"bytes,2,rep,name=state_types,json=stateTypes,proto3" json:"state_types,omitempty"`
	// contains filtered or unexported fields
}

func (*GetIndexerInfoResponse) Descriptor deprecated 

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

Deprecated: Use GetIndexerInfoResponse.ProtoReflect.Descriptor instead.

func (*GetIndexerInfoResponse) GetStateTypes 

func (x *GetIndexerInfoResponse) GetStateTypes() []string

func (*GetIndexerInfoResponse) GetVersion 

func (x *GetIndexerInfoResponse) GetVersion() uint32

func (*GetIndexerInfoResponse) ProtoMessage 

func (*GetIndexerInfoResponse) ProtoMessage()

func (*GetIndexerInfoResponse) ProtoReflect 

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

func (*GetIndexerInfoResponse) Reset 

func (x *GetIndexerInfoResponse) Reset()

func (*GetIndexerInfoResponse) String 

func (x *GetIndexerInfoResponse) String() string

type GetIndexersRequest 

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

func (*GetIndexersRequest) Descriptor deprecated 

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

Deprecated: Use GetIndexersRequest.ProtoReflect.Descriptor instead.

func (*GetIndexersRequest) ProtoMessage 

func (*GetIndexersRequest) ProtoMessage()

func (*GetIndexersRequest) ProtoReflect 

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

func (*GetIndexersRequest) Reset 

func (x *GetIndexersRequest) Reset()

func (*GetIndexersRequest) String 

func (x *GetIndexersRequest) String() string

type GetIndexersResponse 

type GetIndexersResponse struct {

	// indexers_by_id contains all tracked indexers, keyed by their ID.
	IndexersById map[string]*IndexerInfo `` /* 187-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetIndexersResponse) Descriptor deprecated 

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

Deprecated: Use GetIndexersResponse.ProtoReflect.Descriptor instead.

func (*GetIndexersResponse) GetIndexersById 

func (x *GetIndexersResponse) GetIndexersById() map[string]*IndexerInfo

func (*GetIndexersResponse) ProtoMessage 

func (*GetIndexersResponse) ProtoMessage()

func (*GetIndexersResponse) ProtoReflect 

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

func (*GetIndexersResponse) Reset 

func (x *GetIndexersResponse) Reset()

func (*GetIndexersResponse) String 

func (x *GetIndexersResponse) String() string

type IndexRequest 

type IndexRequest struct {

	// states to reindex
	States []*protos.State `protobuf:"bytes,1,rep,name=states,proto3" json:"states,omitempty"`
	// network_id of the states
	NetworkId string `protobuf:"bytes,2,opt,name=network_id,json=networkId,proto3" json:"network_id,omitempty"`
	// reporter_hwid is the hwid of the gateway that reported the states
	ReporterHwid string `protobuf:"bytes,3,opt,name=reporter_hwid,json=reporterHwid,proto3" json:"reporter_hwid,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexRequest) Descriptor deprecated 

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

Deprecated: Use IndexRequest.ProtoReflect.Descriptor instead.

func (*IndexRequest) GetNetworkId 

func (x *IndexRequest) GetNetworkId() string

func (*IndexRequest) GetReporterHwid 

func (x *IndexRequest) GetReporterHwid() string

func (*IndexRequest) GetStates 

func (x *IndexRequest) GetStates() []*protos.State

func (*IndexRequest) ProtoMessage 

func (*IndexRequest) ProtoMessage()

func (*IndexRequest) ProtoReflect 

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

func (*IndexRequest) Reset 

func (x *IndexRequest) Reset()

func (*IndexRequest) String 

func (x *IndexRequest) String() string

type IndexResponse 

type IndexResponse struct {

	// state_errors are errors experienced trying to index specific pieces of state.
	StateErrors []*protos.IDAndError `protobuf:"bytes,1,rep,name=state_errors,json=stateErrors,proto3" json:"state_errors,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexResponse) Descriptor deprecated 

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

Deprecated: Use IndexResponse.ProtoReflect.Descriptor instead.

func (*IndexResponse) GetStateErrors 

func (x *IndexResponse) GetStateErrors() []*protos.IDAndError

func (*IndexResponse) ProtoMessage 

func (*IndexResponse) ProtoMessage()

func (*IndexResponse) ProtoReflect 

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

func (*IndexResponse) Reset 

func (x *IndexResponse) Reset()

func (*IndexResponse) String 

func (x *IndexResponse) String() string

type IndexerClient 

type IndexerClient interface {
	// GetIndexerInfo gets info about this indexer.
	GetIndexerInfo(ctx context.Context, in *GetIndexerInfoRequest, opts ...grpc.CallOption) (*GetIndexerInfoResponse, error)
	// Index a set of states by forwarding to locally-registered indexers.
	Index(ctx context.Context, in *IndexRequest, opts ...grpc.CallOption) (*IndexResponse, error)
	// PrepareReindex of a particular indexer.
	PrepareReindex(ctx context.Context, in *PrepareReindexRequest, opts ...grpc.CallOption) (*PrepareReindexResponse, error)
	// CompleteReindex of a particular indexer.
	CompleteReindex(ctx context.Context, in *CompleteReindexRequest, opts ...grpc.CallOption) (*CompleteReindexResponse, error)
}

IndexerClient is the client API for Indexer service.

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

func NewIndexerClient 

func NewIndexerClient(cc grpc.ClientConnInterface) IndexerClient

type IndexerInfo 

type IndexerInfo struct {

	// indexer_id is the indexer's ID.
	IndexerId string `protobuf:"bytes,1,opt,name=indexer_id,json=indexerId,proto3" json:"indexer_id,omitempty"`
	// actual_version is the indexer's current version.
	ActualVersion uint32 `protobuf:"varint,2,opt,name=actual_version,json=actualVersion,proto3" json:"actual_version,omitempty"`
	// desired_version is the version to which the indexer will be reindexed.
	DesiredVersion uint32 `protobuf:"varint,3,opt,name=desired_version,json=desiredVersion,proto3" json:"desired_version,omitempty"`
	// contains filtered or unexported fields
}

IndexerInfo provides info about a state indexer.

func (*IndexerInfo) Descriptor deprecated 

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

Deprecated: Use IndexerInfo.ProtoReflect.Descriptor instead.

func (*IndexerInfo) GetActualVersion 

func (x *IndexerInfo) GetActualVersion() uint32

func (*IndexerInfo) GetDesiredVersion 

func (x *IndexerInfo) GetDesiredVersion() uint32

func (*IndexerInfo) GetIndexerId 

func (x *IndexerInfo) GetIndexerId() string

func (*IndexerInfo) ProtoMessage 

func (*IndexerInfo) ProtoMessage()

func (*IndexerInfo) ProtoReflect 

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

func (*IndexerInfo) Reset 

func (x *IndexerInfo) Reset()

func (*IndexerInfo) String 

func (x *IndexerInfo) String() string

type IndexerManagerClient 

type IndexerManagerClient interface {
	// GetIndexers returns indexer info for all tracked indexers.
	GetIndexers(ctx context.Context, in *GetIndexersRequest, opts ...grpc.CallOption) (*GetIndexersResponse, error)
	// StartReindex kicks off any required reindex jobs for some or all indexers.
	// Blocks till reindex job returns, streaming loggable updates.
	StartReindex(ctx context.Context, in *StartReindexRequest, opts ...grpc.CallOption) (IndexerManager_StartReindexClient, error)
}

IndexerManagerClient is the client API for IndexerManager service.

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

func NewIndexerManagerClient 

func NewIndexerManagerClient(cc grpc.ClientConnInterface) IndexerManagerClient

type IndexerManagerServer 

type IndexerManagerServer interface {
	// GetIndexers returns indexer info for all tracked indexers.
	GetIndexers(context.Context, *GetIndexersRequest) (*GetIndexersResponse, error)
	// StartReindex kicks off any required reindex jobs for some or all indexers.
	// Blocks till reindex job returns, streaming loggable updates.
	StartReindex(*StartReindexRequest, IndexerManager_StartReindexServer) error
}

IndexerManagerServer is the server API for IndexerManager service.

type IndexerManager_StartReindexClient 

type IndexerManager_StartReindexClient interface {
	Recv() (*StartReindexResponse, error)
	grpc.ClientStream
}

type IndexerManager_StartReindexServer 

type IndexerManager_StartReindexServer interface {
	Send(*StartReindexResponse) error
	grpc.ServerStream
}

type IndexerServer 

type IndexerServer interface {
	// GetIndexerInfo gets info about this indexer.
	GetIndexerInfo(context.Context, *GetIndexerInfoRequest) (*GetIndexerInfoResponse, error)
	// Index a set of states by forwarding to locally-registered indexers.
	Index(context.Context, *IndexRequest) (*IndexResponse, error)
	// PrepareReindex of a particular indexer.
	PrepareReindex(context.Context, *PrepareReindexRequest) (*PrepareReindexResponse, error)
	// CompleteReindex of a particular indexer.
	CompleteReindex(context.Context, *CompleteReindexRequest) (*CompleteReindexResponse, error)
}

IndexerServer is the server API for Indexer service.

type PrepareReindexRequest 

type PrepareReindexRequest struct {

	// indexer_id being reindexed
	IndexerId string `protobuf:"bytes,1,opt,name=indexer_id,json=indexerId,proto3" json:"indexer_id,omitempty"`
	// from_version is the indexer's current (actual) version
	FromVersion uint32 `protobuf:"varint,2,opt,name=from_version,json=fromVersion,proto3" json:"from_version,omitempty"`
	// to_version is the indexer's future (desired) version
	ToVersion uint32 `protobuf:"varint,3,opt,name=to_version,json=toVersion,proto3" json:"to_version,omitempty"`
	// is_first is true iff this is the first time this indexer is being reindexed
	IsFirst bool `protobuf:"varint,4,opt,name=is_first,json=isFirst,proto3" json:"is_first,omitempty"`
	// contains filtered or unexported fields
}

func (*PrepareReindexRequest) Descriptor deprecated 

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

Deprecated: Use PrepareReindexRequest.ProtoReflect.Descriptor instead.

func (*PrepareReindexRequest) GetFromVersion 

func (x *PrepareReindexRequest) GetFromVersion() uint32

func (*PrepareReindexRequest) GetIndexerId 

func (x *PrepareReindexRequest) GetIndexerId() string

func (*PrepareReindexRequest) GetIsFirst 

func (x *PrepareReindexRequest) GetIsFirst() bool

func (*PrepareReindexRequest) GetToVersion 

func (x *PrepareReindexRequest) GetToVersion() uint32

func (*PrepareReindexRequest) ProtoMessage 

func (*PrepareReindexRequest) ProtoMessage()

func (*PrepareReindexRequest) ProtoReflect 

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

func (*PrepareReindexRequest) Reset 

func (x *PrepareReindexRequest) Reset()

func (*PrepareReindexRequest) String 

func (x *PrepareReindexRequest) String() string

type PrepareReindexResponse 

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

func (*PrepareReindexResponse) Descriptor deprecated 

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

Deprecated: Use PrepareReindexResponse.ProtoReflect.Descriptor instead.

func (*PrepareReindexResponse) ProtoMessage 

func (*PrepareReindexResponse) ProtoMessage()

func (*PrepareReindexResponse) ProtoReflect 

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

func (*PrepareReindexResponse) Reset 

func (x *PrepareReindexResponse) Reset()

func (*PrepareReindexResponse) String 

func (x *PrepareReindexResponse) String() string

type StartReindexRequest 

type StartReindexRequest struct {

	// indexer_id is the ID of the indexer to reindex.
	// If indexer_id is empty, will reindex all necessary indexers.
	IndexerId string `protobuf:"bytes,1,opt,name=indexer_id,json=indexerId,proto3" json:"indexer_id,omitempty"`
	// force the reindex to occur.
	// By default, start reindex will fail if automatic reindexing is enabled.
	// Set force=true to overrule this default.
	Force bool `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*StartReindexRequest) Descriptor deprecated 

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

Deprecated: Use StartReindexRequest.ProtoReflect.Descriptor instead.

func (*StartReindexRequest) GetForce 

func (x *StartReindexRequest) GetForce() bool

func (*StartReindexRequest) GetIndexerId 

func (x *StartReindexRequest) GetIndexerId() string

func (*StartReindexRequest) ProtoMessage 

func (*StartReindexRequest) ProtoMessage()

func (*StartReindexRequest) ProtoReflect 

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

func (*StartReindexRequest) Reset 

func (x *StartReindexRequest) Reset()

func (*StartReindexRequest) String 

func (x *StartReindexRequest) String() string

type StartReindexResponse 

type StartReindexResponse struct {

	// update contains a human-readable update on reindex progress
	Update string `protobuf:"bytes,1,opt,name=update,proto3" json:"update,omitempty"`
	// contains filtered or unexported fields
}

func (*StartReindexResponse) Descriptor deprecated 

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

Deprecated: Use StartReindexResponse.ProtoReflect.Descriptor instead.

func (*StartReindexResponse) GetUpdate 

func (x *StartReindexResponse) GetUpdate() string

func (*StartReindexResponse) ProtoMessage 

func (*StartReindexResponse) ProtoMessage()

func (*StartReindexResponse) ProtoReflect 

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

func (*StartReindexResponse) Reset 

func (x *StartReindexResponse) Reset()

func (*StartReindexResponse) String 

func (x *StartReindexResponse) String() string

type UnimplementedIndexerManagerServer 

type UnimplementedIndexerManagerServer struct {
}

UnimplementedIndexerManagerServer can be embedded to have forward compatible implementations.

func (*UnimplementedIndexerManagerServer) GetIndexers 

func (*UnimplementedIndexerManagerServer) GetIndexers(context.Context, *GetIndexersRequest) (*GetIndexersResponse, error)

func (*UnimplementedIndexerManagerServer) StartReindex 

func (*UnimplementedIndexerManagerServer) StartReindex(*StartReindexRequest, IndexerManager_StartReindexServer) error

type UnimplementedIndexerServer 

type UnimplementedIndexerServer struct {
}

UnimplementedIndexerServer can be embedded to have forward compatible implementations.

func (*UnimplementedIndexerServer) CompleteReindex 

func (*UnimplementedIndexerServer) CompleteReindex(context.Context, *CompleteReindexRequest) (*CompleteReindexResponse, error)

func (*UnimplementedIndexerServer) GetIndexerInfo 

func (*UnimplementedIndexerServer) GetIndexerInfo(context.Context, *GetIndexerInfoRequest) (*GetIndexerInfoResponse, error)

func (*UnimplementedIndexerServer) Index 

func (*UnimplementedIndexerServer) Index(context.Context, *IndexRequest) (*IndexResponse, error)

func (*UnimplementedIndexerServer) PrepareReindex 

func (*UnimplementedIndexerServer) PrepareReindex(context.Context, *PrepareReindexRequest) (*PrepareReindexResponse, error)

Source Files

View all Source files

Directories

Path Synopsis

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.