server

Documentation

Overview

Package server contains gRPC API endpoints to work with `storage` service.

Index

• Variables
• type StorageServer
  • func New(logger *zap.Logger, branch brnUC.UseCase, record recUC.UseCase) *StorageServer
  • func (s StorageServer) InitBranch(ctx context.Context, _ *empty.Empty) (*pb.InitBranchResponse, error)
  • func (s StorageServer) Pull(ctx context.Context, in *pb.PullRequest) (*pb.PullResponse, error)
  • func (s StorageServer) Push(ctx context.Context, in *pb.PushRequest) (*pb.PushResponse, error)

Variables

var (
	ErrAuthRequired   = status.Error(codes.Unauthenticated, "authentication required")
	ErrPullUpToDate   = status.Error(codes.NotFound, "nothing to pull: already up to date")
	ErrUnknown        = status.Error(codes.Unknown, "common push error")
	ErrRecordNotFound = status.Error(codes.NotFound, "record not found")
)

Types

type StorageServer

type StorageServer struct {
	pb.UnimplementedStorageServer
	// contains filtered or unexported fields
}

StorageServer implements API points to work with `Storage` service using gRPC protocol.

func New

func New(
	logger *zap.Logger,
	branch brnUC.UseCase,
	record recUC.UseCase,
) *StorageServer

func (StorageServer) InitBranch

func (s StorageServer) InitBranch(ctx context.Context, _ *empty.Empty) (*pb.InitBranchResponse, error)

func (StorageServer) Pull

func (s StorageServer) Pull(ctx context.Context, in *pb.PullRequest) (*pb.PullResponse, error)

func (StorageServer) Push

func (s StorageServer) Push(ctx context.Context, in *pb.PushRequest) (*pb.PushResponse, error)