pb

Documentation

Overview

Package pb is a generated protocol buffer package.

It is generated from these files:

srcstore.proto

It has these top-level messages:

ImportOp
IndexOp

Index

• Variables
• func RegisterMultiRepoImporterServer(s *grpc.Server, srv MultiRepoImporterServer)
• type ImportOp
  • func (m *ImportOp) Marshal() (data []byte, err error)
  • func (m *ImportOp) MarshalTo(data []byte) (int, error)
  • func (*ImportOp) ProtoMessage()
  • func (m *ImportOp) Reset()
  • func (m *ImportOp) Size() (n int)
  • func (m *ImportOp) String() string
  • func (m *ImportOp) Unmarshal(data []byte) error
• type IndexOp
  • func (m *IndexOp) Marshal() (data []byte, err error)
  • func (m *IndexOp) MarshalTo(data []byte) (int, error)
  • func (*IndexOp) ProtoMessage()
  • func (m *IndexOp) Reset()
  • func (m *IndexOp) Size() (n int)
  • func (m *IndexOp) String() string
  • func (m *IndexOp) Unmarshal(data []byte) error
• type MultiRepoImporterClient
  • func NewMultiRepoImporterClient(cc *grpc.ClientConn) MultiRepoImporterClient
• type MultiRepoImporterIndexer
  • func Client(ctx context.Context, c MultiRepoImporterClient) MultiRepoImporterIndexer
• type MultiRepoImporterServer
  • func Server(s MultiRepoImporterIndexer) MultiRepoImporterServer

Variables

var (
	ErrInvalidLengthSrcstore = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSrcstore   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterMultiRepoImporterServer

func RegisterMultiRepoImporterServer(s *grpc.Server, srv MultiRepoImporterServer)

Types

type ImportOp

type ImportOp struct {
	Repo     string               `protobuf:"bytes,1,opt,name=Repo,proto3" json:"Repo,omitempty"`
	CommitID string               `protobuf:"bytes,2,opt,name=CommitID,proto3" json:"CommitID,omitempty"`
	Unit     *unit.RepoSourceUnit `protobuf:"bytes,3,opt,name=Unit" json:"Unit,omitempty"`
	Data     *graph3.Output       `protobuf:"bytes,4,opt,name=Data" json:"Data,omitempty"`
}

func (*ImportOp) Marshal

func (m *ImportOp) Marshal() (data []byte, err error)

func (*ImportOp) MarshalTo

func (m *ImportOp) MarshalTo(data []byte) (int, error)

func (*ImportOp) ProtoMessage

func (*ImportOp) ProtoMessage()

func (*ImportOp) Reset

func (m *ImportOp) Reset()

func (*ImportOp) Size

func (m *ImportOp) Size() (n int)

func (*ImportOp) String

func (m *ImportOp) String() string

func (*ImportOp) Unmarshal

func (m *ImportOp) Unmarshal(data []byte) error

type IndexOp

type IndexOp struct {
	Repo     string `protobuf:"bytes,1,opt,name=Repo,proto3" json:"Repo,omitempty"`
	CommitID string `protobuf:"bytes,2,opt,name=CommitID,proto3" json:"CommitID,omitempty"`
}

func (*IndexOp) Marshal

func (m *IndexOp) Marshal() (data []byte, err error)

func (*IndexOp) MarshalTo

func (m *IndexOp) MarshalTo(data []byte) (int, error)

func (*IndexOp) ProtoMessage

func (*IndexOp) ProtoMessage()

func (*IndexOp) Reset

func (m *IndexOp) Reset()

func (*IndexOp) Size

func (m *IndexOp) Size() (n int)

func (*IndexOp) String

func (m *IndexOp) String() string

func (*IndexOp) Unmarshal

func (m *IndexOp) Unmarshal(data []byte) error

type MultiRepoImporterClient

type MultiRepoImporterClient interface {
	// Import imports srclib build data for a source unit at a
	// specific version into the store.
	Import(ctx context.Context, in *ImportOp, opts ...grpc.CallOption) (*pbtypes.Void, error)
	// Index builds indexes for a specific repo at a specific version.
	Index(ctx context.Context, in *IndexOp, opts ...grpc.CallOption) (*pbtypes.Void, error)
}

func NewMultiRepoImporterClient

func NewMultiRepoImporterClient(cc *grpc.ClientConn) MultiRepoImporterClient

type MultiRepoImporterIndexer

type MultiRepoImporterIndexer interface {
	store.MultiRepoImporter
	store.MultiRepoIndexer
}

A MultiRepoImporterIndexer implements both store.MultiRepoImporter and store.MultiRepoIndexer.

func Client

func Client(ctx context.Context, c MultiRepoImporterClient) MultiRepoImporterIndexer

Client wraps a gRPC MultiRepoImporterClient and makes it implement store.MultiRepoImporter. Clients should not be long-lived (because they must hold the ctx).

type MultiRepoImporterServer

type MultiRepoImporterServer interface {
	// Import imports srclib build data for a source unit at a
	// specific version into the store.
	Import(context.Context, *ImportOp) (*pbtypes.Void, error)
	// Index builds indexes for a specific repo at a specific version.
	Index(context.Context, *IndexOp) (*pbtypes.Void, error)
}

func Server

func Server(s MultiRepoImporterIndexer) MultiRepoImporterServer

Server wraps a store.MultiRepoImporter and makes it implement MultiRepoImporterServer.