api

package

v0.1.0 Latest Latest Go to latest Published: Jul 25, 2023 License: Apache-2.0 Imports: 32 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/apoxy-dev/proximal

Links

Open Source Insights

Documentation ¶

Index ¶

type EndpointService
- func NewEndpointService(db *serverdb.DB, tc tclient.Client) *EndpointService
type LogsService
- func NewLogsService(db *serverdb.DB) *LogsService
type MiddlewareService
- func NewMiddlewareService(db *serverdb.DB, tc tclient.Client, w *watcher.Watcher) *MiddlewareService

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type EndpointService ¶

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

func NewEndpointService ¶

func NewEndpointService(db *serverdb.DB, tc tclient.Client) *EndpointService

func (*EndpointService) CreateEndpoint ¶

func (s *EndpointService) CreateEndpoint(
	ctx context.Context,
	req *endpointv1.CreateEndpointRequest,
) (*endpointv1.Endpoint, error)

func (*EndpointService) DeleteEndpoint ¶

func (s *EndpointService) DeleteEndpoint(ctx context.Context, req *endpointv1.DeleteEndpointRequest) (*emptypb.Empty, error)

func (*EndpointService) GetEndpoint ¶

func (s *EndpointService) GetEndpoint(ctx context.Context, req *endpointv1.GetEndpointRequest) (*endpointv1.Endpoint, error)

func (*EndpointService) InternalListEndpoints ¶

func (s *EndpointService) InternalListEndpoints(
	ctx context.Context,
	_ *emptypb.Empty,
) (*endpointv1.ListEndpointsResponse, error)

func (*EndpointService) ListEndpoints ¶

func (s *EndpointService) ListEndpoints(
	ctx context.Context,
	req *endpointv1.ListEndpointsRequest,
) (*endpointv1.ListEndpointsResponse, error)

func (*EndpointService) UpdateEndpoint ¶

func (s *EndpointService) UpdateEndpoint(
	ctx context.Context,
	req *endpointv1.UpdateEndpointRequest,
) (*endpointv1.Endpoint, error)

type LogsService ¶

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

LogsService manages request logs using Envoy's access log and tap services.

func NewLogsService ¶

func NewLogsService(db *serverdb.DB) *LogsService

NewLogsService creates a new LogsService.

func (*LogsService) GetFullLog ¶

func (s *LogsService) GetFullLog(ctx context.Context, req *logsv1.GetFullLogRequest) (*logsv1.FullLog, error)

func (*LogsService) GetLogs ¶

func (s *LogsService) GetLogs(ctx context.Context, req *logsv1.GetLogsRequest) (*logsv1.GetLogsResponse, error)

GetLogs returns a stream of logs.

func (*LogsService) RegisterALS ¶

func (s *LogsService) RegisterALS(srv *grpc.Server)

func (*LogsService) StreamAccessLogs ¶

func (s *LogsService) StreamAccessLogs(stream accesslogservicev3.AccessLogService_StreamAccessLogsServer) error

type MiddlewareService ¶

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

MiddlewareService implements the MiddlewareServiceServer gRPC service.

func NewMiddlewareService ¶

func NewMiddlewareService(db *serverdb.DB, tc tclient.Client, w *watcher.Watcher) *MiddlewareService

NewMiddlewareService returns a new MiddlewareService.

func (*MiddlewareService) Create ¶

func (s *MiddlewareService) Create(ctx context.Context, req *middlewarev1.CreateRequest) (*middlewarev1.Middleware, error)

Create starts a new ingest workflow for the given middleware.

func (*MiddlewareService) Delete ¶

func (s *MiddlewareService) Delete(ctx context.Context, req *middlewarev1.DeleteRequest) (*emptypb.Empty, error)

func (*MiddlewareService) Get ¶

func (s *MiddlewareService) Get(ctx context.Context, req *middlewarev1.GetRequest) (*middlewarev1.Middleware, error)

func (*MiddlewareService) GetBuild ¶

func (s *MiddlewareService) GetBuild(ctx context.Context, req *middlewarev1.GetBuildRequest) (*middlewarev1.Build, error)

func (*MiddlewareService) GetBuildOutput ¶

func (s *MiddlewareService) GetBuildOutput(ctx context.Context, req *middlewarev1.GetBuildOutputRequest) (*middlewarev1.BuildOutput, error)

func (*MiddlewareService) GetLiveBuild ¶

func (s *MiddlewareService) GetLiveBuild(ctx context.Context, req *middlewarev1.GetLiveBuildRequest) (*middlewarev1.Build, error)

func (*MiddlewareService) GetLiveBuildOutput ¶

func (s *MiddlewareService) GetLiveBuildOutput(ctx context.Context, req *middlewarev1.GetLiveBuildOutputRequest) (*middlewarev1.BuildOutput, error)

func (*MiddlewareService) InternalList ¶

func (s *MiddlewareService) InternalList(ctx context.Context, _ *empty.Empty) (*middlewarev1.ListResponse, error)

func (*MiddlewareService) List ¶

func (s *MiddlewareService) List(ctx context.Context, req *middlewarev1.ListRequest) (*middlewarev1.ListResponse, error)

func (*MiddlewareService) ListBuilds ¶

func (s *MiddlewareService) ListBuilds(ctx context.Context, req *middlewarev1.ListBuildsRequest) (*middlewarev1.ListBuildsResponse, error)

func (*MiddlewareService) TriggerBuild ¶

func (s *MiddlewareService) TriggerBuild(ctx context.Context, req *middlewarev1.TriggerBuildRequest) (*emptypb.Empty, error)

func (*MiddlewareService) Update ¶

func (s *MiddlewareService) Update(ctx context.Context, req *middlewarev1.UpdateRequest) (*middlewarev1.Middleware, error)

Source Files ¶

View all Source files

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