Documentation ¶
Index ¶
- Variables
- func RegisterIntakeServer(s *grpc.Server, srv IntakeServer)
- type AuthenticationInfo
- func (*AuthenticationInfo) Descriptor() ([]byte, []int)deprecated
- func (x *AuthenticationInfo) GetIdpProvider() string
- func (x *AuthenticationInfo) GetIdpSubject() string
- func (x *AuthenticationInfo) GetSessionId() string
- func (*AuthenticationInfo) ProtoMessage()
- func (x *AuthenticationInfo) ProtoReflect() protoreflect.Message
- func (x *AuthenticationInfo) Reset()
- func (x *AuthenticationInfo) String() string
- type HTTPRequest
- func (*HTTPRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HTTPRequest) GetBody() string
- func (x *HTTPRequest) GetFragment() string
- func (x *HTTPRequest) GetHeaders() map[string]string
- func (x *HTTPRequest) GetHost() string
- func (x *HTTPRequest) GetId() string
- func (x *HTTPRequest) GetMethod() string
- func (x *HTTPRequest) GetPath() string
- func (x *HTTPRequest) GetProtocol() string
- func (x *HTTPRequest) GetQuery() string
- func (x *HTTPRequest) GetScheme() string
- func (x *HTTPRequest) GetSize() int64
- func (*HTTPRequest) ProtoMessage()
- func (x *HTTPRequest) ProtoReflect() protoreflect.Message
- func (x *HTTPRequest) Reset()
- func (x *HTTPRequest) String() string
- type HTTPResponse
- func (*HTTPResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HTTPResponse) GetBody() string
- func (x *HTTPResponse) GetHeaders() map[string]string
- func (x *HTTPResponse) GetStatusCode() int32
- func (*HTTPResponse) ProtoMessage()
- func (x *HTTPResponse) ProtoReflect() protoreflect.Message
- func (x *HTTPResponse) Reset()
- func (x *HTTPResponse) String() string
- type IntakeClient
- type IntakeServer
- type Intake_PublishClient
- type Intake_PublishServer
- type Record
- func (*Record) Descriptor() ([]byte, []int)deprecated
- func (x *Record) GetAuthenticationInfo() *AuthenticationInfo
- func (x *Record) GetDestination() string
- func (x *Record) GetHttpRequest() *HTTPRequest
- func (x *Record) GetHttpResponse() *HTTPResponse
- func (x *Record) GetId() string
- func (x *Record) GetMetadata() map[string]string
- func (x *Record) GetOrganizationId() string
- func (m *Record) GetRequest() isRecord_Request
- func (m *Record) GetResponse() isRecord_Response
- func (x *Record) GetSource() string
- func (x *Record) GetStatus() *Status
- func (x *Record) GetTime() *timestamp.Timestamp
- func (*Record) ProtoMessage()
- func (x *Record) ProtoReflect() protoreflect.Message
- func (x *Record) Reset()
- func (x *Record) String() string
- type Record_HttpRequest
- type Record_HttpResponse
- type Status
- type UnimplementedIntakeServer
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_PublishServer ¶
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) GetAuthenticationInfo ¶
func (x *Record) GetAuthenticationInfo() *AuthenticationInfo
func (*Record) GetDestination ¶
func (*Record) GetHttpRequest ¶
func (x *Record) GetHttpRequest() *HTTPRequest
func (*Record) GetHttpResponse ¶
func (x *Record) GetHttpResponse() *HTTPResponse
func (*Record) GetMetadata ¶
func (*Record) GetOrganizationId ¶
func (*Record) GetRequest ¶
func (m *Record) GetRequest() isRecord_Request
func (*Record) GetResponse ¶
func (m *Record) GetResponse() isRecord_Response
func (*Record) ProtoMessage ¶
func (*Record) ProtoMessage()
func (*Record) ProtoReflect ¶
func (x *Record) ProtoReflect() protoreflect.Message
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) GetMessage ¶
func (*Status) ProtoMessage ¶
func (*Status) ProtoMessage()
func (*Status) ProtoReflect ¶
func (x *Status) ProtoReflect() protoreflect.Message
type UnimplementedIntakeServer ¶
type UnimplementedIntakeServer struct { }
UnimplementedIntakeServer can be embedded to have forward compatible implementations.
func (*UnimplementedIntakeServer) Publish ¶
func (*UnimplementedIntakeServer) Publish(Intake_PublishServer) error
Click to show internal directories.
Click to hide internal directories.