tracker

package
v0.1.13 Latest Latest
Warning

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

 Go to latest Published: Sep 9, 2020 License: MIT Imports: 16 Imported by: 2

Documentation

Overview

Package tracker is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterDependencyServiceHandler 

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

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

func RegisterDependencyServiceHandlerClient 

func RegisterDependencyServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DependencyServiceClient) error

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

func RegisterDependencyServiceHandlerFromEndpoint 

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

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

func RegisterDependencyServiceHandlerServer 

func RegisterDependencyServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server DependencyServiceServer) error

RegisterDependencyServiceHandlerServer registers the http handlers for service DependencyService to "mux". UnaryRPC :call DependencyServiceServer 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 (such as grpc.SendHeader, etc) to stop working. Consider using RegisterDependencyServiceHandlerFromEndpoint instead.

func RegisterDependencyServiceServer 

func RegisterDependencyServiceServer(s *grpc.Server, srv DependencyServiceServer)

func RegisterModuleServiceHandler 

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

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

func RegisterModuleServiceHandlerClient 

func RegisterModuleServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ModuleServiceClient) error

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

func RegisterModuleServiceHandlerFromEndpoint 

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

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

func RegisterModuleServiceHandlerServer 

func RegisterModuleServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ModuleServiceServer) error

RegisterModuleServiceHandlerServer registers the http handlers for service ModuleService to "mux". UnaryRPC :call ModuleServiceServer 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 (such as grpc.SendHeader, etc) to stop working. Consider using RegisterModuleServiceHandlerFromEndpoint instead.

func RegisterModuleServiceServer 

func RegisterModuleServiceServer(s *grpc.Server, srv ModuleServiceServer)

func RegisterSearchServiceServer added in v0.1.9 

func RegisterSearchServiceServer(s *grpc.Server, srv SearchServiceServer)

func RegisterSourceServiceHandler 

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

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

func RegisterSourceServiceHandlerClient 

func RegisterSourceServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client SourceServiceClient) error

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

func RegisterSourceServiceHandlerFromEndpoint 

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

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

func RegisterSourceServiceHandlerServer 

func RegisterSourceServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server SourceServiceServer) error

RegisterSourceServiceHandlerServer registers the http handlers for service SourceService to "mux". UnaryRPC :call SourceServiceServer 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 (such as grpc.SendHeader, etc) to stop working. Consider using RegisterSourceServiceHandlerFromEndpoint instead.

func RegisterSourceServiceServer 

func RegisterSourceServiceServer(s *grpc.Server, srv SourceServiceServer)

Types

type Dependency 

