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.

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) StartReindex

type UnimplementedIndexerServer

type UnimplementedIndexerServer struct {
}

UnimplementedIndexerServer can be embedded to have forward compatible implementations.

func (*UnimplementedIndexerServer) CompleteReindex

func (*UnimplementedIndexerServer) GetIndexerInfo

func (*UnimplementedIndexerServer) Index

func (*UnimplementedIndexerServer) PrepareReindex

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL