replication

package
v0.0.0-...-c2b79b4 Latest Latest
Warning

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

 Go to latest Published: Sep 3, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterReplicationServiceServer 

func RegisterReplicationServiceServer(s *grpc.Server, srv ReplicationServiceServer)

Types

type CreateRepositoryRequest 

type CreateRepositoryRequest struct {
	Repository           *Repository `protobuf:"bytes,1,opt,name=repository,proto3" json:"repository,omitempty"`
	RemoteAddr           string      `protobuf:"bytes,2,opt,name=remote_addr,json=remoteAddr,proto3" json:"remote_addr,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*CreateRepositoryRequest) Descriptor 

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

func (*CreateRepositoryRequest) GetRemoteAddr 

func (m *CreateRepositoryRequest) GetRemoteAddr() string

func (*CreateRepositoryRequest) GetRepository 

func (m *CreateRepositoryRequest) GetRepository() *Repository

func (*CreateRepositoryRequest) ProtoMessage 

func (*CreateRepositoryRequest) ProtoMessage()

func (*CreateRepositoryRequest) Reset 

func (m *CreateRepositoryRequest) Reset()

func (*CreateRepositoryRequest) String 

func (m *CreateRepositoryRequest) String() string

func (*CreateRepositoryRequest) XXX_DiscardUnknown 

func (m *CreateRepositoryRequest) XXX_DiscardUnknown()

func (*CreateRepositoryRequest) XXX_Marshal 

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

func (*CreateRepositoryRequest) XXX_Merge 

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

func (*CreateRepositoryRequest) XXX_Size 

func (m *CreateRepositoryRequest) XXX_Size() int

func (*CreateRepositoryRequest) XXX_Unmarshal 

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

type CreateRepositoryResponse 

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

func (*CreateRepositoryResponse) Descriptor 

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

func (*CreateRepositoryResponse) GetData 

func (m *CreateRepositoryResponse) GetData() []byte

func (*CreateRepositoryResponse) ProtoMessage 

func (*CreateRepositoryResponse) ProtoMessage()

func (*CreateRepositoryResponse) Reset 

func (m *CreateRepositoryResponse) Reset()

func (*CreateRepositoryResponse) String 

func (m *CreateRepositoryResponse) String() string

func (*CreateRepositoryResponse) XXX_DiscardUnknown 

func (m *CreateRepositoryResponse) XXX_DiscardUnknown()

func (*CreateRepositoryResponse) XXX_Marshal 

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

func (*CreateRepositoryResponse) XXX_Merge 

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

func (*CreateRepositoryResponse) XXX_Size 

func (m *CreateRepositoryResponse) XXX_Size() int

func (*CreateRepositoryResponse) XXX_Unmarshal 

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

type ReplicationServiceClient 

type ReplicationServiceClient interface {
	CreateRepository(ctx context.Context, in *CreateRepositoryRequest, opts ...grpc.CallOption) (*CreateRepositoryResponse, error)
	SyncRepository(ctx context.Context, in *SyncRepositoryRequest, opts ...grpc.CallOption) (*SyncRepositoryResponse, error)
}

ReplicationServiceClient is the client API for ReplicationService service.

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

func NewReplicationServiceClient 

func NewReplicationServiceClient(cc *grpc.ClientConn) ReplicationServiceClient

type ReplicationServiceServer 

type ReplicationServiceServer interface {
	CreateRepository(context.Context, *CreateRepositoryRequest) (*CreateRepositoryResponse, error)
	SyncRepository(context.Context, *SyncRepositoryRequest) (*SyncRepositoryResponse, error)
}

ReplicationServiceServer is the server API for ReplicationService service.

type Repository 

type Repository struct {
	User                 string   `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Repo                 string   `protobuf:"bytes,2,opt,name=repo,proto3" json:"repo,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Repository) Descriptor 

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

func (*Repository) GetRepo 

func (m *Repository) GetRepo() string

func (*Repository) GetUser 

func (m *Repository) GetUser() string

func (*Repository) ProtoMessage 

func (*Repository) ProtoMessage()

func (*Repository) Reset 

func (m *Repository) Reset()

func (*Repository) String 

func (m *Repository) String() string

func (*Repository) XXX_DiscardUnknown 

func (m *Repository) XXX_DiscardUnknown()

func (*Repository) XXX_Marshal 

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

func (*Repository) XXX_Merge 

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

func (*Repository) XXX_Size 

func (m *Repository) XXX_Size() int

func (*Repository) XXX_Unmarshal 

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

type SyncRepositoryRequest 

type SyncRepositoryRequest struct {
	Repository           *Repository `protobuf:"bytes,1,opt,name=repository,proto3" json:"repository,omitempty"`
	RemoteAddr           string      `protobuf:"bytes,2,opt,name=remote_addr,json=remoteAddr,proto3" json:"remote_addr,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*SyncRepositoryRequest) Descriptor 

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

func (*SyncRepositoryRequest) GetRemoteAddr 

func (m *SyncRepositoryRequest) GetRemoteAddr() string

func (*SyncRepositoryRequest) GetRepository 

func (m *SyncRepositoryRequest) GetRepository() *Repository

func (*SyncRepositoryRequest) ProtoMessage 

func (*SyncRepositoryRequest) ProtoMessage()

func (*SyncRepositoryRequest) Reset 

func (m *SyncRepositoryRequest) Reset()

func (*SyncRepositoryRequest) String 

func (m *SyncRepositoryRequest) String() string

func (*SyncRepositoryRequest) XXX_DiscardUnknown 

func (m *SyncRepositoryRequest) XXX_DiscardUnknown()

func (*SyncRepositoryRequest) XXX_Marshal 

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

func (*SyncRepositoryRequest) XXX_Merge 

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

func (*SyncRepositoryRequest) XXX_Size 

func (m *SyncRepositoryRequest) XXX_Size() int

func (*SyncRepositoryRequest) XXX_Unmarshal 

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

type SyncRepositoryResponse 

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

func (*SyncRepositoryResponse) Descriptor 

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

func (*SyncRepositoryResponse) GetData 

func (m *SyncRepositoryResponse) GetData() []byte

func (*SyncRepositoryResponse) ProtoMessage 

func (*SyncRepositoryResponse) ProtoMessage()

func (*SyncRepositoryResponse) Reset 

func (m *SyncRepositoryResponse) Reset()

func (*SyncRepositoryResponse) String 

func (m *SyncRepositoryResponse) String() string

func (*SyncRepositoryResponse) XXX_DiscardUnknown 

func (m *SyncRepositoryResponse) XXX_DiscardUnknown()

func (*SyncRepositoryResponse) XXX_Marshal 

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

func (*SyncRepositoryResponse) XXX_Merge 

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

func (*SyncRepositoryResponse) XXX_Size 

func (m *SyncRepositoryResponse) XXX_Size() int

func (*SyncRepositoryResponse) XXX_Unmarshal 

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

type UnimplementedReplicationServiceServer 

type UnimplementedReplicationServiceServer struct {
}

UnimplementedReplicationServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedReplicationServiceServer) CreateRepository 

func (*UnimplementedReplicationServiceServer) CreateRepository(ctx context.Context, req *CreateRepositoryRequest) (*CreateRepositoryResponse, error)

func (*UnimplementedReplicationServiceServer) SyncRepository 

func (*UnimplementedReplicationServiceServer) SyncRepository(ctx context.Context, req *SyncRepositoryRequest) (*SyncRepositoryResponse, 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.