Help us shape the future of Go! Take the 2026 Go Developer Survey

copier

package
v0.12.1 Latest Latest
Warning

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

 Go to latest Published: Apr 7, 2016 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const MuxHeader = 6

MuxHeader is the header byte used for the TCP muxer.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client 

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

Client represents a client for connecting remotely to a copier service.

func NewClient 

func NewClient(host string) *Client

NewClient return a new instance of Client.

func (*Client) ShardReader 

func (c *Client) ShardReader(id uint64) (io.ReadCloser, error)

ShardReader returns a reader for streaming shard data. Returned ReadCloser must be closed by the caller.

type Service 

type Service struct {
	TSDBStore interface {
		Shard(id uint64) *tsdb.Shard
	}

	Listener net.Listener
	Logger   *log.Logger
	// contains filtered or unexported fields
}

Service manages the listener for the endpoint.

func NewService 

func NewService() *Service

NewService returns a new instance of Service.

func (*Service) Close 

func (s *Service) Close() error

Close implements the Service interface.

func (*Service) Err 

func (s *Service) Err() <-chan error

Err returns a channel for fatal out-of-band errors.

func (*Service) Open 

func (s *Service) Open() error

Open starts the service.

func (*Service) SetLogger 

func (s *Service) SetLogger(l *log.Logger)

SetLogger sets the internal logger to the logger passed in.

Source Files

View all Source files

Directories

Path Synopsis
Package internal is a generated protocol buffer package.
 Package internal is a generated protocol buffer package.

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.