grpcio

package

v0.0.0-...-7fad99f Latest Latest Go to latest Published: Jun 28, 2023 License: Apache-2.0 Imports: 25 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/ntail-io/streams

Documentation ¶

Index ¶

func NewServer(ctx context.Context, addr string, service *GatewayService, useAlts bool) error
type GatewayService
- func NewGatewayService(topicService *gateway.TopicService, etcdClient *clientv3.Client, ...) *GatewayService

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewServer ¶

func NewServer(ctx context.Context, addr string, service *GatewayService, useAlts bool) error

Types ¶

type GatewayService ¶

type GatewayService struct {
	v1.UnimplementedGatewayServiceServer
	// contains filtered or unexported fields
}

func NewGatewayService ¶

func NewGatewayService(
	topicService *gateway.TopicService,
	etcdClient *clientv3.Client,
	bqReaderService *bigquery.ReaderService,
) *GatewayService

func (*GatewayService) Append ¶

func (s *GatewayService) Append(server v1.GatewayService_AppendServer) error

func (*GatewayService) CreateSubscription ¶

func (s *GatewayService) CreateSubscription(ctx context.Context, req *v1.CreateSubscriptionRequest) (*empty.Empty, error)

func (*GatewayService) CreateTopic ¶

func (s *GatewayService) CreateTopic(ctx context.Context, req *v1.CreateTopicRequest) (*empty.Empty, error)

func (*GatewayService) ListSubscriptions ¶

func (s *GatewayService) ListSubscriptions(_ context.Context, req *v1.ListSubscriptionsRequest) (res *v1.ListSubscriptionsResponse, err error)

func (*GatewayService) ListTopics ¶

func (s *GatewayService) ListTopics(_ context.Context, _ *v1.ListTopicsRequest) (*v1.ListTopicsResponse, error)

func (*GatewayService) Tail ¶

func (s *GatewayService) Tail(server v1.GatewayService_TailServer) (err error)

Tail will attempt to stream and entire segment to the client. If the client disconnects, the segment will be released and the client will be disconnected. If the segment is on the buffer, and the buffer drops the segment the client will be disconnected. If the segment reaches EOF the client will be disconnected. It is expected that the client will open a new stream to continue reading.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL