ingest

package
v0.0.0-...-6794c67 Latest Latest
Warning

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

 Go to latest Published: Aug 24, 2021 License: Apache-2.0 Imports: 21 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 {
	ProcessComplianceReport(ctx context.Context, in *compliance.Report, opts ...grpc.CallOption) (*empty.Empty, error)
	HandleEvent(ctx context.Context, in *event.EventMsg, opts ...grpc.CallOption) (*event.EventResponse, error)
	ProjectUpdateStatus(ctx context.Context, in *ProjectUpdateStatusReq, opts ...grpc.CallOption) (*ProjectUpdateStatusResp, 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.

func NewComplianceIngesterServiceClient 

func NewComplianceIngesterServiceClient(cc grpc.ClientConnInterface) ComplianceIngesterServiceClient

type ComplianceIngesterServiceServer 

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

ComplianceIngesterServiceServer is the server API for ComplianceIngesterService service.

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 

func (m *MockComplianceIngesterServiceClient) EXPECT() *MockComplianceIngesterServiceClientMockRecorder

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

func (*MockComplianceIngesterServiceClient) HandleEvent 

func (m *MockComplianceIngesterServiceClient) HandleEvent(ctx context.Context, in *event.EventMsg, opts ...grpc.CallOption) (*event.EventResponse, error)

HandleEvent mocks base method

func (*MockComplianceIngesterServiceClient) ProcessComplianceReport 

func (m *MockComplianceIngesterServiceClient) ProcessComplianceReport(ctx context.Context, in *compliance.Report, opts ...grpc.CallOption) (*empty.Empty, error)

ProcessComplianceReport mocks base method

func (*MockComplianceIngesterServiceClient) ProjectUpdateStatus 

func (m *MockComplianceIngesterServiceClient) ProjectUpdateStatus(ctx context.Context, in *ProjectUpdateStatusReq, opts ...grpc.CallOption) (*ProjectUpdateStatusResp, error)

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(ctx, in interface{}, opts ...interface{}) *gomock.Call

HandleEvent indicates an expected call of HandleEvent

func (*MockComplianceIngesterServiceClientMockRecorder) ProcessComplianceReport 

func (mr *MockComplianceIngesterServiceClientMockRecorder) ProcessComplianceReport(ctx, in interface{}, opts ...interface{}) *gomock.Call

ProcessComplianceReport indicates an expected call of ProcessComplianceReport

func (*MockComplianceIngesterServiceClientMockRecorder) ProjectUpdateStatus 

func (mr *MockComplianceIngesterServiceClientMockRecorder) ProjectUpdateStatus(ctx, in interface{}, opts ...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 

func (m *MockComplianceIngesterServiceServer) EXPECT() *MockComplianceIngesterServiceServerMockRecorder

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

func (*MockComplianceIngesterServiceServer) HandleEvent 

func (m *MockComplianceIngesterServiceServer) HandleEvent(arg0 context.Context, arg1 *event.EventMsg) (*event.EventResponse, error)

HandleEvent mocks base method

func (*MockComplianceIngesterServiceServer) ProcessComplianceReport 

func (m *MockComplianceIngesterServiceServer) ProcessComplianceReport(arg0 context.Context, arg1 *compliance.Report) (*empty.Empty, error)

ProcessComplianceReport mocks base method

func (*MockComplianceIngesterServiceServer) ProjectUpdateStatus 

func (m *MockComplianceIngesterServiceServer) ProjectUpdateStatus(arg0 context.Context, arg1 *ProjectUpdateStatusReq) (*ProjectUpdateStatusResp, error)

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, arg1 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 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 *timestamp.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() *timestamp.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 UnimplementedComplianceIngesterServiceServer 

type UnimplementedComplianceIngesterServiceServer struct {
}

UnimplementedComplianceIngesterServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedComplianceIngesterServiceServer) HandleEvent 

func (*UnimplementedComplianceIngesterServiceServer) HandleEvent(context.Context, *event.EventMsg) (*event.EventResponse, error)

func (*UnimplementedComplianceIngesterServiceServer) ProcessComplianceReport 

func (*UnimplementedComplianceIngesterServiceServer) ProcessComplianceReport(context.Context, *compliance.Report) (*empty.Empty, error)

func (*UnimplementedComplianceIngesterServiceServer) ProjectUpdateStatus 

func (*UnimplementedComplianceIngesterServiceServer) ProjectUpdateStatus(context.Context, *ProjectUpdateStatusReq) (*ProjectUpdateStatusResp, error)

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.