rpc

package
v0.6.1 Latest Latest
Warning

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

 Go to latest Published: Aug 16, 2025 License: MIT Imports: 33 Imported by: 14

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	// ErrNameAlreadyTaken is returned when the request name is already taken by another mirror
	ErrNameAlreadyTaken = errors.New("name already taken")
)
View Source 
var ScanMirrorRequest_Method_name = map[int32]string{
	0: "ALL",
	1: "FTP",
	2: "RSYNC",
}
View Source 
var ScanMirrorRequest_Method_value = map[string]int32{
	"ALL":   0,
	"FTP":   1,
	"RSYNC": 2,
}

Functions

func MirrorFromRPC 

func MirrorFromRPC(m *Mirror) (*mirrors.Mirror, error)

func RegisterCLIServer added in v0.6.1 

func RegisterCLIServer(s *grpc.Server, srv CLIServer)

func StreamInterceptor 

func StreamInterceptor(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error

func UnaryInterceptor 

func UnaryInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)

Types

type AddMirrorReply added in v0.6.1 

type AddMirrorReply struct {
	Latitude             float32  `protobuf:"fixed32,1,opt,name=Latitude,proto3" json:"Latitude,omitempty"`
	Longitude            float32  `protobuf:"fixed32,2,opt,name=Longitude,proto3" json:"Longitude,omitempty"`
	Country              string   `protobuf:"bytes,3,opt,name=Country,proto3" json:"Country,omitempty"`
	Continent            string   `protobuf:"bytes,4,opt,name=Continent,proto3" json:"Continent,omitempty"`
	ASN                  string   `protobuf:"bytes,5,opt,name=ASN,proto3" json:"ASN,omitempty"`
	Warnings             []string `protobuf:"bytes,6,rep,name=Warnings,proto3" json:"Warnings,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddMirrorReply) Descriptor added in v0.6.1 

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

func (*AddMirrorReply) GetASN added in v0.6.1 

func (m *AddMirrorReply) GetASN() string

func (*AddMirrorReply) GetContinent added in v0.6.1 

func (m *AddMirrorReply) GetContinent() string

func (*AddMirrorReply) GetCountry added in v0.6.1 

func (m *AddMirrorReply) GetCountry() string

func (*AddMirrorReply) GetLatitude added in v0.6.1 

func (m *AddMirrorReply) GetLatitude() float32

func (*AddMirrorReply) GetLongitude added in v0.6.1 

func (m *AddMirrorReply) GetLongitude() float32

func (*AddMirrorReply) GetWarnings added in v0.6.1 

func (m *AddMirrorReply) GetWarnings() []string

func (*AddMirrorReply) ProtoMessage added in v0.6.1 

func (*AddMirrorReply) ProtoMessage()

func (*AddMirrorReply) Reset added in v0.6.1 

func (m *AddMirrorReply) Reset()

func (*AddMirrorReply) String added in v0.6.1 

func (m *AddMirrorReply) String() string

func (*AddMirrorReply) XXX_DiscardUnknown added in v0.6.1 

func (m *AddMirrorReply) XXX_DiscardUnknown()

func (*AddMirrorReply) XXX_Marshal added in v0.6.1 

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

func (*AddMirrorReply) XXX_Merge added in v0.6.1 

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

func (*AddMirrorReply) XXX_Size added in v0.6.1 

func (m *AddMirrorReply) XXX_Size() int

func (*AddMirrorReply) XXX_Unmarshal added in v0.6.1 

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

type CLI 

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

CLI object handles the server side RPC of the CLI

func (*CLI) AddMirror 

func (c *CLI) AddMirror(ctx context.Context, in *Mirror) (*AddMirrorReply, error)

func (*CLI) ChangeStatus 

func (c *CLI) ChangeStatus(ctx context.Context, in *ChangeStatusRequest) (*empty.Empty, error)

func (*CLI) Close 

func (c *CLI) Close() error

func (*CLI) GeoUpdateMirror added in v0.6.1 

func (c *CLI) GeoUpdateMirror(ctx context.Context, in *MirrorIDRequest) (*GeoUpdateMirrorReply, error)

func (*CLI) GetMirrorLogs added in v0.6.1 

func (c *CLI) GetMirrorLogs(ctx context.Context, in *GetMirrorLogsRequest) (*GetMirrorLogsReply, error)

func (*CLI) GetVersion 

func (c *CLI) GetVersion(context.Context, *empty.Empty) (*VersionReply, error)

func (*CLI) List 

func (c *CLI) List(ctx context.Context, in *empty.Empty) (*MirrorListReply, error)

func (*CLI) MatchMirror 

func (c *CLI) MatchMirror(ctx context.Context, in *MatchRequest) (*MatchReply, error)

func (*CLI) MirrorInfo 

func (c *CLI) MirrorInfo(ctx context.Context, in *MirrorIDRequest) (*Mirror, error)

func (*CLI) Ping 

func (c *CLI) Ping(context.Context, *empty.Empty) (*empty.Empty, error)

func (*CLI) RefreshRepository 

func (c *CLI) RefreshRepository(ctx context.Context, in *RefreshRepositoryRequest) (*empty.Empty, error)

func (*CLI) Reload 

func (c *CLI) Reload(ctx context.Context, in *empty.Empty) (*empty.Empty, error)

func (*CLI) RemoveMirror 

func (c *CLI) RemoveMirror(ctx context.Context, in *MirrorIDRequest) (*empty.Empty, error)

func (*CLI) ScanMirror 

func (c *CLI) ScanMirror(ctx context.Context, in *ScanMirrorRequest) (*ScanMirrorReply, error)

func (*CLI) SetCache added in v0.6.1 

func (c *CLI) SetCache(cache *mirrors.Cache)

func (*CLI) SetDatabase 

func (c *CLI) SetDatabase(r *database.Redis)

func (*CLI) SetSignals 

func (c *CLI) SetSignals(sig chan<- os.Signal)

func (*CLI) Start 

func (c *CLI) Start() error

func (*CLI) StatsFile 

func (c *CLI) StatsFile(ctx context.Context, in *StatsFileRequest) (*StatsFileReply, error)

func (*CLI) StatsMirror 

func (c *CLI) StatsMirror(ctx context.Context, in *StatsMirrorRequest) (*StatsMirrorReply, error)

func (*CLI) UpdateMirror 

func (c *CLI) UpdateMirror(ctx context.Context, in *Mirror) (*UpdateMirrorReply, error)

func (*CLI) Upgrade 

func (c *CLI) Upgrade(ctx context.Context, in *empty.Empty) (*empty.Empty, error)

type CLIClient added in v0.6.1 

type CLIClient interface {
	GetVersion(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*VersionReply, error)
	Upgrade(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	Reload(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	ChangeStatus(ctx context.Context, in *ChangeStatusRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	List(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*MirrorListReply, error)
	MirrorInfo(ctx context.Context, in *MirrorIDRequest, opts ...grpc.CallOption) (*Mirror, error)
	AddMirror(ctx context.Context, in *Mirror, opts ...grpc.CallOption) (*AddMirrorReply, error)
	UpdateMirror(ctx context.Context, in *Mirror, opts ...grpc.CallOption) (*UpdateMirrorReply, error)
	RemoveMirror(ctx context.Context, in *MirrorIDRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	GeoUpdateMirror(ctx context.Context, in *MirrorIDRequest, opts ...grpc.CallOption) (*GeoUpdateMirrorReply, error)
	RefreshRepository(ctx context.Context, in *RefreshRepositoryRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	ScanMirror(ctx context.Context, in *ScanMirrorRequest, opts ...grpc.CallOption) (*ScanMirrorReply, error)
	StatsFile(ctx context.Context, in *StatsFileRequest, opts ...grpc.CallOption) (*StatsFileReply, error)
	StatsMirror(ctx context.Context, in *StatsMirrorRequest, opts ...grpc.CallOption) (*StatsMirrorReply, error)
	Ping(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	GetMirrorLogs(ctx context.Context, in *GetMirrorLogsRequest, opts ...grpc.CallOption) (*GetMirrorLogsReply, error)
	// Tools
	MatchMirror(ctx context.Context, in *MatchRequest, opts ...grpc.CallOption) (*MatchReply, error)
}

CLIClient is the client API for CLI service.

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

func NewCLIClient added in v0.6.1 

func NewCLIClient(cc grpc.ClientConnInterface) CLIClient

type CLIServer added in v0.6.1 

type CLIServer interface {
	GetVersion(context.Context, *empty.Empty) (*VersionReply, error)
	Upgrade(context.Context, *empty.Empty) (*empty.Empty, error)
	Reload(context.Context, *empty.Empty) (*empty.Empty, error)
	ChangeStatus(context.Context, *ChangeStatusRequest) (*empty.Empty, error)
	List(context.Context, *empty.Empty) (*MirrorListReply, error)
	MirrorInfo(context.Context, *MirrorIDRequest) (*Mirror, error)
	AddMirror(context.Context, *Mirror) (*AddMirrorReply, error)
	UpdateMirror(context.Context, *Mirror) (*UpdateMirrorReply, error)
	RemoveMirror(context.Context, *MirrorIDRequest) (*empty.Empty, error)
	GeoUpdateMirror(context.Context, *MirrorIDRequest) (*GeoUpdateMirrorReply, error)
	RefreshRepository(context.Context, *RefreshRepositoryRequest) (*empty.Empty, error)
	ScanMirror(context.Context, *ScanMirrorRequest) (*ScanMirrorReply, error)
	StatsFile(context.Context, *StatsFileRequest) (*StatsFileReply, error)
	StatsMirror(context.Context, *StatsMirrorRequest) (*StatsMirrorReply, error)
	Ping(context.Context, *empty.Empty) (*empty.Empty, error)
	GetMirrorLogs(context.Context, *GetMirrorLogsRequest) (*GetMirrorLogsReply, error)
	// Tools
	MatchMirror(context.Context, *MatchRequest) (*MatchReply, error)
}

CLIServer is the server API for CLI service.

type ChangeStatusRequest added in v0.6.1 

type ChangeStatusRequest struct {
	ID                   int32    `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Enabled              bool     `protobuf:"varint,2,opt,name=Enabled,proto3" json:"Enabled,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ChangeStatusRequest) Descriptor added in v0.6.1 

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

func (*ChangeStatusRequest) GetEnabled added in v0.6.1 

func (m *ChangeStatusRequest) GetEnabled() bool

func (*ChangeStatusRequest) GetID added in v0.6.1 

func (m *ChangeStatusRequest) GetID() int32

func (*ChangeStatusRequest) ProtoMessage added in v0.6.1 

func (*ChangeStatusRequest) ProtoMessage()

func (*ChangeStatusRequest) Reset added in v0.6.1 

func (m *ChangeStatusRequest) Reset()

func (*ChangeStatusRequest) String added in v0.6.1 

func (m *ChangeStatusRequest) String() string

func (*ChangeStatusRequest) XXX_DiscardUnknown added in v0.6.1 

func (m *ChangeStatusRequest) XXX_DiscardUnknown()

func (*ChangeStatusRequest) XXX_Marshal added in v0.6.1 

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

func (*ChangeStatusRequest) XXX_Merge added in v0.6.1 

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

func (*ChangeStatusRequest) XXX_Size added in v0.6.1 

func (m *ChangeStatusRequest) XXX_Size() int

func (*ChangeStatusRequest) XXX_Unmarshal added in v0.6.1 

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

type GeoUpdateMirrorReply added in v0.6.1 

type GeoUpdateMirrorReply struct {
	Mirror               *Mirror  `protobuf:"bytes,1,opt,name=Mirror,proto3" json:"Mirror,omitempty"`
	Diff                 string   `protobuf:"bytes,2,opt,name=Diff,proto3" json:"Diff,omitempty"`
	Warnings             []string `protobuf:"bytes,3,rep,name=Warnings,proto3" json:"Warnings,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GeoUpdateMirrorReply) Descriptor added in v0.6.1 

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

func (*GeoUpdateMirrorReply) GetDiff added in v0.6.1 

func (m *GeoUpdateMirrorReply) GetDiff() string

func (*GeoUpdateMirrorReply) GetMirror added in v0.6.1 

func (m *GeoUpdateMirrorReply) GetMirror() *Mirror

func (*GeoUpdateMirrorReply) GetWarnings added in v0.6.1 

func (m *GeoUpdateMirrorReply) GetWarnings() []string

func (*GeoUpdateMirrorReply) ProtoMessage added in v0.6.1 

func (*GeoUpdateMirrorReply) ProtoMessage()

func (*GeoUpdateMirrorReply) Reset added in v0.6.1 

func (m *GeoUpdateMirrorReply) Reset()

func (*GeoUpdateMirrorReply) String added in v0.6.1 

func (m *GeoUpdateMirrorReply) String() string

func (*GeoUpdateMirrorReply) XXX_DiscardUnknown added in v0.6.1 

func (m *GeoUpdateMirrorReply) XXX_DiscardUnknown()

func (*GeoUpdateMirrorReply) XXX_Marshal added in v0.6.1 

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

func (*GeoUpdateMirrorReply) XXX_Merge added in v0.6.1 

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

func (*GeoUpdateMirrorReply) XXX_Size added in v0.6.1 

func (m *GeoUpdateMirrorReply) XXX_Size() int

func (*GeoUpdateMirrorReply) XXX_Unmarshal added in v0.6.1 

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

type GetMirrorLogsReply added in v0.6.1 

type GetMirrorLogsReply struct {
	Line                 []string `protobuf:"bytes,1,rep,name=line,proto3" json:"line,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetMirrorLogsReply) Descriptor added in v0.6.1 

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

func (*GetMirrorLogsReply) GetLine added in v0.6.1 

func (m *GetMirrorLogsReply) GetLine() []string

func (*GetMirrorLogsReply) ProtoMessage added in v0.6.1 

func (*GetMirrorLogsReply) ProtoMessage()

func (*GetMirrorLogsReply) Reset added in v0.6.1 

func (m *GetMirrorLogsReply) Reset()

func (*GetMirrorLogsReply) String added in v0.6.1 

func (m *GetMirrorLogsReply) String() string

func (*GetMirrorLogsReply) XXX_DiscardUnknown added in v0.6.1 

func (m *GetMirrorLogsReply) XXX_DiscardUnknown()

func (*GetMirrorLogsReply) XXX_Marshal added in v0.6.1 

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

func (*GetMirrorLogsReply) XXX_Merge added in v0.6.1 

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

func (*GetMirrorLogsReply) XXX_Size added in v0.6.1 

func (m *GetMirrorLogsReply) XXX_Size() int

func (*GetMirrorLogsReply) XXX_Unmarshal added in v0.6.1 

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

type GetMirrorLogsRequest added in v0.6.1 

type GetMirrorLogsRequest struct {
	ID                   int32    `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	MaxResults           int32    `protobuf:"varint,2,opt,name=MaxResults,proto3" json:"MaxResults,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetMirrorLogsRequest) Descriptor added in v0.6.1 

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

func (*GetMirrorLogsRequest) GetID added in v0.6.1 

func (m *GetMirrorLogsRequest) GetID() int32

func (*GetMirrorLogsRequest) GetMaxResults added in v0.6.1 

func (m *GetMirrorLogsRequest) GetMaxResults() int32

func (*GetMirrorLogsRequest) ProtoMessage added in v0.6.1 

func (*GetMirrorLogsRequest) ProtoMessage()

func (*GetMirrorLogsRequest) Reset added in v0.6.1 

func (m *GetMirrorLogsRequest) Reset()

func (*GetMirrorLogsRequest) String added in v0.6.1 

func (m *GetMirrorLogsRequest) String() string

func (*GetMirrorLogsRequest) XXX_DiscardUnknown added in v0.6.1 

func (m *GetMirrorLogsRequest) XXX_DiscardUnknown()

func (*GetMirrorLogsRequest) XXX_Marshal added in v0.6.1 

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

func (*GetMirrorLogsRequest) XXX_Merge added in v0.6.1 

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

func (*GetMirrorLogsRequest) XXX_Size added in v0.6.1 

func (m *GetMirrorLogsRequest) XXX_Size() int

func (*GetMirrorLogsRequest) XXX_Unmarshal added in v0.6.1 

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

type MatchReply added in v0.6.1 

type MatchReply struct {
	Mirrors              []*MirrorID `protobuf:"bytes,1,rep,name=Mirrors,proto3" json:"Mirrors,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*MatchReply) Descriptor added in v0.6.1 

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

func (*MatchReply) GetMirrors added in v0.6.1 

func (m *MatchReply) GetMirrors() []*MirrorID

func (*MatchReply) ProtoMessage added in v0.6.1 

func (*MatchReply) ProtoMessage()

func (*MatchReply) Reset added in v0.6.1 

func (m *MatchReply) Reset()

func (*MatchReply) String added in v0.6.1 

func (m *MatchReply) String() string

func (*MatchReply) XXX_DiscardUnknown added in v0.6.1 

func (m *MatchReply) XXX_DiscardUnknown()

func (*MatchReply) XXX_Marshal added in v0.6.1 

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

func (*MatchReply) XXX_Merge added in v0.6.1 

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

func (*MatchReply) XXX_Size added in v0.6.1 

func (m *MatchReply) XXX_Size() int

func (*MatchReply) XXX_Unmarshal added in v0.6.1 

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

type MatchRequest added in v0.6.1 

type MatchRequest struct {
	Pattern              string   `protobuf:"bytes,1,opt,name=Pattern,proto3" json:"Pattern,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MatchRequest) Descriptor added in v0.6.1 

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

func (*MatchRequest) GetPattern added in v0.6.1 

func (m *MatchRequest) GetPattern() string

func (*MatchRequest) ProtoMessage added in v0.6.1 

func (*MatchRequest) ProtoMessage()

func (*MatchRequest) Reset added in v0.6.1 

func (m *MatchRequest) Reset()

func (*MatchRequest) String added in v0.6.1 

func (m *MatchRequest) String() string

func (*MatchRequest) XXX_DiscardUnknown added in v0.6.1 

func (m *MatchRequest) XXX_DiscardUnknown()

func (*MatchRequest) XXX_Marshal added in v0.6.1 

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

func (*MatchRequest) XXX_Merge added in v0.6.1 

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

func (*MatchRequest) XXX_Size added in v0.6.1 

func (m *MatchRequest) XXX_Size() int

func (*MatchRequest) XXX_Unmarshal added in v0.6.1 

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

type Mirror added in v0.6.1 

type Mirror struct {
	ID                   int32                `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Name                 string               `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
	HttpURL              string               `protobuf:"bytes,3,opt,name=HttpURL,proto3" json:"HttpURL,omitempty"`
	RsyncURL             string               `protobuf:"bytes,4,opt,name=RsyncURL,proto3" json:"RsyncURL,omitempty"`
	FtpURL               string               `protobuf:"bytes,5,opt,name=FtpURL,proto3" json:"FtpURL,omitempty"`
	SponsorName          string               `protobuf:"bytes,6,opt,name=SponsorName,proto3" json:"SponsorName,omitempty"`
	SponsorURL           string               `protobuf:"bytes,7,opt,name=SponsorURL,proto3" json:"SponsorURL,omitempty"`
	SponsorLogoURL       string               `protobuf:"bytes,8,opt,name=SponsorLogoURL,proto3" json:"SponsorLogoURL,omitempty"`
	AdminName            string               `protobuf:"bytes,9,opt,name=AdminName,proto3" json:"AdminName,omitempty"`
	AdminEmail           string               `protobuf:"bytes,10,opt,name=AdminEmail,proto3" json:"AdminEmail,omitempty"`
	CustomData           string               `protobuf:"bytes,11,opt,name=CustomData,proto3" json:"CustomData,omitempty"`
	ContinentOnly        bool                 `protobuf:"varint,12,opt,name=ContinentOnly,proto3" json:"ContinentOnly,omitempty"`
	CountryOnly          bool                 `protobuf:"varint,13,opt,name=CountryOnly,proto3" json:"CountryOnly,omitempty"`
	ASOnly               bool                 `protobuf:"varint,14,opt,name=ASOnly,proto3" json:"ASOnly,omitempty"`
	Score                int32                `protobuf:"varint,15,opt,name=Score,proto3" json:"Score,omitempty"`
	Latitude             float32              `protobuf:"fixed32,16,opt,name=Latitude,proto3" json:"Latitude,omitempty"`
	Longitude            float32              `protobuf:"fixed32,17,opt,name=Longitude,proto3" json:"Longitude,omitempty"`
	ContinentCode        string               `protobuf:"bytes,18,opt,name=ContinentCode,proto3" json:"ContinentCode,omitempty"`
	CountryCodes         string               `protobuf:"bytes,19,opt,name=CountryCodes,proto3" json:"CountryCodes,omitempty"`
	ExcludedCountryCodes string               `protobuf:"bytes,20,opt,name=ExcludedCountryCodes,proto3" json:"ExcludedCountryCodes,omitempty"`
	Asnum                uint32               `protobuf:"varint,21,opt,name=Asnum,proto3" json:"Asnum,omitempty"`
	Comment              string               `protobuf:"bytes,22,opt,name=Comment,proto3" json:"Comment,omitempty"`
	Enabled              bool                 `protobuf:"varint,23,opt,name=Enabled,proto3" json:"Enabled,omitempty"`
	HttpUp               bool                 `protobuf:"varint,24,opt,name=HttpUp,proto3" json:"HttpUp,omitempty"`
	HttpDownReason       string               `protobuf:"bytes,25,opt,name=HttpDownReason,proto3" json:"HttpDownReason,omitempty"`
	StateSince           *timestamp.Timestamp `protobuf:"bytes,26,opt,name=StateSince,proto3" json:"StateSince,omitempty"`
	AllowRedirects       int32                `protobuf:"varint,27,opt,name=AllowRedirects,proto3" json:"AllowRedirects,omitempty"`
	LastSync             *timestamp.Timestamp `protobuf:"bytes,28,opt,name=LastSync,proto3" json:"LastSync,omitempty"`
	LastSuccessfulSync   *timestamp.Timestamp `protobuf:"bytes,29,opt,name=LastSuccessfulSync,proto3" json:"LastSuccessfulSync,omitempty"`
	LastModTime          *timestamp.Timestamp `protobuf:"bytes,30,opt,name=LastModTime,proto3" json:"LastModTime,omitempty"`
	HttpsUp              bool                 `protobuf:"varint,31,opt,name=HttpsUp,proto3" json:"HttpsUp,omitempty"`
	HttpsDownReason      string               `protobuf:"bytes,32,opt,name=HttpsDownReason,proto3" json:"HttpsDownReason,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func MirrorToRPC 

func MirrorToRPC(m *mirrors.Mirror) (*Mirror, error)

func (*Mirror) Descriptor added in v0.6.1 

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

func (*Mirror) GetASOnly added in v0.6.1 

func (m *Mirror) GetASOnly() bool

func (*Mirror) GetAdminEmail added in v0.6.1 

func (m *Mirror) GetAdminEmail() string

func (*Mirror) GetAdminName added in v0.6.1 

func (m *Mirror) GetAdminName() string

func (*Mirror) GetAllowRedirects added in v0.6.1 

func (m *Mirror) GetAllowRedirects() int32

func (*Mirror) GetAsnum added in v0.6.1 

func (m *Mirror) GetAsnum() uint32

func (*Mirror) GetComment added in v0.6.1 

func (m *Mirror) GetComment() string

func (*Mirror) GetContinentCode added in v0.6.1 

func (m *Mirror) GetContinentCode() string

func (*Mirror) GetContinentOnly added in v0.6.1 

func (m *Mirror) GetContinentOnly() bool

func (*Mirror) GetCountryCodes added in v0.6.1 

func (m *Mirror) GetCountryCodes() string

func (*Mirror) GetCountryOnly added in v0.6.1 

func (m *Mirror) GetCountryOnly() bool

func (*Mirror) GetCustomData added in v0.6.1 

func (m *Mirror) GetCustomData() string

func (*Mirror) GetEnabled added in v0.6.1 

func (m *Mirror) GetEnabled() bool

func (*Mirror) GetExcludedCountryCodes added in v0.6.1 

func (m *Mirror) GetExcludedCountryCodes() string

func (*Mirror) GetFtpURL added in v0.6.1 

func (m *Mirror) GetFtpURL() string

func (*Mirror) GetHttpDownReason added in v0.6.1 

func (m *Mirror) GetHttpDownReason() string

func (*Mirror) GetHttpURL added in v0.6.1 

func (m *Mirror) GetHttpURL() string

func (*Mirror) GetHttpUp added in v0.6.1 

func (m *Mirror) GetHttpUp() bool

func (*Mirror) GetHttpsDownReason added in v0.6.1 

func (m *Mirror) GetHttpsDownReason() string

func (*Mirror) GetHttpsUp added in v0.6.1 

func (m *Mirror) GetHttpsUp() bool

func (*Mirror) GetID added in v0.6.1 

func (m *Mirror) GetID() int32

func (*Mirror) GetLastModTime added in v0.6.1 

func (m *Mirror) GetLastModTime() *timestamp.Timestamp

func (*Mirror) GetLastSuccessfulSync added in v0.6.1 

func (m *Mirror) GetLastSuccessfulSync() *timestamp.Timestamp

func (*Mirror) GetLastSync added in v0.6.1 

func (m *Mirror) GetLastSync() *timestamp.Timestamp

func (*Mirror) GetLatitude added in v0.6.1 

func (m *Mirror) GetLatitude() float32

func (*Mirror) GetLongitude added in v0.6.1 

func (m *Mirror) GetLongitude() float32

func (*Mirror) GetName added in v0.6.1 

func (m *Mirror) GetName() string

func (*Mirror) GetRsyncURL added in v0.6.1 

func (m *Mirror) GetRsyncURL() string

func (*Mirror) GetScore added in v0.6.1 

func (m *Mirror) GetScore() int32

func (*Mirror) GetSponsorLogoURL added in v0.6.1 

func (m *Mirror) GetSponsorLogoURL() string

func (*Mirror) GetSponsorName added in v0.6.1 

func (m *Mirror) GetSponsorName() string

func (*Mirror) GetSponsorURL added in v0.6.1 

func (m *Mirror) GetSponsorURL() string

func (*Mirror) GetStateSince added in v0.6.1 

func (m *Mirror) GetStateSince() *timestamp.Timestamp

func (*Mirror) ProtoMessage added in v0.6.1 

func (*Mirror) ProtoMessage()

func (*Mirror) Reset added in v0.6.1 

func (m *Mirror) Reset()

func (*Mirror) String added in v0.6.1 

func (m *Mirror) String() string

func (*Mirror) XXX_DiscardUnknown added in v0.6.1 

func (m *Mirror) XXX_DiscardUnknown()

func (*Mirror) XXX_Marshal added in v0.6.1 

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

func (*Mirror) XXX_Merge added in v0.6.1 

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

func (*Mirror) XXX_Size added in v0.6.1 

func (m *Mirror) XXX_Size() int

func (*Mirror) XXX_Unmarshal added in v0.6.1 

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

type MirrorID added in v0.6.1 

type MirrorID struct {
	ID                   int32    `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MirrorID) Descriptor added in v0.6.1 

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

func (*MirrorID) GetID added in v0.6.1 

func (m *MirrorID) GetID() int32

func (*MirrorID) GetName added in v0.6.1 

func (m *MirrorID) GetName() string

func (*MirrorID) ProtoMessage added in v0.6.1 

func (*MirrorID) ProtoMessage()

func (*MirrorID) Reset added in v0.6.1 

func (m *MirrorID) Reset()

func (*MirrorID) String added in v0.6.1 

func (m *MirrorID) String() string

func (*MirrorID) XXX_DiscardUnknown added in v0.6.1 

func (m *MirrorID) XXX_DiscardUnknown()

func (*MirrorID) XXX_Marshal added in v0.6.1 

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

func (*MirrorID) XXX_Merge added in v0.6.1 

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

func (*MirrorID) XXX_Size added in v0.6.1 

func (m *MirrorID) XXX_Size() int

func (*MirrorID) XXX_Unmarshal added in v0.6.1 

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

type MirrorIDRequest added in v0.6.1 

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

func (*MirrorIDRequest) Descriptor added in v0.6.1 

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

func (*MirrorIDRequest) GetID added in v0.6.1 

func (m *MirrorIDRequest) GetID() int32

func (*MirrorIDRequest) ProtoMessage added in v0.6.1 

func (*MirrorIDRequest) ProtoMessage()

func (*MirrorIDRequest) Reset added in v0.6.1 

func (m *MirrorIDRequest) Reset()

func (*MirrorIDRequest) String added in v0.6.1 

func (m *MirrorIDRequest) String() string

func (*MirrorIDRequest) XXX_DiscardUnknown added in v0.6.1 

func (m *MirrorIDRequest) XXX_DiscardUnknown()

func (*MirrorIDRequest) XXX_Marshal added in v0.6.1 

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

func (*MirrorIDRequest) XXX_Merge added in v0.6.1 

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

func (*MirrorIDRequest) XXX_Size added in v0.6.1 

func (m *MirrorIDRequest) XXX_Size() int

func (*MirrorIDRequest) XXX_Unmarshal added in v0.6.1 

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

type MirrorListReply added in v0.6.1 

type MirrorListReply struct {
	Mirrors              []*Mirror `protobuf:"bytes,1,rep,name=Mirrors,proto3" json:"Mirrors,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*MirrorListReply) Descriptor added in v0.6.1 

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

func (*MirrorListReply) GetMirrors added in v0.6.1 

func (m *MirrorListReply) GetMirrors() []*Mirror

func (*MirrorListReply) ProtoMessage added in v0.6.1 

func (*MirrorListReply) ProtoMessage()

func (*MirrorListReply) Reset added in v0.6.1 

func (m *MirrorListReply) Reset()

func (*MirrorListReply) String added in v0.6.1 

func (m *MirrorListReply) String() string

func (*MirrorListReply) XXX_DiscardUnknown added in v0.6.1 

func (m *MirrorListReply) XXX_DiscardUnknown()

func (*MirrorListReply) XXX_Marshal added in v0.6.1 

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

func (*MirrorListReply) XXX_Merge added in v0.6.1 

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

func (*MirrorListReply) XXX_Size added in v0.6.1 

func (m *MirrorListReply) XXX_Size() int

func (*MirrorListReply) XXX_Unmarshal added in v0.6.1 

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

type RefreshRepositoryRequest added in v0.6.1 

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

func (*RefreshRepositoryRequest) Descriptor added in v0.6.1 

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

func (*RefreshRepositoryRequest) GetRehash added in v0.6.1 

func (m *RefreshRepositoryRequest) GetRehash() bool

func (*RefreshRepositoryRequest) ProtoMessage added in v0.6.1 

func (*RefreshRepositoryRequest) ProtoMessage()

func (*RefreshRepositoryRequest) Reset added in v0.6.1 

func (m *RefreshRepositoryRequest) Reset()

func (*RefreshRepositoryRequest) String added in v0.6.1 

func (m *RefreshRepositoryRequest) String() string

func (*RefreshRepositoryRequest) XXX_DiscardUnknown added in v0.6.1 

func (m *RefreshRepositoryRequest) XXX_DiscardUnknown()

func (*RefreshRepositoryRequest) XXX_Marshal added in v0.6.1 

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

func (*RefreshRepositoryRequest) XXX_Merge added in v0.6.1 

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

func (*RefreshRepositoryRequest) XXX_Size added in v0.6.1 

func (m *RefreshRepositoryRequest) XXX_Size() int

func (*RefreshRepositoryRequest) XXX_Unmarshal added in v0.6.1 

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

type ScanMirrorReply added in v0.6.1 

type ScanMirrorReply struct {
	Enabled              bool     `protobuf:"varint,1,opt,name=Enabled,proto3" json:"Enabled,omitempty"`
	FilesIndexed         int64    `protobuf:"varint,2,opt,name=FilesIndexed,proto3" json:"FilesIndexed,omitempty"`
	KnownIndexed         int64    `protobuf:"varint,3,opt,name=KnownIndexed,proto3" json:"KnownIndexed,omitempty"`
	Removed              int64    `protobuf:"varint,4,opt,name=Removed,proto3" json:"Removed,omitempty"`
	TZOffsetMs           int64    `protobuf:"varint,5,opt,name=TZOffsetMs,proto3" json:"TZOffsetMs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ScanMirrorReply) Descriptor added in v0.6.1 

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

func (*ScanMirrorReply) GetEnabled added in v0.6.1 

func (m *ScanMirrorReply) GetEnabled() bool

func (*ScanMirrorReply) GetFilesIndexed added in v0.6.1 

func (m *ScanMirrorReply) GetFilesIndexed() int64

func (*ScanMirrorReply) GetKnownIndexed added in v0.6.1 

func (m *ScanMirrorReply) GetKnownIndexed() int64

func (*ScanMirrorReply) GetRemoved added in v0.6.1 

func (m *ScanMirrorReply) GetRemoved() int64

func (*ScanMirrorReply) GetTZOffsetMs added in v0.6.1 

func (m *ScanMirrorReply) GetTZOffsetMs() int64

func (*ScanMirrorReply) ProtoMessage added in v0.6.1 

func (*ScanMirrorReply) ProtoMessage()

func (*ScanMirrorReply) Reset added in v0.6.1 

func (m *ScanMirrorReply) Reset()

func (*ScanMirrorReply) String added in v0.6.1 

func (m *ScanMirrorReply) String() string

func (*ScanMirrorReply) XXX_DiscardUnknown added in v0.6.1 

func (m *ScanMirrorReply) XXX_DiscardUnknown()

func (*ScanMirrorReply) XXX_Marshal added in v0.6.1 

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

func (*ScanMirrorReply) XXX_Merge added in v0.6.1 

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

func (*ScanMirrorReply) XXX_Size added in v0.6.1 

func (m *ScanMirrorReply) XXX_Size() int

func (*ScanMirrorReply) XXX_Unmarshal added in v0.6.1 

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

type ScanMirrorRequest added in v0.6.1 

type ScanMirrorRequest struct {
	ID                   int32                    `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	AutoEnable           bool                     `protobuf:"varint,2,opt,name=AutoEnable,proto3" json:"AutoEnable,omitempty"`
	Protocol             ScanMirrorRequest_Method `protobuf:"varint,3,opt,name=Protocol,proto3,enum=ScanMirrorRequest_Method" json:"Protocol,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*ScanMirrorRequest) Descriptor added in v0.6.1 

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

func (*ScanMirrorRequest) GetAutoEnable added in v0.6.1 

func (m *ScanMirrorRequest) GetAutoEnable() bool

func (*ScanMirrorRequest) GetID added in v0.6.1 

func (m *ScanMirrorRequest) GetID() int32

func (*ScanMirrorRequest) GetProtocol added in v0.6.1 

func (m *ScanMirrorRequest) GetProtocol() ScanMirrorRequest_Method

func (*ScanMirrorRequest) ProtoMessage added in v0.6.1 

func (*ScanMirrorRequest) ProtoMessage()

func (*ScanMirrorRequest) Reset added in v0.6.1 

func (m *ScanMirrorRequest) Reset()

func (*ScanMirrorRequest) String added in v0.6.1 

func (m *ScanMirrorRequest) String() string

func (*ScanMirrorRequest) XXX_DiscardUnknown added in v0.6.1 

func (m *ScanMirrorRequest) XXX_DiscardUnknown()

func (*ScanMirrorRequest) XXX_Marshal added in v0.6.1 

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

func (*ScanMirrorRequest) XXX_Merge added in v0.6.1 

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

func (*ScanMirrorRequest) XXX_Size added in v0.6.1 

func (m *ScanMirrorRequest) XXX_Size() int

func (*ScanMirrorRequest) XXX_Unmarshal added in v0.6.1 

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

type ScanMirrorRequest_Method added in v0.6.1 

type ScanMirrorRequest_Method int32
const (
	ScanMirrorRequest_ALL   ScanMirrorRequest_Method = 0
	ScanMirrorRequest_FTP   ScanMirrorRequest_Method = 1
	ScanMirrorRequest_RSYNC ScanMirrorRequest_Method = 2
)

func (ScanMirrorRequest_Method) EnumDescriptor added in v0.6.1 

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

func (ScanMirrorRequest_Method) String added in v0.6.1 

func (x ScanMirrorRequest_Method) String() string

type StatsFileReply added in v0.6.1 

type StatsFileReply struct {
	Files                map[string]int64 `` /* 152-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*StatsFileReply) Descriptor added in v0.6.1 

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

func (*StatsFileReply) GetFiles added in v0.6.1 

func (m *StatsFileReply) GetFiles() map[string]int64

func (*StatsFileReply) ProtoMessage added in v0.6.1 

func (*StatsFileReply) ProtoMessage()

func (*StatsFileReply) Reset added in v0.6.1 

func (m *StatsFileReply) Reset()

func (*StatsFileReply) String added in v0.6.1 

func (m *StatsFileReply) String() string

func (*StatsFileReply) XXX_DiscardUnknown added in v0.6.1 

func (m *StatsFileReply) XXX_DiscardUnknown()

func (*StatsFileReply) XXX_Marshal added in v0.6.1 

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

func (*StatsFileReply) XXX_Merge added in v0.6.1 

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

func (*StatsFileReply) XXX_Size added in v0.6.1 

func (m *StatsFileReply) XXX_Size() int

func (*StatsFileReply) XXX_Unmarshal added in v0.6.1 

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

type StatsFileRequest added in v0.6.1 

type StatsFileRequest struct {
	Pattern              string               `protobuf:"bytes,1,opt,name=Pattern,proto3" json:"Pattern,omitempty"`
	DateStart            *timestamp.Timestamp `protobuf:"bytes,2,opt,name=DateStart,proto3" json:"DateStart,omitempty"`
	DateEnd              *timestamp.Timestamp `protobuf:"bytes,3,opt,name=DateEnd,proto3" json:"DateEnd,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*StatsFileRequest) Descriptor added in v0.6.1 

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

func (*StatsFileRequest) GetDateEnd added in v0.6.1 

func (m *StatsFileRequest) GetDateEnd() *timestamp.Timestamp

func (*StatsFileRequest) GetDateStart added in v0.6.1 

func (m *StatsFileRequest) GetDateStart() *timestamp.Timestamp

func (*StatsFileRequest) GetPattern added in v0.6.1 

func (m *StatsFileRequest) GetPattern() string

func (*StatsFileRequest) ProtoMessage added in v0.6.1 

func (*StatsFileRequest) ProtoMessage()

func (*StatsFileRequest) Reset added in v0.6.1 

func (m *StatsFileRequest) Reset()

func (*StatsFileRequest) String added in v0.6.1 

func (m *StatsFileRequest) String() string

func (*StatsFileRequest) XXX_DiscardUnknown added in v0.6.1 

func (m *StatsFileRequest) XXX_DiscardUnknown()

func (*StatsFileRequest) XXX_Marshal added in v0.6.1 

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

func (*StatsFileRequest) XXX_Merge added in v0.6.1 

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

func (*StatsFileRequest) XXX_Size added in v0.6.1 

func (m *StatsFileRequest) XXX_Size() int

func (*StatsFileRequest) XXX_Unmarshal added in v0.6.1 

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

type StatsMirrorReply added in v0.6.1 

type StatsMirrorReply struct {
	Mirror               *Mirror  `protobuf:"bytes,1,opt,name=Mirror,proto3" json:"Mirror,omitempty"`
	Requests             int64    `protobuf:"varint,2,opt,name=Requests,proto3" json:"Requests,omitempty"`
	Bytes                int64    `protobuf:"varint,3,opt,name=Bytes,proto3" json:"Bytes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StatsMirrorReply) Descriptor added in v0.6.1 

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

func (*StatsMirrorReply) GetBytes added in v0.6.1 

func (m *StatsMirrorReply) GetBytes() int64

func (*StatsMirrorReply) GetMirror added in v0.6.1 

func (m *StatsMirrorReply) GetMirror() *Mirror

func (*StatsMirrorReply) GetRequests added in v0.6.1 

func (m *StatsMirrorReply) GetRequests() int64

func (*StatsMirrorReply) ProtoMessage added in v0.6.1 

func (*StatsMirrorReply) ProtoMessage()

func (*StatsMirrorReply) Reset added in v0.6.1 

func (m *StatsMirrorReply) Reset()

func (*StatsMirrorReply) String added in v0.6.1 

func (m *StatsMirrorReply) String() string

func (*StatsMirrorReply) XXX_DiscardUnknown added in v0.6.1 

func (m *StatsMirrorReply) XXX_DiscardUnknown()

func (*StatsMirrorReply) XXX_Marshal added in v0.6.1 

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

func (*StatsMirrorReply) XXX_Merge added in v0.6.1 

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

func (*StatsMirrorReply) XXX_Size added in v0.6.1 

func (m *StatsMirrorReply) XXX_Size() int

func (*StatsMirrorReply) XXX_Unmarshal added in v0.6.1 

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

type StatsMirrorRequest added in v0.6.1 

type StatsMirrorRequest struct {
	ID                   int32                `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	DateStart            *timestamp.Timestamp `protobuf:"bytes,2,opt,name=DateStart,proto3" json:"DateStart,omitempty"`
	DateEnd              *timestamp.Timestamp `protobuf:"bytes,3,opt,name=DateEnd,proto3" json:"DateEnd,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*StatsMirrorRequest) Descriptor added in v0.6.1 

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

func (*StatsMirrorRequest) GetDateEnd added in v0.6.1 

func (m *StatsMirrorRequest) GetDateEnd() *timestamp.Timestamp

func (*StatsMirrorRequest) GetDateStart added in v0.6.1 

func (m *StatsMirrorRequest) GetDateStart() *timestamp.Timestamp

func (*StatsMirrorRequest) GetID added in v0.6.1 

func (m *StatsMirrorRequest) GetID() int32

func (*StatsMirrorRequest) ProtoMessage added in v0.6.1 

func (*StatsMirrorRequest) ProtoMessage()

func (*StatsMirrorRequest) Reset added in v0.6.1 

func (m *StatsMirrorRequest) Reset()

func (*StatsMirrorRequest) String added in v0.6.1 

func (m *StatsMirrorRequest) String() string

func (*StatsMirrorRequest) XXX_DiscardUnknown added in v0.6.1 

func (m *StatsMirrorRequest) XXX_DiscardUnknown()

func (*StatsMirrorRequest) XXX_Marshal added in v0.6.1 

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

func (*StatsMirrorRequest) XXX_Merge added in v0.6.1 

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

func (*StatsMirrorRequest) XXX_Size added in v0.6.1 

func (m *StatsMirrorRequest) XXX_Size() int

func (*StatsMirrorRequest) XXX_Unmarshal added in v0.6.1 

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

type UnimplementedCLIServer added in v0.6.1 

type UnimplementedCLIServer struct {
}

UnimplementedCLIServer can be embedded to have forward compatible implementations.

func (*UnimplementedCLIServer) AddMirror added in v0.6.1 

func (*UnimplementedCLIServer) AddMirror(ctx context.Context, req *Mirror) (*AddMirrorReply, error)

func (*UnimplementedCLIServer) ChangeStatus added in v0.6.1 

func (*UnimplementedCLIServer) ChangeStatus(ctx context.Context, req *ChangeStatusRequest) (*empty.Empty, error)

func (*UnimplementedCLIServer) GeoUpdateMirror added in v0.6.1 

func (*UnimplementedCLIServer) GeoUpdateMirror(ctx context.Context, req *MirrorIDRequest) (*GeoUpdateMirrorReply, error)

func (*UnimplementedCLIServer) GetMirrorLogs added in v0.6.1 

func (*UnimplementedCLIServer) GetMirrorLogs(ctx context.Context, req *GetMirrorLogsRequest) (*GetMirrorLogsReply, error)

func (*UnimplementedCLIServer) GetVersion added in v0.6.1 

func (*UnimplementedCLIServer) GetVersion(ctx context.Context, req *empty.Empty) (*VersionReply, error)

func (*UnimplementedCLIServer) List added in v0.6.1 

func (*UnimplementedCLIServer) List(ctx context.Context, req *empty.Empty) (*MirrorListReply, error)

func (*UnimplementedCLIServer) MatchMirror added in v0.6.1 

func (*UnimplementedCLIServer) MatchMirror(ctx context.Context, req *MatchRequest) (*MatchReply, error)

func (*UnimplementedCLIServer) MirrorInfo added in v0.6.1 

func (*UnimplementedCLIServer) MirrorInfo(ctx context.Context, req *MirrorIDRequest) (*Mirror, error)

func (*UnimplementedCLIServer) Ping added in v0.6.1 

func (*UnimplementedCLIServer) Ping(ctx context.Context, req *empty.Empty) (*empty.Empty, error)

func (*UnimplementedCLIServer) RefreshRepository added in v0.6.1 

func (*UnimplementedCLIServer) RefreshRepository(ctx context.Context, req *RefreshRepositoryRequest) (*empty.Empty, error)

func (*UnimplementedCLIServer) Reload added in v0.6.1 

func (*UnimplementedCLIServer) Reload(ctx context.Context, req *empty.Empty) (*empty.Empty, error)

func (*UnimplementedCLIServer) RemoveMirror added in v0.6.1 

func (*UnimplementedCLIServer) RemoveMirror(ctx context.Context, req *MirrorIDRequest) (*empty.Empty, error)

func (*UnimplementedCLIServer) ScanMirror added in v0.6.1 

func (*UnimplementedCLIServer) ScanMirror(ctx context.Context, req *ScanMirrorRequest) (*ScanMirrorReply, error)

func (*UnimplementedCLIServer) StatsFile added in v0.6.1 

func (*UnimplementedCLIServer) StatsFile(ctx context.Context, req *StatsFileRequest) (*StatsFileReply, error)

func (*UnimplementedCLIServer) StatsMirror added in v0.6.1 

func (*UnimplementedCLIServer) StatsMirror(ctx context.Context, req *StatsMirrorRequest) (*StatsMirrorReply, error)

func (*UnimplementedCLIServer) UpdateMirror added in v0.6.1 

func (*UnimplementedCLIServer) UpdateMirror(ctx context.Context, req *Mirror) (*UpdateMirrorReply, error)

func (*UnimplementedCLIServer) Upgrade added in v0.6.1 

func (*UnimplementedCLIServer) Upgrade(ctx context.Context, req *empty.Empty) (*empty.Empty, error)

type UpdateMirrorReply added in v0.6.1 

type UpdateMirrorReply struct {
	Diff                 string   `protobuf:"bytes,1,opt,name=Diff,proto3" json:"Diff,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateMirrorReply) Descriptor added in v0.6.1 

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

func (*UpdateMirrorReply) GetDiff added in v0.6.1 

func (m *UpdateMirrorReply) GetDiff() string

func (*UpdateMirrorReply) ProtoMessage added in v0.6.1 

func (*UpdateMirrorReply) ProtoMessage()

func (*UpdateMirrorReply) Reset added in v0.6.1 

func (m *UpdateMirrorReply) Reset()

func (*UpdateMirrorReply) String added in v0.6.1 

func (m *UpdateMirrorReply) String() string

func (*UpdateMirrorReply) XXX_DiscardUnknown added in v0.6.1 

func (m *UpdateMirrorReply) XXX_DiscardUnknown()

func (*UpdateMirrorReply) XXX_Marshal added in v0.6.1 

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

func (*UpdateMirrorReply) XXX_Merge added in v0.6.1 

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

func (*UpdateMirrorReply) XXX_Size added in v0.6.1 

func (m *UpdateMirrorReply) XXX_Size() int

func (*UpdateMirrorReply) XXX_Unmarshal added in v0.6.1 

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

type VersionReply added in v0.6.1 

type VersionReply struct {
	Version              string   `protobuf:"bytes,1,opt,name=Version,proto3" json:"Version,omitempty"`
	Build                string   `protobuf:"bytes,2,opt,name=Build,proto3" json:"Build,omitempty"`
	GoVersion            string   `protobuf:"bytes,3,opt,name=GoVersion,proto3" json:"GoVersion,omitempty"`
	OS                   string   `protobuf:"bytes,4,opt,name=OS,proto3" json:"OS,omitempty"`
	Arch                 string   `protobuf:"bytes,5,opt,name=Arch,proto3" json:"Arch,omitempty"`
	GoMaxProcs           int32    `protobuf:"varint,6,opt,name=GoMaxProcs,proto3" json:"GoMaxProcs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VersionReply) Descriptor added in v0.6.1 

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

func (*VersionReply) GetArch added in v0.6.1 

func (m *VersionReply) GetArch() string

func (*VersionReply) GetBuild added in v0.6.1 

func (m *VersionReply) GetBuild() string

func (*VersionReply) GetGoMaxProcs added in v0.6.1 

func (m *VersionReply) GetGoMaxProcs() int32

func (*VersionReply) GetGoVersion added in v0.6.1 

func (m *VersionReply) GetGoVersion() string

func (*VersionReply) GetOS added in v0.6.1 

func (m *VersionReply) GetOS() string

func (*VersionReply) GetVersion added in v0.6.1 

func (m *VersionReply) GetVersion() string

func (*VersionReply) ProtoMessage added in v0.6.1 

func (*VersionReply) ProtoMessage()

func (*VersionReply) Reset added in v0.6.1 

func (m *VersionReply) Reset()

func (*VersionReply) String added in v0.6.1 

func (m *VersionReply) String() string

func (*VersionReply) XXX_DiscardUnknown added in v0.6.1 

func (m *VersionReply) XXX_DiscardUnknown()

func (*VersionReply) XXX_Marshal added in v0.6.1 

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

func (*VersionReply) XXX_Merge added in v0.6.1 

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

func (*VersionReply) XXX_Size added in v0.6.1 

func (m *VersionReply) XXX_Size() int

func (*VersionReply) XXX_Unmarshal added in v0.6.1 

func (m *VersionReply) XXX_Unmarshal(b []byte) 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.