server

package
v0.0.0-...-837eb61 Latest Latest
Warning

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

Go to latest
Published: May 2, 2024 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewGRPC

func NewGRPC(ctx context.Context, config *config.DataFeedConfig, connFactory *secureconn.Factory, db *dao.DB) (*grpc.Server, error)

NewGRPC creates the gRPC server.

func StartGRPC

func StartGRPC(ctx context.Context, config *config.DataFeedConfig, connFactory *secureconn.Factory, db *dao.DB) error

StartGRPC starts the gRPC server

Types

type DatafeedServer

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

DatafeedServer is the interface to this component.

func NewDatafeedServer

func NewDatafeedServer(db *dao.DB, config *config.DataFeedConfig, connFactory *secureconn.Factory) (*DatafeedServer, error)

New creates a new DatafeedServer instance.

func (*DatafeedServer) AddDestination

func (datafeedServer *DatafeedServer) AddDestination(ctx context.Context, destination *datafeed.AddDestinationRequest) (*datafeed.AddDestinationResponse, error)

Add a new destination

func (*DatafeedServer) DeleteDestination

func (datafeedServer *DatafeedServer) DeleteDestination(ctx context.Context, destination *datafeed.DeleteDestinationRequest) (*datafeed.DeleteDestinationResponse, error)

func (*DatafeedServer) EnableDestination

func (datafeedServer *DatafeedServer) EnableDestination(ctx context.Context, destination *datafeed.UpdateDestinationEnableRequest) (*datafeed.GetDestinationResponse, error)

func (*DatafeedServer) GetDestination

func (datafeedServer *DatafeedServer) GetDestination(ctx context.Context, destination *datafeed.GetDestinationRequest) (*datafeed.GetDestinationResponse, error)

func (*DatafeedServer) GlobalDataFeedConfig

func (datafeedServer *DatafeedServer) GlobalDataFeedConfig(ctx context.Context, destination *datafeed.GlobalDataFeedConfigRequest) (*datafeed.GlobalDataFeedConfigResponse, error)

func (*DatafeedServer) Health

func (datafeedServer *DatafeedServer) Health() *health.Service

Health returns the servers embedded health check service

func (*DatafeedServer) ListDestinations

func (datafeedServer *DatafeedServer) ListDestinations(ctx context.Context, destination *datafeed.ListDestinationRequest) (*datafeed.ListDestinationResponse, error)

func (*DatafeedServer) TestDestination

func (datafeedServer *DatafeedServer) TestDestination(ctx context.Context, request *datafeed.URLValidationRequest) (*datafeed.TestDestinationResponse, error)

func (*DatafeedServer) UpdateDestination

func (datafeedServer *DatafeedServer) UpdateDestination(ctx context.Context, destination *datafeed.UpdateDestinationRequest) (*datafeed.UpdateDestinationResponse, error)

Jump to

Keyboard shortcuts

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