Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

transport

package

Go to main page

Versions in this module

v3

v3.2.0

Jan 2, 2025

Changes in this version

type HttpTransportOptions

+ TLSConfig *tls.Config

v3.0.0

Apr 20, 2024

Changes in this version

+ const DefaultBasePath

+ func SetSinkView(s Sink, v ByteView) error

+ type ByteView struct

+ func ByteViewFrom(x any) ByteView

+ func ByteViewWithExpire(b []byte, expire time.Time) ByteView

+ func (v ByteView) At(i int) byte

+ func (v ByteView) ByteSlice() []byte

+ func (v ByteView) Copy(dest []byte) int

+ func (v ByteView) Equal(b2 ByteView) bool

+ func (v ByteView) EqualBytes(b2 []byte) bool

+ func (v ByteView) EqualString(s string) bool

+ func (v ByteView) Expire() time.Time

+ func (v ByteView) Len() int

+ func (v ByteView) ReadAt(p []byte, off int64) (n int, err error)

+ func (v ByteView) Reader() io.ReadSeeker

+ func (v ByteView) Slice(from, to int) ByteView

+ func (v ByteView) SliceFrom(from int) ByteView

+ func (v ByteView) String() string

+ func (v ByteView) WriteTo(w io.Writer) (n int64, err error)

+ type ErrNotFound struct

+ Msg string

+ func (e *ErrNotFound) Error() string

+ func (e *ErrNotFound) Is(target error) bool

+ type ErrRemoteCall struct

+ Msg string

+ func (e *ErrRemoteCall) Error() string

+ func (e *ErrRemoteCall) Is(target error) bool

+ type Group interface

+ Get func(context.Context, string, Sink) error

+ Name func() string

+ Remove func(context.Context, string) error

+ Set func(context.Context, string, []byte, time.Time, bool) error

+ UsedBytes func() (int64, int64)

+ type GroupCacheInstance interface

+ GetGroup func(string) Group

+ type HttpClient struct

+ func (h *HttpClient) Get(ctx context.Context, in *pb.GetRequest, out *pb.GetResponse) error

+ func (h *HttpClient) HashKey() string

+ func (h *HttpClient) PeerInfo() peer.Info

+ func (h *HttpClient) Remove(ctx context.Context, in *pb.GetRequest) error

+ func (h *HttpClient) Set(ctx context.Context, in *pb.SetRequest) error

+ type HttpTransport struct

+ func NewHttpTransport(opts HttpTransportOptions) *HttpTransport

+ func (t *HttpTransport) ListenAddress() string

+ func (t *HttpTransport) ListenAndServe(ctx context.Context, address string) error

+ func (t *HttpTransport) New() Transport

+ func (t *HttpTransport) NewClient(_ context.Context, p peer.Info) (peer.Client, error)

+ func (t *HttpTransport) Register(instance GroupCacheInstance)

+ func (t *HttpTransport) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (t *HttpTransport) Shutdown(ctx context.Context) error

+ type HttpTransportOptions struct

+ BasePath string

+ Client *http.Client

+ Context func(*http.Request) context.Context

+ Logger Logger

+ Scheme string

+ type Logger interface

+ Error func(msg string, args ...any)

+ Info func(msg string, args ...any)

+ type MockClient struct

+ func (c *MockClient) Get(ctx context.Context, in *pb.GetRequest, out *pb.GetResponse) error

+ func (c *MockClient) HashKey() string

+ func (c *MockClient) PeerInfo() peer.Info

+ func (c *MockClient) Remove(ctx context.Context, in *pb.GetRequest) error

+ func (c *MockClient) Set(ctx context.Context, in *pb.SetRequest) error

+ type MockTransport struct

+ func NewMockTransport() *MockTransport

+ func (t *MockTransport) ListenAddress() string

+ func (t *MockTransport) ListenAndServe(_ context.Context, address string) error

+ func (t *MockTransport) New() Transport

+ func (t *MockTransport) NewClient(ctx context.Context, peer peer.Info) (peer.Client, error)

+ func (t *MockTransport) Register(i GroupCacheInstance)

+ func (t *MockTransport) Report(method string) string

+ func (t *MockTransport) Reset()

+ func (t *MockTransport) Shutdown(_ context.Context) error

+ type Sink interface

+ SetBytes func(v []byte, e time.Time) error

+ SetProto func(m proto.Message, e time.Time) error

+ SetString func(s string, e time.Time) error

+ View func() (ByteView, error)

+ func AllocatingByteSliceSink(dst *[]byte) Sink

+ func ByteViewSink(dst *ByteView) Sink

+ func ProtoSink(m proto.Message) Sink

+ func StringSink(sp *string) Sink

+ func TruncatingByteSliceSink(dst *[]byte) Sink

+ type Transport interface

+ ListenAddress func() string

+ ListenAndServe func(ctx context.Context, address string) error

+ New func() Transport

+ NewClient func(ctx context.Context, peer peer.Info) (peer.Client, error)

+ Register func(instance GroupCacheInstance)

+ Shutdown func(ctx context.Context) error

v3.0.0-rc.2

Apr 20, 2024

v3.0.0-rc.1

Apr 11, 2024