server

Documentation

Index

• func NewGRPC(ctx context.Context, config *config.DataFeedConfig, ...) (*grpc.Server, error)
• func StartGRPC(ctx context.Context, config *config.DataFeedConfig, ...) error
• type DatafeedServer
  • func NewDatafeedServer(db *dao.DB, config *config.DataFeedConfig, connFactory *secureconn.Factory) (*DatafeedServer, error)
  • func (datafeedServer *DatafeedServer) AddDestination(ctx context.Context, destination *datafeed.AddDestinationRequest) (*datafeed.AddDestinationResponse, error)
  • func (datafeedServer *DatafeedServer) DeleteDestination(ctx context.Context, destination *datafeed.DeleteDestinationRequest) (*datafeed.DeleteDestinationResponse, error)
  • func (datafeedServer *DatafeedServer) EnableDestination(ctx context.Context, destination *datafeed.UpdateDestinationEnableRequest) (*datafeed.GetDestinationResponse, error)
  • func (datafeedServer *DatafeedServer) GetDestination(ctx context.Context, destination *datafeed.GetDestinationRequest) (*datafeed.GetDestinationResponse, error)
  • func (datafeedServer *DatafeedServer) GlobalDataFeedConfig(ctx context.Context, destination *datafeed.GlobalDataFeedConfigRequest) (*datafeed.GlobalDataFeedConfigResponse, error)
  • func (datafeedServer *DatafeedServer) Health() *health.Service
  • func (datafeedServer *DatafeedServer) ListDestinations(ctx context.Context, destination *datafeed.ListDestinationRequest) (*datafeed.ListDestinationResponse, error)
  • func (datafeedServer *DatafeedServer) TestDestination(ctx context.Context, request *datafeed.URLValidationRequest) (*datafeed.TestDestinationResponse, error)
  • func (datafeedServer *DatafeedServer) UpdateDestination(ctx context.Context, destination *datafeed.UpdateDestinationRequest) (*datafeed.UpdateDestinationResponse, error)

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)