ingest

package
v0.0.0-...-f0fd134 Latest Latest
Warning

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

Go to latest
Published: Apr 19, 2024 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Overview

Package ingest is a generated GoMock package.

Package ingest is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source
var File_interservice_compliance_ingest_ingest_compliance_proto protoreflect.FileDescriptor

Functions

func RegisterComplianceIngesterServiceHandler

func RegisterComplianceIngesterServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterComplianceIngesterServiceHandler registers the http handlers for service ComplianceIngesterService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterComplianceIngesterServiceHandlerClient

func RegisterComplianceIngesterServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ComplianceIngesterServiceClient) error

RegisterComplianceIngesterServiceHandlerClient registers the http handlers for service ComplianceIngesterService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ComplianceIngesterServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ComplianceIngesterServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ComplianceIngesterServiceClient" to call the correct interceptors.

func RegisterComplianceIngesterServiceHandlerFromEndpoint

func RegisterComplianceIngesterServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterComplianceIngesterServiceHandlerFromEndpoint is same as RegisterComplianceIngesterServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterComplianceIngesterServiceHandlerServer

func RegisterComplianceIngesterServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ComplianceIngesterServiceServer) error

RegisterComplianceIngesterServiceHandlerServer registers the http handlers for service ComplianceIngesterService to "mux". UnaryRPC :call ComplianceIngesterServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterComplianceIngesterServiceServer

func RegisterComplianceIngesterServiceServer(s *grpc.Server, srv ComplianceIngesterServiceServer)

Types

type ComplianceIngesterServiceClient

type ComplianceIngesterServiceClient interface {
	HandleEvent(ctx context.Context, in *event.EventMsg, opts ...grpc.CallOption) (*event.EventResponse, error)
	ProjectUpdateStatus(ctx context.Context, in *ProjectUpdateStatusReq, opts ...grpc.CallOption) (*ProjectUpdateStatusResp, error)
	ProcessComplianceReport(ctx context.Context, opts ...grpc.CallOption) (ComplianceIngesterService_ProcessComplianceReportClient, error)
}

ComplianceIngesterServiceClient is the client API for ComplianceIngesterService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

type ComplianceIngesterServiceServer

type ComplianceIngesterServiceServer interface {
	HandleEvent(context.Context, *event.EventMsg) (*event.EventResponse, error)
	ProjectUpdateStatus(context.Context, *ProjectUpdateStatusReq) (*ProjectUpdateStatusResp, error)
	ProcessComplianceReport(ComplianceIngesterService_ProcessComplianceReportServer) error
}

ComplianceIngesterServiceServer is the server API for ComplianceIngesterService service.

type ComplianceIngesterService_ProcessComplianceReportClient

type ComplianceIngesterService_ProcessComplianceReportClient interface {
	Send(*ReportData) error
	CloseAndRecv() (*emptypb.Empty, error)
	grpc.ClientStream
}

type ComplianceIngesterService_ProcessComplianceReportServer

type ComplianceIngesterService_ProcessComplianceReportServer interface {
	SendAndClose(*emptypb.Empty) error
	Recv() (*ReportData, error)
	grpc.ServerStream
}

type MockComplianceIngesterServiceClient

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

MockComplianceIngesterServiceClient is a mock of ComplianceIngesterServiceClient interface

func NewMockComplianceIngesterServiceClient

func NewMockComplianceIngesterServiceClient(ctrl *gomock.Controller) *MockComplianceIngesterServiceClient

NewMockComplianceIngesterServiceClient creates a new mock instance

func (*MockComplianceIngesterServiceClient) EXPECT

EXPECT returns an object that allows the caller to indicate expected use

func (*MockComplianceIngesterServiceClient) HandleEvent

HandleEvent mocks base method

func (*MockComplianceIngesterServiceClient) ProcessComplianceReport

ProcessComplianceReport mocks base method

func (*MockComplianceIngesterServiceClient) ProjectUpdateStatus

ProjectUpdateStatus mocks base method

type MockComplianceIngesterServiceClientMockRecorder

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

