audit

package
v0.12.0 Latest Latest
Warning

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

Go to latest
Published: Jan 8, 2021 License: Apache-2.0 Imports: 11 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_audit_proto protoreflect.FileDescriptor

Functions

func RegisterIntakeServer

func RegisterIntakeServer(s *grpc.Server, srv IntakeServer)

Types

type AuthenticationInfo

type AuthenticationInfo struct {
	SessionId   string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	IdpProvider string `protobuf:"bytes,2,opt,name=idp_provider,json=idpProvider,proto3" json:"idp_provider,omitempty"`
	IdpSubject  string `protobuf:"bytes,3,opt,name=idp_subject,json=idpSubject,proto3" json:"idp_subject,omitempty"`
	// contains filtered or unexported fields
}

func (*AuthenticationInfo) Descriptor deprecated

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

Deprecated: Use AuthenticationInfo.ProtoReflect.Descriptor instead.

func (*AuthenticationInfo) GetIdpProvider

func (x *AuthenticationInfo) GetIdpProvider() string

func (*AuthenticationInfo) GetIdpSubject

func (x *AuthenticationInfo) GetIdpSubject() string

func (*AuthenticationInfo) GetSessionId

func (x *AuthenticationInfo) GetSessionId() string

func (*AuthenticationInfo) ProtoMessage

func (*AuthenticationInfo) ProtoMessage()

func (*AuthenticationInfo) ProtoReflect

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

func (*AuthenticationInfo) Reset

func (x *AuthenticationInfo) Reset()

func (*AuthenticationInfo) String

func (x *AuthenticationInfo) String() string

type HTTPRequest

