grpcapi

package
v0.0.9 Latest Latest
Warning

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

 Go to latest Published: Dec 1, 2023 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	GRPCAuthMetadataKey      = "auth-token"
	GRPCRequestIDMetadataKey = "request-id"
)
View Source 
const (
	MaxKVCommandSizeBytes = 64 * 1024 // 64KB
)

Variables

View Source 
var (
	GRPCMissingAuthError     = errors.New("missing auth token")
	GRPCInvalidAuthError     = errors.New("invalid auth token")
	GRPCServerShutdownError  = errors.New("server shutting down")
	GRPCMissingMetadataError = errors.New("missing metadata; misconfigured grpc client?")
)

Functions

This section is empty.

Types

type ExternalServer 

type ExternalServer struct {
	GRPCAPI
	// Must be implemented in order to satisfy the protos ExternalServer interface
	protos.UnimplementedExternalServer
}

ExternalServer implements the external GRPC API interface

func (*ExternalServer) AppRegister 

func (s *ExternalServer) AppRegister(ctx context.Context, req *protos.AppRegistrationRequest) (*protos.StandardResponse, error)

func (*ExternalServer) AppRegisterReject 

func (s *ExternalServer) AppRegisterReject(ctx context.Context, req *protos.AppRegisterRejectRequest) (*protos.StandardResponse, error)

func (*ExternalServer) AppRegistrationStatus 

func (s *ExternalServer) AppRegistrationStatus(_ context.Context, req *protos.AppRegistrationStatusRequest) (*protos.AppRegistrationStatusResponse, error)

func (*ExternalServer) AppVerifyRegistration 

func (s *ExternalServer) AppVerifyRegistration(_ context.Context, req *protos.AppVerifyRegistrationRequest) (*protos.StandardResponse, error)

func (*ExternalServer) AttachNotification 

func (s *ExternalServer) AttachNotification(ctx context.Context, req *protos.AttachNotificationRequest) (*protos.StandardResponse, error)

func (*ExternalServer) AttachPipeline 

func (s *ExternalServer) AttachPipeline(ctx context.Context, req *protos.AttachPipelineRequest) (*protos.StandardResponse, error)

func (*ExternalServer) CreateNotification 

func (s *ExternalServer) CreateNotification(ctx context.Context, req *protos.CreateNotificationRequest) (*protos.StandardResponse, error)

func (*ExternalServer) CreatePipeline 

func (s *ExternalServer) CreatePipeline(ctx context.Context, req *protos.CreatePipelineRequest) (*protos.CreatePipelineResponse, error)

func (*ExternalServer) DeleteAudience 

func (s *ExternalServer) DeleteAudience(ctx context.Context, req *protos.DeleteAudienceRequest) (*protos.StandardResponse, error)

func (*ExternalServer) DeleteNotification 

func (s *ExternalServer) DeleteNotification(ctx context.Context, req *protos.DeleteNotificationRequest) (*protos.StandardResponse, error)

func (*ExternalServer) DeletePipeline 

func (s *ExternalServer) DeletePipeline(ctx context.Context, req *protos.DeletePipelineRequest) (*protos.StandardResponse, error)

func (*ExternalServer) DeleteService 

func (s *ExternalServer) DeleteService(ctx context.Context, req *protos.DeleteServiceRequest) (*protos.StandardResponse, error)

func (*ExternalServer) DetachNotification 

func (s *ExternalServer) DetachNotification(ctx context.Context, req *protos.DetachNotificationRequest) (*protos.StandardResponse, error)

func (*ExternalServer) DetachPipeline 

func (s *ExternalServer) DetachPipeline(ctx context.Context, req *protos.DetachPipelineRequest) (*protos.StandardResponse, error)

func (*ExternalServer) GetAll 

func (s *ExternalServer) GetAll(ctx context.Context, req *protos.GetAllRequest) (*protos.GetAllResponse, error)

func (*ExternalServer) GetAllStream 

func (s *ExternalServer) GetAllStream(req *protos.GetAllRequest, server protos.External_GetAllStreamServer) error

func (*ExternalServer) GetAudienceRates 

func (s *ExternalServer) GetAudienceRates(_ *protos.GetAudienceRatesRequest, server protos.External_GetAudienceRatesServer) error

func (*ExternalServer) GetMetrics 

func (s *ExternalServer) GetMetrics(_ *protos.GetMetricsRequest, server protos.External_GetMetricsServer) error

func (*ExternalServer) GetNotification 

func (s *ExternalServer) GetNotification(ctx context.Context, req *protos.GetNotificationRequest) (*protos.GetNotificationResponse, error)

func (*ExternalServer) GetNotifications 

func (s *ExternalServer) GetNotifications(ctx context.Context, req *protos.GetNotificationsRequest) (*protos.GetNotificationsResponse, error)

func (*ExternalServer) GetPipeline 

func (s *ExternalServer) GetPipeline(ctx context.Context, req *protos.GetPipelineRequest) (*protos.GetPipelineResponse, error)