type Dependency struct {
	Depends              *schema.Depends `protobuf:"bytes,1,opt,name=depends,proto3" json:"depends,omitempty"`
	Module               *schema.Module  `protobuf:"bytes,2,opt,name=module,proto3" json:"module,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*Dependency) Descriptor 

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

func (*Dependency) GetDepends 

func (m *Dependency) GetDepends() *schema.Depends

func (*Dependency) GetModule 

func (m *Dependency) GetModule() *schema.Module

func (*Dependency) ProtoMessage 

func (*Dependency) ProtoMessage()

func (*Dependency) Reset 

func (m *Dependency) Reset()

func (*Dependency) String 

func (m *Dependency) String() string

func (*Dependency) XXX_DiscardUnknown 

func (m *Dependency) XXX_DiscardUnknown()

func (*Dependency) XXX_Marshal 

func (m *Dependency) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Dependency) XXX_Merge 

func (m *Dependency) XXX_Merge(src proto.Message)

func (*Dependency) XXX_Size 

func (m *Dependency) XXX_Size() int

func (*Dependency) XXX_Unmarshal 

func (m *Dependency) XXX_Unmarshal(b []byte) error

type DependencyRequest 

type DependencyRequest struct {
	Language             string   `protobuf:"bytes,1,opt,name=language,proto3" json:"language,omitempty"`
	Organization         string   `protobuf:"bytes,5,opt,name=organization,proto3" json:"organization,omitempty"`
	Module               string   `protobuf:"bytes,6,opt,name=module,proto3" json:"module,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DependencyRequest) Descriptor 

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

func (*DependencyRequest) GetLanguage 

func (m *DependencyRequest) GetLanguage() string

func (*DependencyRequest) GetModule 

func (m *DependencyRequest) GetModule() string

func (*DependencyRequest) GetOrganization 

func (m *DependencyRequest) GetOrganization() string

func (*DependencyRequest) ProtoMessage 

func (*DependencyRequest) ProtoMessage()

func (*DependencyRequest) Reset 

func (m *DependencyRequest) Reset()

func (*DependencyRequest) String 

func (m *DependencyRequest) String() string

func (*DependencyRequest) XXX_DiscardUnknown 

func (m *DependencyRequest) XXX_DiscardUnknown()

func (*DependencyRequest) XXX_Marshal 

func (m *DependencyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DependencyRequest) XXX_Merge 

func (m *DependencyRequest) XXX_Merge(src proto.Message)

func (*DependencyRequest) XXX_Size 

func (m *DependencyRequest) XXX_Size() int

func (*DependencyRequest) XXX_Unmarshal 

func (m *DependencyRequest) XXX_Unmarshal(b []byte) error

type DependencyServiceClient 

type DependencyServiceClient interface {
	ListDependents(ctx context.Context, in *DependencyRequest, opts ...grpc.CallOption) (*ListDependentsResponse, error)
	ListDependencies(ctx context.Context, in *DependencyRequest, opts ...grpc.CallOption) (*ListDependenciesResponse, error)
}

DependencyServiceClient is the client API for DependencyService service.

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

func NewDependencyServiceClient 

func NewDependencyServiceClient(cc *grpc.ClientConn) DependencyServiceClient

type DependencyServiceServer 

type DependencyServiceServer interface {
	ListDependents(context.Context, *DependencyRequest) (*ListDependentsResponse, error)
	ListDependencies(context.Context, *DependencyRequest) (*ListDependenciesResponse, error)
}

DependencyServiceServer is the server API for DependencyService service.

type ListDependenciesResponse 

type ListDependenciesResponse struct {
	Dependencies         []*Dependency `protobuf:"bytes,1,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ListDependenciesResponse) Descriptor 

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

func (*ListDependenciesResponse) GetDependencies 

func (m *ListDependenciesResponse) GetDependencies() []*Dependency

func (*ListDependenciesResponse) ProtoMessage 

func (*ListDependenciesResponse) ProtoMessage()

func (*ListDependenciesResponse) Reset 

func (m *ListDependenciesResponse) Reset()

func (*ListDependenciesResponse) String 

func (m *ListDependenciesResponse) String() string

func (*ListDependenciesResponse) XXX_DiscardUnknown 

func (m *ListDependenciesResponse) XXX_DiscardUnknown()

func (*ListDependenciesResponse) XXX_Marshal 

func (m *ListDependenciesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListDependenciesResponse) XXX_Merge 

func (m *ListDependenciesResponse) XXX_Merge(src proto.Message)

func (*ListDependenciesResponse) XXX_Size 

func (m *ListDependenciesResponse) XXX_Size() int

func (*ListDependenciesResponse) XXX_Unmarshal 

func (m *ListDependenciesResponse) XXX_Unmarshal(b []byte) error

type ListDependentsResponse 

type ListDependentsResponse struct {
	Dependents           []*Dependency `protobuf:"bytes,1,rep,name=dependents,proto3" json:"dependents,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ListDependentsResponse) Descriptor 

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

func (*ListDependentsResponse) GetDependents 

func (m *ListDependentsResponse) GetDependents() []*Dependency

func (*ListDependentsResponse) ProtoMessage 

func (*ListDependentsResponse) ProtoMessage()

func (*ListDependentsResponse) Reset 

func (m *ListDependentsResponse) Reset()

func (*ListDependentsResponse) String 

func (m *ListDependentsResponse) String() string

func (*ListDependentsResponse) XXX_DiscardUnknown 

func (m *ListDependentsResponse) XXX_DiscardUnknown()

func (*ListDependentsResponse) XXX_Marshal 

func (m *ListDependentsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListDependentsResponse) XXX_Merge 

func (m *ListDependentsResponse) XXX_Merge(src proto.Message)

func (*ListDependentsResponse) XXX_Size 

func (m *ListDependentsResponse) XXX_Size() int

func (*ListDependentsResponse) XXX_Unmarshal 

func (m *ListDependentsResponse) XXX_Unmarshal(b []byte) error

type ListManagedResponse 

type ListManagedResponse struct {
	Modules              []*ManagedModule `protobuf:"bytes,1,rep,name=modules,proto3" json:"modules,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ListManagedResponse) Descriptor 

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

func (*ListManagedResponse) GetModules 

func (m *ListManagedResponse) GetModules() []*ManagedModule

func (*ListManagedResponse) ProtoMessage 

func (*ListManagedResponse) ProtoMessage()

func (*ListManagedResponse) Reset 

func (m *ListManagedResponse) Reset()

func (*ListManagedResponse) String 

func (m *ListManagedResponse) String() string

func (*ListManagedResponse) XXX_DiscardUnknown 

func (m *ListManagedResponse) XXX_DiscardUnknown()

func (*ListManagedResponse) XXX_Marshal 

func (m *ListManagedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListManagedResponse) XXX_Merge 

func (m *ListManagedResponse) XXX_Merge(src proto.Message)

func (*ListManagedResponse) XXX_Size 

func (m *ListManagedResponse) XXX_Size() int

func (*ListManagedResponse) XXX_Unmarshal 

func (m *ListManagedResponse) XXX_Unmarshal(b []byte) error

type ListModuleResponse 

type ListModuleResponse struct {
	Page                 int32            `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty"`
	Count                int32            `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	Modules              []*schema.Module `protobuf:"bytes,3,rep,name=modules,proto3" json:"modules,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ListModuleResponse) Descriptor 

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

func (*ListModuleResponse) GetCount 

func (m *ListModuleResponse) GetCount() int32

func (*ListModuleResponse) GetModules 

func (m *ListModuleResponse) GetModules() []*schema.Module

func (*ListModuleResponse) GetPage 

func (m *ListModuleResponse) GetPage() int32

func (*ListModuleResponse) ProtoMessage 

func (*ListModuleResponse) ProtoMessage()

func (*ListModuleResponse) Reset 

func (m *ListModuleResponse) Reset()

func (*ListModuleResponse) String 

func (m *ListModuleResponse) String() string

func (*ListModuleResponse) XXX_DiscardUnknown 

func (m *ListModuleResponse) XXX_DiscardUnknown()

func (*ListModuleResponse) XXX_Marshal 

func (m *ListModuleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListModuleResponse) XXX_Merge 

func (m *ListModuleResponse) XXX_Merge(src proto.Message)

func (*ListModuleResponse) XXX_Size 

func (m *ListModuleResponse) XXX_Size() int

func (*ListModuleResponse) XXX_Unmarshal 

func (m *ListModuleResponse) XXX_Unmarshal(b []byte) error

type ListRequest 

type ListRequest struct {
	Page                 int32    `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty"`
	Count                int32    `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListRequest) Descriptor 

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

func (*ListRequest) GetCount 

func (m *ListRequest) GetCount() int32

func (*ListRequest) GetPage 

func (m *ListRequest) GetPage() int32

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) Reset 

func (m *ListRequest) Reset()

func (*ListRequest) String 

func (m *ListRequest) String() string

func (*ListRequest) XXX_DiscardUnknown 

func (m *ListRequest) XXX_DiscardUnknown()

func (*ListRequest) XXX_Marshal 

func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListRequest) XXX_Merge 

func (m *ListRequest) XXX_Merge(src proto.Message)

func (*ListRequest) XXX_Size 

func (m *ListRequest) XXX_Size() int

func (*ListRequest) XXX_Unmarshal 

func (m *ListRequest) XXX_Unmarshal(b []byte) error

type ListSourceResponse 

type ListSourceResponse struct {
	Page                 int32            `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty"`
	Count                int32            `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	Sources              []*schema.Source `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ListSourceResponse) Descriptor 

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

func (*ListSourceResponse) GetCount 

func (m *ListSourceResponse) GetCount() int32

func (*ListSourceResponse) GetPage 

func (m *ListSourceResponse) GetPage() int32

func (*ListSourceResponse) GetSources 

func (m *ListSourceResponse) GetSources() []*schema.Source

func (*ListSourceResponse) ProtoMessage 

func (*ListSourceResponse) ProtoMessage()

func (*ListSourceResponse) Reset 

func (m *ListSourceResponse) Reset()

func (*ListSourceResponse) String 

func (m *ListSourceResponse) String() string

func (*ListSourceResponse) XXX_DiscardUnknown 

func (m *ListSourceResponse) XXX_DiscardUnknown()

func (*ListSourceResponse) XXX_Marshal 

func (m *ListSourceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListSourceResponse) XXX_Merge 

func (m *ListSourceResponse) XXX_Merge(src proto.Message)

func (*ListSourceResponse) XXX_Size 

func (m *ListSourceResponse) XXX_Size() int

func (*ListSourceResponse) XXX_Unmarshal 

func (m *ListSourceResponse) XXX_Unmarshal(b []byte) error

type ListSourcesResponse 

type ListSourcesResponse struct {
	Sources              []*ManagedSource `protobuf:"bytes,1,rep,name=sources,proto3" json:"sources,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ListSourcesResponse) Descriptor 

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

func (*ListSourcesResponse) GetSources 

func (m *ListSourcesResponse) GetSources() []*ManagedSource

func (*ListSourcesResponse) ProtoMessage 

func (*ListSourcesResponse) ProtoMessage()

func (*ListSourcesResponse) Reset 

func (m *ListSourcesResponse) Reset()

func (*ListSourcesResponse) String 

func (m *ListSourcesResponse) String() string

func (*ListSourcesResponse) XXX_DiscardUnknown 

func (m *ListSourcesResponse) XXX_DiscardUnknown()

func (*ListSourcesResponse) XXX_Marshal 

func (m *ListSourcesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListSourcesResponse) XXX_Merge 

func (m *ListSourcesResponse) XXX_Merge(src proto.Message)

func (*ListSourcesResponse) XXX_Size 

func (m *ListSourcesResponse) XXX_Size() int

func (*ListSourcesResponse) XXX_Unmarshal 

func (m *ListSourcesResponse) XXX_Unmarshal(b []byte) error

type ManagedModule 

type ManagedModule struct {
	Manages              *schema.Manages `protobuf:"bytes,1,opt,name=manages,proto3" json:"manages,omitempty"`
	Module               *schema.Module  `protobuf:"bytes,2,opt,name=module,proto3" json:"module,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ManagedModule) Descriptor 

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

func (*ManagedModule) GetManages 

func (m *ManagedModule) GetManages() *schema.Manages

func (*ManagedModule) GetModule 

func (m *ManagedModule) GetModule() *schema.Module

func (*ManagedModule) ProtoMessage 

func (*ManagedModule) ProtoMessage()

func (*ManagedModule) Reset 

func (m *ManagedModule) Reset()

func (*ManagedModule) String 

func (m *ManagedModule) String() string

func (*ManagedModule) XXX_DiscardUnknown 

func (m *ManagedModule) XXX_DiscardUnknown()

func (*ManagedModule) XXX_Marshal 

func (m *ManagedModule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ManagedModule) XXX_Merge 

func (m *ManagedModule) XXX_Merge(src proto.Message)

func (*ManagedModule) XXX_Size 

func (m *ManagedModule) XXX_Size() int

func (*ManagedModule) XXX_Unmarshal 

func (m *ManagedModule) XXX_Unmarshal(b []byte) error

type ManagedSource 

type ManagedSource struct {
	Source               *schema.Source  `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Manages              *schema.Manages `protobuf:"bytes,2,opt,name=manages,proto3" json:"manages,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ManagedSource) Descriptor 

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

func (*ManagedSource) GetManages 

func (m *ManagedSource) GetManages() *schema.Manages

func (*ManagedSource) GetSource 

func (m *ManagedSource) GetSource() *schema.Source

func (*ManagedSource) ProtoMessage 

func (*ManagedSource) ProtoMessage()

func (*ManagedSource) Reset 

func (m *ManagedSource) Reset()

func (*ManagedSource) String 

func (m *ManagedSource) String() string

func (*ManagedSource) XXX_DiscardUnknown 

func (m *ManagedSource) XXX_DiscardUnknown()

func (*ManagedSource) XXX_Marshal 

func (m *ManagedSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ManagedSource) XXX_Merge 

func (m *ManagedSource) XXX_Merge(src proto.Message)

func (*ManagedSource) XXX_Size 

func (m *ManagedSource) XXX_Size() int

func (*ManagedSource) XXX_Unmarshal 

func (m *ManagedSource) XXX_Unmarshal(b []byte) error

type ModuleServiceClient 

type ModuleServiceClient interface {
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListModuleResponse, error)
	ListSources(ctx context.Context, in *schema.Module, opts ...grpc.CallOption) (*ListSourcesResponse, error)
	ListManaged(ctx context.Context, in *schema.Source, opts ...grpc.CallOption) (*ListManagedResponse, error)
}

ModuleServiceClient is the client API for ModuleService service.

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

func NewModuleServiceClient 

func NewModuleServiceClient(cc *grpc.ClientConn) ModuleServiceClient

type ModuleServiceServer 

type ModuleServiceServer interface {
	List(context.Context, *ListRequest) (*ListModuleResponse, error)
	ListSources(context.Context, *schema.Module) (*ListSourcesResponse, error)
	ListManaged(context.Context, *schema.Source) (*ListManagedResponse, error)
}

ModuleServiceServer is the server API for ModuleService service.

type SearchRequest added in v0.1.9 

type SearchRequest struct {
	Cancel               bool               `protobuf:"varint,1,opt,name=cancel,proto3" json:"cancel,omitempty"`
	DependentsOf         *DependencyRequest `protobuf:"bytes,5,opt,name=dependentsOf,proto3" json:"dependentsOf,omitempty"`
	DependenciesOf       *DependencyRequest `protobuf:"bytes,6,opt,name=dependenciesOf,proto3" json:"dependenciesOf,omitempty"`
	ModulesFor           *schema.Source     `protobuf:"bytes,7,opt,name=modulesFor,proto3" json:"modulesFor,omitempty"`
	SourcesFor           *schema.Module     `protobuf:"bytes,8,opt,name=sourcesFor,proto3" json:"sourcesFor,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*SearchRequest) Descriptor added in v0.1.9 

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

func (*SearchRequest) GetCancel added in v0.1.9 

func (m *SearchRequest) GetCancel() bool

func (*SearchRequest) GetDependenciesOf added in v0.1.9 

func (m *SearchRequest) GetDependenciesOf() *DependencyRequest

func (*SearchRequest) GetDependentsOf added in v0.1.9 

func (m *SearchRequest) GetDependentsOf() *DependencyRequest

func (*SearchRequest) GetModulesFor added in v0.1.9 

func (m *SearchRequest) GetModulesFor() *schema.Source

func (*SearchRequest) GetSourcesFor added in v0.1.9 

func (m *SearchRequest) GetSourcesFor() *schema.Module

func (*SearchRequest) ProtoMessage added in v0.1.9 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) Reset added in v0.1.9 

func (m *SearchRequest) Reset()

func (*SearchRequest) String added in v0.1.9 

func (m *SearchRequest) String() string

func (*SearchRequest) XXX_DiscardUnknown added in v0.1.9 

func (m *SearchRequest) XXX_DiscardUnknown()

func (*SearchRequest) XXX_Marshal added in v0.1.9 

func (m *SearchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SearchRequest) XXX_Merge added in v0.1.9 

func (m *SearchRequest) XXX_Merge(src proto.Message)

func (*SearchRequest) XXX_Size added in v0.1.9 

func (m *SearchRequest) XXX_Size() int

func (*SearchRequest) XXX_Unmarshal added in v0.1.9 

func (m *SearchRequest) XXX_Unmarshal(b []byte) error

type SearchResponse added in v0.1.9 

type SearchResponse struct {
	Request              *SearchRequest   `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	Dependents           []*Dependency    `protobuf:"bytes,5,rep,name=dependents,proto3" json:"dependents,omitempty"`
	Dependencies         []*Dependency    `protobuf:"bytes,6,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	Modules              []*ManagedModule `protobuf:"bytes,7,rep,name=modules,proto3" json:"modules,omitempty"`
	Sources              []*ManagedSource `protobuf:"bytes,8,rep,name=sources,proto3" json:"sources,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*SearchResponse) Descriptor added in v0.1.9 

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

func (*SearchResponse) GetDependencies added in v0.1.9 

func (m *SearchResponse) GetDependencies() []*Dependency

func (*SearchResponse) GetDependents added in v0.1.9 

func (m *SearchResponse) GetDependents() []*Dependency

func (*SearchResponse) GetModules added in v0.1.9 

func (m *SearchResponse) GetModules() []*ManagedModule

func (*SearchResponse) GetRequest added in v0.1.9 

func (m *SearchResponse) GetRequest() *SearchRequest

func (*SearchResponse) GetSources added in v0.1.9 

func (m *SearchResponse) GetSources() []*ManagedSource

func (*SearchResponse) ProtoMessage added in v0.1.9 

func (*SearchResponse) ProtoMessage()

func (*SearchResponse) Reset added in v0.1.9 

func (m *SearchResponse) Reset()

func (*SearchResponse) String added in v0.1.9 

func (m *SearchResponse) String() string

func (*SearchResponse) XXX_DiscardUnknown added in v0.1.9 

func (m *SearchResponse) XXX_DiscardUnknown()

func (*SearchResponse) XXX_Marshal added in v0.1.9 

func (m *SearchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SearchResponse) XXX_Merge added in v0.1.9 

func (m *SearchResponse) XXX_Merge(src proto.Message)

func (*SearchResponse) XXX_Size added in v0.1.9 

func (m *SearchResponse) XXX_Size() int

func (*SearchResponse) XXX_Unmarshal added in v0.1.9 

func (m *SearchResponse) XXX_Unmarshal(b []byte) error

type SearchServiceClient added in v0.1.9 

type SearchServiceClient interface {
	Search(ctx context.Context, opts ...grpc.CallOption) (SearchService_SearchClient, error)
	BreadthFirstSearch(ctx context.Context, opts ...grpc.CallOption) (SearchService_BreadthFirstSearchClient, error)
	DepthFirstSearch(ctx context.Context, opts ...grpc.CallOption) (SearchService_DepthFirstSearchClient, error)
}

SearchServiceClient is the client API for SearchService service.

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

func NewSearchServiceClient added in v0.1.9 

func NewSearchServiceClient(cc *grpc.ClientConn) SearchServiceClient

type SearchServiceServer added in v0.1.9 

type SearchServiceServer interface {
	Search(SearchService_SearchServer) error
	BreadthFirstSearch(SearchService_BreadthFirstSearchServer) error
	DepthFirstSearch(SearchService_DepthFirstSearchServer) error
}

SearchServiceServer is the server API for SearchService service.

type SearchService_BreadthFirstSearchClient added in v0.1.9 

type SearchService_BreadthFirstSearchClient interface {
	Send(*SearchRequest) error
	Recv() (*SearchResponse, error)
	grpc.ClientStream
}

type SearchService_BreadthFirstSearchServer added in v0.1.9 

type SearchService_BreadthFirstSearchServer interface {
	Send(*SearchResponse) error
	Recv() (*SearchRequest, error)
	grpc.ServerStream
}

type SearchService_DepthFirstSearchClient added in v0.1.9 

type SearchService_DepthFirstSearchClient interface {
	Send(*SearchRequest) error
	Recv() (*SearchResponse, error)
	grpc.ClientStream
}

type SearchService_DepthFirstSearchServer added in v0.1.9 

type SearchService_DepthFirstSearchServer interface {
	Send(*SearchResponse) error
	Recv() (*SearchRequest, error)
	grpc.ServerStream
}

type SearchService_SearchClient added in v0.1.9 

type SearchService_SearchClient interface {
	Send(*SearchRequest) error
	Recv() (*SearchResponse, error)
	grpc.ClientStream
}

type SearchService_SearchServer added in v0.1.9 

type SearchService_SearchServer interface {
	Send(*SearchResponse) error
	Recv() (*SearchRequest, error)
	grpc.ServerStream
}

type SourceRequest 

type SourceRequest struct {
	Source               *schema.Source                   `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	ManagementFiles      []*deps.DependencyManagementFile `protobuf:"bytes,2,rep,name=managementFiles,proto3" json:"managementFiles,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*SourceRequest) Descriptor 

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

func (*SourceRequest) GetManagementFiles 

func (m *SourceRequest) GetManagementFiles() []*deps.DependencyManagementFile

func (*SourceRequest) GetSource 

func (m *SourceRequest) GetSource() *schema.Source

func (*SourceRequest) ProtoMessage 

func (*SourceRequest) ProtoMessage()

func (*SourceRequest) Reset 

func (m *SourceRequest) Reset()

func (*SourceRequest) String 

func (m *SourceRequest) String() string

func (*SourceRequest) XXX_DiscardUnknown 

func (m *SourceRequest) XXX_DiscardUnknown()

func (*SourceRequest) XXX_Marshal 

func (m *SourceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SourceRequest) XXX_Merge 

func (m *SourceRequest) XXX_Merge(src proto.Message)

func (*SourceRequest) XXX_Size 

func (m *SourceRequest) XXX_Size() int

func (*SourceRequest) XXX_Unmarshal 

func (m *SourceRequest) XXX_Unmarshal(b []byte) error

type SourceServiceClient 

type SourceServiceClient interface {
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListSourceResponse, error)
	Track(ctx context.Context, in *SourceRequest, opts ...grpc.CallOption) (*TrackResponse, error)
}

SourceServiceClient is the client API for SourceService service.

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

func NewSourceServiceClient 

func NewSourceServiceClient(cc *grpc.ClientConn) SourceServiceClient

type SourceServiceServer 

type SourceServiceServer interface {
	List(context.Context, *ListRequest) (*ListSourceResponse, error)
	Track(context.Context, *SourceRequest) (*TrackResponse, error)
}

SourceServiceServer is the server API for SourceService service.

type TrackResponse 

type TrackResponse struct {
	Tracking             bool     `protobuf:"varint,1,opt,name=tracking,proto3" json:"tracking,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TrackResponse) Descriptor 

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

func (*TrackResponse) GetTracking 

func (m *TrackResponse) GetTracking() bool

func (*TrackResponse) ProtoMessage 

func (*TrackResponse) ProtoMessage()

func (*TrackResponse) Reset 

func (m *TrackResponse) Reset()

func (*TrackResponse) String 

func (m *TrackResponse) String() string

func (*TrackResponse) XXX_DiscardUnknown 

func (m *TrackResponse) XXX_DiscardUnknown()

func (*TrackResponse) XXX_Marshal 

func (m *TrackResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TrackResponse) XXX_Merge 

func (m *TrackResponse) XXX_Merge(src proto.Message)

func (*TrackResponse) XXX_Size 

func (m *TrackResponse) XXX_Size() int

func (*TrackResponse) XXX_Unmarshal 

func (m *TrackResponse) XXX_Unmarshal(b []byte) error

type UnimplementedDependencyServiceServer 

type UnimplementedDependencyServiceServer struct {
}

UnimplementedDependencyServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDependencyServiceServer) ListDependencies 

func (*UnimplementedDependencyServiceServer) ListDependencies(ctx context.Context, req *DependencyRequest) (*ListDependenciesResponse, error)

func (*UnimplementedDependencyServiceServer) ListDependents 

func (*UnimplementedDependencyServiceServer) ListDependents(ctx context.Context, req *DependencyRequest) (*ListDependentsResponse, error)

type UnimplementedModuleServiceServer 

type UnimplementedModuleServiceServer struct {
}

UnimplementedModuleServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedModuleServiceServer) List 

func (*UnimplementedModuleServiceServer) List(ctx context.Context, req *ListRequest) (*ListModuleResponse, error)

func (*UnimplementedModuleServiceServer) ListManaged 

func (*UnimplementedModuleServiceServer) ListManaged(ctx context.Context, req *schema.Source) (*ListManagedResponse, error)

func (*UnimplementedModuleServiceServer) ListSources 

func (*UnimplementedModuleServiceServer) ListSources(ctx context.Context, req *schema.Module) (*ListSourcesResponse, error)

type UnimplementedSearchServiceServer added in v0.1.9 

type UnimplementedSearchServiceServer struct {
}

UnimplementedSearchServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSearchServiceServer) BreadthFirstSearch added in v0.1.9 

func (*UnimplementedSearchServiceServer) BreadthFirstSearch(srv SearchService_BreadthFirstSearchServer) error

func (*UnimplementedSearchServiceServer) DepthFirstSearch added in v0.1.9 

func (*UnimplementedSearchServiceServer) DepthFirstSearch(srv SearchService_DepthFirstSearchServer) error

func (*UnimplementedSearchServiceServer) Search added in v0.1.9 

func (*UnimplementedSearchServiceServer) Search(srv SearchService_SearchServer) error

type UnimplementedSourceServiceServer 

type UnimplementedSourceServiceServer struct {
}

UnimplementedSourceServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSourceServiceServer) List 

func (*UnimplementedSourceServiceServer) List(ctx context.Context, req *ListRequest) (*ListSourceResponse, error)

func (*UnimplementedSourceServiceServer) Track 

func (*UnimplementedSourceServiceServer) Track(ctx context.Context, req *SourceRequest) (*TrackResponse, 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.