server

Documentation

Index

• func NewGRPCServer(options ...grpcOption) *grpc.Server
• func WithGRPCServerOptions(options ...grpc.ServerOption) grpcOption
• func WithGRPCTLSConfig(tlsConfig *tls.Config) grpcOption
• func WithStreamInterceptor(interceptor grpc.StreamServerInterceptor) grpcOption
• func WithUnaryInterceptor(interceptor grpc.UnaryServerInterceptor) grpcOption
• type Option
  • func WithAddr(addr string) Option
  • func WithId(id string) Option
  • func WithPort(port int) Option
  • func WithPrometheusAddr(addr string) Option
  • func WithPrometheusPort(port int) Option
  • func WithStoragePath(path string) Option
  • func WithTLSConfig(config *tls.Config) Option
• type Options
  • func (o *Options) Apply(options ...Option)
• type Server
  • func New(options ...Option) (*Server, error)
  • func (s *Server) Serve() error
  • func (s *Server) Stop() error
• type StorageService
  • func NewStorageService(store storage.Storage) *StorageService
  • func (s *StorageService) List(ctx context.Context, req *api.ListRequest) (*api.ListResponse, error)
  • func (s *StorageService) Read(req *api.ReadRequest, stream api.Storage_ReadServer) error
  • func (s *StorageService) Remove(ctx context.Context, req *api.RemoveRequest) (*api.RemoveResponse, error)
  • func (s *StorageService) Rename(ctx context.Context, req *api.RenameRequest) (*api.RenameResponse, error)
  • func (s *StorageService) Stat(ctx context.Context, req *api.StatRequest) (*api.StatResponse, error)
  • func (s *StorageService) Write(stream api.Storage_WriteServer) error

Functions

func NewGRPCServer

func NewGRPCServer(options ...grpcOption) *grpc.Server

func WithGRPCServerOptions

func WithGRPCServerOptions(options ...grpc.ServerOption) grpcOption

func WithGRPCTLSConfig

func WithGRPCTLSConfig(tlsConfig *tls.Config) grpcOption

func WithStreamInterceptor

func WithStreamInterceptor(interceptor grpc.StreamServerInterceptor) grpcOption

func WithUnaryInterceptor

func WithUnaryInterceptor(interceptor grpc.UnaryServerInterceptor) grpcOption

Types

type Option

type Option func(*Options)

func WithAddr

func WithAddr(addr string) Option

func WithId

func WithId(id string) Option

func WithPort

func WithPort(port int) Option

func WithPrometheusAddr

func WithPrometheusAddr(addr string) Option

func WithPrometheusPort

func WithPrometheusPort(port int) Option

func WithStoragePath

func WithStoragePath(path string) Option

func WithTLSConfig

func WithTLSConfig(config *tls.Config) Option

type Options

type Options struct {
	Id             string
	Addr           string
	Port           int
	TLSConfig      *tls.Config
	StoragePath    string
	PrometheusAddr string
	PrometheusPort int
}

func (*Options) Apply

func (o *Options) Apply(options ...Option)

Apply calls each option on o in turn

type Server

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

func New

func New(options ...Option) (*Server, error)

func (*Server) Serve

func (s *Server) Serve() error

func (*Server) Stop

func (s *Server) Stop() error

type StorageService

type StorageService struct {
	api.UnimplementedStorageServer
	// contains filtered or unexported fields
}

func NewStorageService

func NewStorageService(store storage.Storage) *StorageService

func (*StorageService) List

func (s *StorageService) List(ctx context.Context, req *api.ListRequest) (*api.ListResponse, error)

func (*StorageService) Read

func (s *StorageService) Read(req *api.ReadRequest, stream api.Storage_ReadServer) error

func (*StorageService) Remove

func (s *StorageService) Remove(ctx context.Context, req *api.RemoveRequest) (*api.RemoveResponse, error)

func (*StorageService) Rename

func (s *StorageService) Rename(ctx context.Context, req *api.RenameRequest) (*api.RenameResponse, error)

func (*StorageService) Stat

func (s *StorageService) Stat(ctx context.Context, req *api.StatRequest) (*api.StatResponse, error)

func (*StorageService) Write

func (s *StorageService) Write(stream api.Storage_WriteServer) error