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

cos

package

Go to main page

Versions in this module

v1

v1.1.1

Oct 12, 2024

Changes in this version

+ func URL(host string, port int) string

type ReadSideManager

+ func NewReadSideManager(ctx context.Context, cosHost string, cosPort int) ReadSideManager

v1.1.0

Jul 29, 2023

v1.0.0

Mar 31, 2022

Changes in this version

+ const KeepAliveTime

+ type Builder struct

+ func NewBuilder() *Builder

+ func (b *Builder) GetConn(ctx context.Context, addr string) (*grpc.ClientConn, error)

+ func (b *Builder) GetTLSConn(ctx context.Context, addr string) (*grpc.ClientConn, error)

+ func (b *Builder) WithBlock() *Builder

+ func (b *Builder) WithClientTransportCredentials(insecureSkipVerify bool, certPool *x509.CertPool) *Builder

+ func (b *Builder) WithInsecure() *Builder

+ func (b *Builder) WithKeepAliveParams(params keepalive.ClientParameters) *Builder

+ func (b *Builder) WithOptions(opts ...grpc.DialOption) *Builder

+ type ConnectionBuilder interface

+ GetConn func(ctx context.Context, addr string) (*grpc.ClientConn, error)

+ GetTLSConn func(ctx context.Context, addr string) (*grpc.ClientConn, error)

+ WithInsecure func()

+ WithKeepAliveParams func(params keepalive.ClientParameters)

+ WithOptions func(opts ...grpc.DialOption)

+ type ReadSideManager interface

+ GetLatestOffset func(ctx context.Context, in *cospb.GetLatestOffsetRequest) (*cospb.GetLatestOffsetResponse, error)

+ GetLatestOffsetByShard func(ctx context.Context, in *cospb.GetLatestOffsetByShardRequest) (*cospb.GetLatestOffsetByShardResponse, error)

+ PauseReadSide func(ctx context.Context, in *cospb.PauseReadSideRequest) (*cospb.PauseReadSideResponse, error)

+ PauseReadSideByShard func(ctx context.Context, in *cospb.PauseReadSideByShardRequest) (*cospb.PauseReadSideByShardResponse, error)

+ RestartReadSide func(ctx context.Context, in *cospb.RestartReadSideRequest) (*cospb.RestartReadSideResponse, error)

+ RestartReadSideByShard func(ctx context.Context, in *cospb.RestartReadSideByShardRequest) (*cospb.RestartReadSideByShardResponse, error)

+ ResumeReadSide func(ctx context.Context, in *cospb.ResumeReadSideRequest) (*cospb.ResumeReadSideResponse, error)

+ ResumeReadSideByShard func(ctx context.Context, in *cospb.ResumeReadSideByShardRequest) (*cospb.ResumeReadSideByShardResponse, error)

+ SkipOffset func(ctx context.Context, in *cospb.SkipOffsetRequest) (*cospb.SkipOffsetResponse, error)

+ SkipOffsetByShard func(ctx context.Context, in *cospb.SkipOffsetByShardRequest) (*cospb.SkipOffsetByShardResponse, error)

+ func NewClient(ctx context.Context, cosHost string, cosPort int) (ReadSideManager, error)

v1.0.0-beta.2

Mar 29, 2022

v1.0.0-beta.1

Feb 21, 2022