MockComplianceIngesterServiceClientMockRecorder is the mock recorder for MockComplianceIngesterServiceClient

func (*MockComplianceIngesterServiceClientMockRecorder) HandleEvent

func (mr *MockComplianceIngesterServiceClientMockRecorder) HandleEvent(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

HandleEvent indicates an expected call of HandleEvent

func (*MockComplianceIngesterServiceClientMockRecorder) ProcessComplianceReport

func (mr *MockComplianceIngesterServiceClientMockRecorder) ProcessComplianceReport(arg0 interface{}, arg1 ...interface{}) *gomock.Call

ProcessComplianceReport indicates an expected call of ProcessComplianceReport

func (*MockComplianceIngesterServiceClientMockRecorder) ProjectUpdateStatus

func (mr *MockComplianceIngesterServiceClientMockRecorder) ProjectUpdateStatus(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ProjectUpdateStatus indicates an expected call of ProjectUpdateStatus

type MockComplianceIngesterServiceServer

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

MockComplianceIngesterServiceServer is a mock of ComplianceIngesterServiceServer interface

func NewMockComplianceIngesterServiceServer

func NewMockComplianceIngesterServiceServer(ctrl *gomock.Controller) *MockComplianceIngesterServiceServer

NewMockComplianceIngesterServiceServer creates a new mock instance

func (*MockComplianceIngesterServiceServer) EXPECT

EXPECT returns an object that allows the caller to indicate expected use

func (*MockComplianceIngesterServiceServer) HandleEvent

HandleEvent mocks base method

func (*MockComplianceIngesterServiceServer) ProcessComplianceReport

ProcessComplianceReport mocks base method

func (*MockComplianceIngesterServiceServer) ProjectUpdateStatus

ProjectUpdateStatus mocks base method

type MockComplianceIngesterServiceServerMockRecorder

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

MockComplianceIngesterServiceServerMockRecorder is the mock recorder for MockComplianceIngesterServiceServer

func (*MockComplianceIngesterServiceServerMockRecorder) HandleEvent

func (mr *MockComplianceIngesterServiceServerMockRecorder) HandleEvent(arg0, arg1 interface{}) *gomock.Call

HandleEvent indicates an expected call of HandleEvent

func (*MockComplianceIngesterServiceServerMockRecorder) ProcessComplianceReport

func (mr *MockComplianceIngesterServiceServerMockRecorder) ProcessComplianceReport(arg0 interface{}) *gomock.Call

ProcessComplianceReport indicates an expected call of ProcessComplianceReport

func (*MockComplianceIngesterServiceServerMockRecorder) ProjectUpdateStatus

func (mr *MockComplianceIngesterServiceServerMockRecorder) ProjectUpdateStatus(arg0, arg1 interface{}) *gomock.Call

ProjectUpdateStatus indicates an expected call of ProjectUpdateStatus

type MockComplianceIngesterService_ProcessComplianceReportClient

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

MockComplianceIngesterService_ProcessComplianceReportClient is a mock of ComplianceIngesterService_ProcessComplianceReportClient interface

func NewMockComplianceIngesterService_ProcessComplianceReportClient

func NewMockComplianceIngesterService_ProcessComplianceReportClient(ctrl *gomock.Controller) *MockComplianceIngesterService_ProcessComplianceReportClient

NewMockComplianceIngesterService_ProcessComplianceReportClient creates a new mock instance

func (*MockComplianceIngesterService_ProcessComplianceReportClient) CloseAndRecv

CloseAndRecv mocks base method

func (*MockComplianceIngesterService_ProcessComplianceReportClient) CloseSend

CloseSend mocks base method

func (*MockComplianceIngesterService_ProcessComplianceReportClient) Context

Context mocks base method

func (*MockComplianceIngesterService_ProcessComplianceReportClient) EXPECT

EXPECT returns an object that allows the caller to indicate expected use

func (*MockComplianceIngesterService_ProcessComplianceReportClient) Header

Header mocks base method

func (*MockComplianceIngesterService_ProcessComplianceReportClient) RecvMsg

RecvMsg mocks base method

func (*MockComplianceIngesterService_ProcessComplianceReportClient) Send

Send mocks base method

func (*MockComplianceIngesterService_ProcessComplianceReportClient) SendMsg

SendMsg mocks base method

func (*MockComplianceIngesterService_ProcessComplianceReportClient) Trailer

Trailer mocks base method

type MockComplianceIngesterService_ProcessComplianceReportClientMockRecorder

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

MockComplianceIngesterService_ProcessComplianceReportClientMockRecorder is the mock recorder for MockComplianceIngesterService_ProcessComplianceReportClient

func (*MockComplianceIngesterService_ProcessComplianceReportClientMockRecorder) CloseAndRecv

CloseAndRecv indicates an expected call of CloseAndRecv

func (*MockComplianceIngesterService_ProcessComplianceReportClientMockRecorder) CloseSend

CloseSend indicates an expected call of CloseSend

func (*MockComplianceIngesterService_ProcessComplianceReportClientMockRecorder) Context

Context indicates an expected call of Context

func (*MockComplianceIngesterService_ProcessComplianceReportClientMockRecorder) Header

Header indicates an expected call of Header

func (*MockComplianceIngesterService_ProcessComplianceReportClientMockRecorder) RecvMsg

RecvMsg indicates an expected call of RecvMsg

func (*MockComplianceIngesterService_ProcessComplianceReportClientMockRecorder) Send

Send indicates an expected call of Send

func (*MockComplianceIngesterService_ProcessComplianceReportClientMockRecorder) SendMsg

SendMsg indicates an expected call of SendMsg

func (*MockComplianceIngesterService_ProcessComplianceReportClientMockRecorder) Trailer

Trailer indicates an expected call of Trailer

type MockComplianceIngesterService_ProcessComplianceReportServer

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

MockComplianceIngesterService_ProcessComplianceReportServer is a mock of ComplianceIngesterService_ProcessComplianceReportServer interface

func NewMockComplianceIngesterService_ProcessComplianceReportServer

func NewMockComplianceIngesterService_ProcessComplianceReportServer(ctrl *gomock.Controller) *MockComplianceIngesterService_ProcessComplianceReportServer

NewMockComplianceIngesterService_ProcessComplianceReportServer creates a new mock instance

func (*MockComplianceIngesterService_ProcessComplianceReportServer) Context

Context mocks base method

func (*MockComplianceIngesterService_ProcessComplianceReportServer) EXPECT

EXPECT returns an object that allows the caller to indicate expected use

func (*MockComplianceIngesterService_ProcessComplianceReportServer) Recv

Recv mocks base method

func (*MockComplianceIngesterService_ProcessComplianceReportServer) RecvMsg

RecvMsg mocks base method

func (*MockComplianceIngesterService_ProcessComplianceReportServer) SendAndClose

SendAndClose mocks base method

func (*MockComplianceIngesterService_ProcessComplianceReportServer) SendHeader

SendHeader mocks base method

func (*MockComplianceIngesterService_ProcessComplianceReportServer) SendMsg

SendMsg mocks base method

func (*MockComplianceIngesterService_ProcessComplianceReportServer) SetHeader

SetHeader mocks base method

func (*MockComplianceIngesterService_ProcessComplianceReportServer) SetTrailer

SetTrailer mocks base method

type MockComplianceIngesterService_ProcessComplianceReportServerMockRecorder

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

MockComplianceIngesterService_ProcessComplianceReportServerMockRecorder is the mock recorder for MockComplianceIngesterService_ProcessComplianceReportServer

func (*MockComplianceIngesterService_ProcessComplianceReportServerMockRecorder) Context

Context indicates an expected call of Context

func (*MockComplianceIngesterService_ProcessComplianceReportServerMockRecorder) Recv

Recv indicates an expected call of Recv

func (*MockComplianceIngesterService_ProcessComplianceReportServerMockRecorder) RecvMsg

RecvMsg indicates an expected call of RecvMsg

func (*MockComplianceIngesterService_ProcessComplianceReportServerMockRecorder) SendAndClose

SendAndClose indicates an expected call of SendAndClose

func (*MockComplianceIngesterService_ProcessComplianceReportServerMockRecorder) SendHeader

SendHeader indicates an expected call of SendHeader

func (*MockComplianceIngesterService_ProcessComplianceReportServerMockRecorder) SendMsg

SendMsg indicates an expected call of SendMsg

func (*MockComplianceIngesterService_ProcessComplianceReportServerMockRecorder) SetHeader

SetHeader indicates an expected call of SetHeader

func (*MockComplianceIngesterService_ProcessComplianceReportServerMockRecorder) SetTrailer

SetTrailer indicates an expected call of SetTrailer

type ProjectUpdateStatusReq

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

func (*ProjectUpdateStatusReq) Descriptor deprecated

func (*ProjectUpdateStatusReq) Descriptor() ([]byte, []int)

Deprecated: Use ProjectUpdateStatusReq.ProtoReflect.Descriptor instead.

func (*ProjectUpdateStatusReq) ProtoMessage

func (*ProjectUpdateStatusReq) ProtoMessage()

func (*ProjectUpdateStatusReq) ProtoReflect

func (x *ProjectUpdateStatusReq) ProtoReflect() protoreflect.Message

func (*ProjectUpdateStatusReq) Reset

func (x *ProjectUpdateStatusReq) Reset()

func (*ProjectUpdateStatusReq) String

func (x *ProjectUpdateStatusReq) String() string

type ProjectUpdateStatusResp

type ProjectUpdateStatusResp struct {
	State                 string                 `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty" toml:"state,omitempty" mapstructure:"state,omitempty"`
	EstimatedTimeComplete *timestamppb.Timestamp `` /* 216-byte string literal not displayed */
	PercentageComplete    float32                `` /* 199-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ProjectUpdateStatusResp) Descriptor deprecated

func (*ProjectUpdateStatusResp) Descriptor() ([]byte, []int)

Deprecated: Use ProjectUpdateStatusResp.ProtoReflect.Descriptor instead.

func (*ProjectUpdateStatusResp) GetEstimatedTimeComplete

func (x *ProjectUpdateStatusResp) GetEstimatedTimeComplete() *timestamppb.Timestamp

func (*ProjectUpdateStatusResp) GetPercentageComplete

func (x *ProjectUpdateStatusResp) GetPercentageComplete() float32

func (*ProjectUpdateStatusResp) GetState

func (x *ProjectUpdateStatusResp) GetState() string

func (*ProjectUpdateStatusResp) ProtoMessage

func (*ProjectUpdateStatusResp) ProtoMessage()

func (*ProjectUpdateStatusResp) ProtoReflect

func (x *ProjectUpdateStatusResp) ProtoReflect() protoreflect.Message

func (*ProjectUpdateStatusResp) Reset

func (x *ProjectUpdateStatusResp) Reset()

func (*ProjectUpdateStatusResp) String

func (x *ProjectUpdateStatusResp) String() string

type ReportData

type ReportData struct {
	Content []byte `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty" toml:"content,omitempty" mapstructure:"content,omitempty"`
	// contains filtered or unexported fields
}

func (*ReportData) Descriptor deprecated

func (*ReportData) Descriptor() ([]byte, []int)

Deprecated: Use ReportData.ProtoReflect.Descriptor instead.

func (*ReportData) GetContent

func (x *ReportData) GetContent() []byte

func (*ReportData) ProtoMessage

func (*ReportData) ProtoMessage()

func (*ReportData) ProtoReflect

func (x *ReportData) ProtoReflect() protoreflect.Message

func (*ReportData) Reset

func (x *ReportData) Reset()

func (*ReportData) String

func (x *ReportData) String() string

type UnimplementedComplianceIngesterServiceServer

type UnimplementedComplianceIngesterServiceServer struct {
}

UnimplementedComplianceIngesterServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedComplianceIngesterServiceServer) HandleEvent

func (*UnimplementedComplianceIngesterServiceServer) ProcessComplianceReport

func (*UnimplementedComplianceIngesterServiceServer) ProjectUpdateStatus

Jump to

Keyboard shortcuts

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