type HTTPRequest struct {
	Id       string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Method   string            `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Headers  map[string]string `` /* 155-byte string literal not displayed */
	Path     string            `protobuf:"bytes,4,opt,name=path,proto3" json:"path,omitempty"`
	Host     string            `protobuf:"bytes,5,opt,name=host,proto3" json:"host,omitempty"`
	Scheme   string            `protobuf:"bytes,6,opt,name=scheme,proto3" json:"scheme,omitempty"`
	Query    string            `protobuf:"bytes,7,opt,name=query,proto3" json:"query,omitempty"`
	Fragment string            `protobuf:"bytes,8,opt,name=fragment,proto3" json:"fragment,omitempty"`
	Size     int64             `protobuf:"varint,9,opt,name=size,proto3" json:"size,omitempty"`
	Protocol string            `protobuf:"bytes,10,opt,name=protocol,proto3" json:"protocol,omitempty"`
	Body     string            `protobuf:"bytes,11,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*HTTPRequest) Descriptor deprecated

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

Deprecated: Use HTTPRequest.ProtoReflect.Descriptor instead.

func (*HTTPRequest) GetBody

func (x *HTTPRequest) GetBody() string

func (*HTTPRequest) GetFragment

func (x *HTTPRequest) GetFragment() string

func (*HTTPRequest) GetHeaders

func (x *HTTPRequest) GetHeaders() map[string]string

func (*HTTPRequest) GetHost

func (x *HTTPRequest) GetHost() string

func (*HTTPRequest) GetId

func (x *HTTPRequest) GetId() string

func (*HTTPRequest) GetMethod

func (x *HTTPRequest) GetMethod() string

func (*HTTPRequest) GetPath

func (x *HTTPRequest) GetPath() string

func (*HTTPRequest) GetProtocol

func (x *HTTPRequest) GetProtocol() string

func (*HTTPRequest) GetQuery

func (x *HTTPRequest) GetQuery() string

func (*HTTPRequest) GetScheme

func (x *HTTPRequest) GetScheme() string

func (*HTTPRequest) GetSize

func (x *HTTPRequest) GetSize() int64

func (*HTTPRequest) ProtoMessage

func (*HTTPRequest) ProtoMessage()

func (*HTTPRequest) ProtoReflect

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

func (*HTTPRequest) Reset

func (x *HTTPRequest) Reset()

func (*HTTPRequest) String

func (x *HTTPRequest) String() string

type HTTPResponse

type HTTPResponse struct {
	StatusCode int32             `protobuf:"varint,1,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	Headers    map[string]string `` /* 155-byte string literal not displayed */
	Body       string            `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*HTTPResponse) Descriptor deprecated

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

Deprecated: Use HTTPResponse.ProtoReflect.Descriptor instead.

func (*HTTPResponse) GetBody

func (x *HTTPResponse) GetBody() string

func (*HTTPResponse) GetHeaders

func (x *HTTPResponse) GetHeaders() map[string]string

func (*HTTPResponse) GetStatusCode

func (x *HTTPResponse) GetStatusCode() int32

func (*HTTPResponse) ProtoMessage

func (*HTTPResponse) ProtoMessage()

func (*HTTPResponse) ProtoReflect

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

func (*HTTPResponse) Reset

func (x *HTTPResponse) Reset()

func (*HTTPResponse) String

func (x *HTTPResponse) String() string

type IntakeClient

type IntakeClient interface {
	Publish(ctx context.Context, opts ...grpc.CallOption) (Intake_PublishClient, error)
}

IntakeClient is the client API for Intake service.

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

func NewIntakeClient

func NewIntakeClient(cc grpc.ClientConnInterface) IntakeClient

type IntakeServer

type IntakeServer interface {
	Publish(Intake_PublishServer) error
}

IntakeServer is the server API for Intake service.

type Intake_PublishClient

type Intake_PublishClient interface {
	Send(*Record) error
	CloseAndRecv() (*empty.Empty, error)
	grpc.ClientStream
}

type Intake_PublishServer

type Intake_PublishServer interface {
	SendAndClose(*empty.Empty) error
	Recv() (*Record, error)
	grpc.ServerStream
}

type Record

type Record struct {
	OrganizationId     string               `protobuf:"bytes,1,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"`
	Id                 string               `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Time               *timestamp.Timestamp `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	AuthenticationInfo *AuthenticationInfo  `protobuf:"bytes,4,opt,name=authentication_info,json=authenticationInfo,proto3" json:"authentication_info,omitempty"`
	Source             string               `protobuf:"bytes,5,opt,name=source,proto3" json:"source,omitempty"`
	Destination        string               `protobuf:"bytes,6,opt,name=destination,proto3" json:"destination,omitempty"`
	// Types that are assignable to Request:
	//	*Record_HttpRequest
	Request isRecord_Request `protobuf_oneof:"request"`
	// Types that are assignable to Response:
	//	*Record_HttpResponse
	Response isRecord_Response `protobuf_oneof:"response"`
	Status   *Status           `protobuf:"bytes,9,opt,name=status,proto3" json:"status,omitempty"`
	Metadata map[string]string `` /* 158-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Record) Descriptor deprecated

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

Deprecated: Use Record.ProtoReflect.Descriptor instead.

func (*Record) GetAuthenticationInfo

func (x *Record) GetAuthenticationInfo() *AuthenticationInfo

func (*Record) GetDestination

func (x *Record) GetDestination() string

func (*Record) GetHttpRequest

func (x *Record) GetHttpRequest() *HTTPRequest

func (*Record) GetHttpResponse

func (x *Record) GetHttpResponse() *HTTPResponse

func (*Record) GetId

func (x *Record) GetId() string

func (*Record) GetMetadata

func (x *Record) GetMetadata() map[string]string

func (*Record) GetOrganizationId

func (x *Record) GetOrganizationId() string

func (*Record) GetRequest

func (m *Record) GetRequest() isRecord_Request

func (*Record) GetResponse

func (m *Record) GetResponse() isRecord_Response

func (*Record) GetSource

func (x *Record) GetSource() string

func (*Record) GetStatus

func (x *Record) GetStatus() *Status

func (*Record) GetTime

func (x *Record) GetTime() *timestamp.Timestamp

func (*Record) ProtoMessage

func (*Record) ProtoMessage()

func (*Record) ProtoReflect

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

func (*Record) Reset

func (x *Record) Reset()

func (*Record) String

func (x *Record) String() string

type Record_HttpRequest

type Record_HttpRequest struct {
	HttpRequest *HTTPRequest `protobuf:"bytes,7,opt,name=http_request,json=httpRequest,proto3,oneof"`
}

type Record_HttpResponse

type Record_HttpResponse struct {
	HttpResponse *HTTPResponse `protobuf:"bytes,8,opt,name=http_response,json=httpResponse,proto3,oneof"`
}

type Status

type Status struct {
	Code    int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Status) Descriptor deprecated

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetCode

func (x *Status) GetCode() int32

func (*Status) GetMessage

func (x *Status) GetMessage() string

func (*Status) ProtoMessage

func (*Status) ProtoMessage()

func (*Status) ProtoReflect

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

func (*Status) Reset

func (x *Status) Reset()

func (*Status) String

func (x *Status) String() string

type UnimplementedIntakeServer

type UnimplementedIntakeServer struct {
}

UnimplementedIntakeServer can be embedded to have forward compatible implementations.

func (*UnimplementedIntakeServer) Publish

Jump to

Keyboard shortcuts

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