func (*ExternalServer) GetPipelines 

func (s *ExternalServer) GetPipelines(ctx context.Context, req *protos.GetPipelinesRequest) (*protos.GetPipelinesResponse, error)

func (*ExternalServer) GetSchema 

func (s *ExternalServer) GetSchema(ctx context.Context, req *protos.GetSchemaRequest) (*protos.GetSchemaResponse, error)

func (*ExternalServer) PausePipeline 

func (s *ExternalServer) PausePipeline(ctx context.Context, req *protos.PausePipelineRequest) (*protos.StandardResponse, error)

func (*ExternalServer) PauseTail added in v0.0.9 

func (s *ExternalServer) PauseTail(ctx context.Context, req *protos.PauseTailRequest) (*protos.StandardResponse, error)

func (*ExternalServer) ResumePipeline 

func (s *ExternalServer) ResumePipeline(ctx context.Context, req *protos.ResumePipelineRequest) (*protos.StandardResponse, error)

func (*ExternalServer) ResumeTail added in v0.0.9 

func (s *ExternalServer) ResumeTail(ctx context.Context, req *protos.ResumeTailRequest) (*protos.StandardResponse, error)

func (*ExternalServer) Tail 

func (s *ExternalServer) Tail(req *protos.TailRequest, server protos.External_TailServer) error

func (*ExternalServer) Test 

func (s *ExternalServer) Test(_ context.Context, req *protos.TestRequest) (*protos.TestResponse, error)

func (*ExternalServer) UpdateNotification 

func (s *ExternalServer) UpdateNotification(ctx context.Context, req *protos.UpdateNotificationRequest) (*protos.StandardResponse, error)

func (*ExternalServer) UpdatePipeline 

func (s *ExternalServer) UpdatePipeline(ctx context.Context, req *protos.UpdatePipelineRequest) (*protos.StandardResponse, error)

type GRPCAPI 

type GRPCAPI struct {
	Options *Options
	// contains filtered or unexported fields
}

func New 

func New(o *Options) (*GRPCAPI, error)

func (*GRPCAPI) AuthServerStreamInterceptor 

func (g *GRPCAPI) AuthServerStreamInterceptor(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error

func (*GRPCAPI) AuthServerUnaryInterceptor 

func (g *GRPCAPI) AuthServerUnaryInterceptor(ctx context.Context, req interface{}, _ *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)

AuthServerUnaryInterceptor is a GRPC interceptor (middleware) that checks for a valid auth token

func (*GRPCAPI) RequestIDServerStreamInterceptor 

func (g *GRPCAPI) RequestIDServerStreamInterceptor(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error

func (*GRPCAPI) RequestIDServerUnaryInterceptor 

func (g *GRPCAPI) RequestIDServerUnaryInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)

RequestIDServerUnaryInterceptor will set a request ID if one is not already set

func (*GRPCAPI) Run 

func (g *GRPCAPI) Run() error

type InternalServer 

type InternalServer struct {
	GRPCAPI
	// Must be implemented in order to satisfy the protos InternalServer interface
	protos.UnimplementedInternalServer
}

InternalServer implements the internal GRPC API interface

func (*InternalServer) GetAttachCommandsByService 

func (s *InternalServer) GetAttachCommandsByService(
	ctx context.Context,
	req *protos.GetAttachCommandsByServiceRequest,
) (*protos.GetAttachCommandsByServiceResponse, error)

func (*InternalServer) Heartbeat 

func (s *InternalServer) Heartbeat(ctx context.Context, req *protos.HeartbeatRequest) (*protos.StandardResponse, error)

func (*InternalServer) Metrics 

func (s *InternalServer) Metrics(ctx context.Context, req *protos.MetricsRequest) (*protos.StandardResponse, error)

func (*InternalServer) NewAudience 

func (s *InternalServer) NewAudience(ctx context.Context, req *protos.NewAudienceRequest) (*protos.StandardResponse, error)

func (*InternalServer) Notify 

func (s *InternalServer) Notify(ctx context.Context, request *protos.NotifyRequest) (*protos.StandardResponse, error)

func (*InternalServer) Register 

func (s *InternalServer) Register(request *protos.RegisterRequest, server protos.Internal_RegisterServer) error

func (*InternalServer) SendSchema 

func (s *InternalServer) SendSchema(ctx context.Context, req *protos.SendSchemaRequest) (*protos.StandardResponse, error)

func (*InternalServer) SendTail 

func (s *InternalServer) SendTail(srv protos.Internal_SendTailServer) error

type Options 

type Options struct {
	Config          *config.Config
	MetricsService  metrics.IMetrics
	StoreService    store.IStore
	BusService      bus.IBus
	ShutdownContext context.Context
	CmdService      cmd.ICmd
	NotifyService   notify.INotifier
	RedisBackend    *redis.Client
	PubSubService   pubsub.IPubSub
	KVService       kv.IKV
	DemoMode        bool
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.