Documentation ¶
Index ¶
- Variables
- func RegisterManagerServer(s grpc.ServiceRegistrar, srv ManagerServer)
- type Event
- func (*Event) Descriptor() ([]byte, []int)deprecated
- func (x *Event) GetBody() string
- func (x *Event) GetHeaders() *Headers
- func (x *Event) GetIsBase64Encoded() bool
- func (x *Event) GetRawPath() string
- func (x *Event) GetRawQueryString() string
- func (x *Event) GetRequestContext() *RequestContext
- func (x *Event) GetRouteKey() string
- func (x *Event) GetVersion() string
- func (*Event) ProtoMessage()
- func (x *Event) ProtoReflect() protoreflect.Message
- func (x *Event) Reset()
- func (x *Event) String() string
- type Headers
- func (*Headers) Descriptor() ([]byte, []int)deprecated
- func (x *Headers) GetAccept() string
- func (x *Headers) GetAcceptEncoding() string
- func (x *Headers) GetContentLength() string
- func (x *Headers) GetContentType() string
- func (x *Headers) GetHost() string
- func (x *Headers) GetUserAgent() string
- func (x *Headers) GetXAmznTraceId() string
- func (x *Headers) GetXForwardedFor() string
- func (x *Headers) GetXForwardedPort() string
- func (x *Headers) GetXForwardedProto() string
- func (x *Headers) GetXSlackRequestTimestamp() string
- func (x *Headers) GetXSlackSignature() string
- func (*Headers) ProtoMessage()
- func (x *Headers) ProtoReflect() protoreflect.Message
- func (x *Headers) Reset()
- func (x *Headers) String() string
- type Http
- func (*Http) Descriptor() ([]byte, []int)deprecated
- func (x *Http) GetMethod() string
- func (x *Http) GetPath() string
- func (x *Http) GetProtocol() string
- func (x *Http) GetSourcePp() string
- func (x *Http) GetUserAgent() string
- func (*Http) ProtoMessage()
- func (x *Http) ProtoReflect() protoreflect.Message
- func (x *Http) Reset()
- func (x *Http) String() string
- type ManagerClient
- type ManagerServer
- type Request
- type RequestContext
- func (*RequestContext) Descriptor() ([]byte, []int)deprecated
- func (x *RequestContext) GetAccountId() string
- func (x *RequestContext) GetApiId() string
- func (x *RequestContext) GetDomainName() string
- func (x *RequestContext) GetDomainPrefix() string
- func (x *RequestContext) GetHttp() *Http
- func (x *RequestContext) GetRequestId() string
- func (x *RequestContext) GetRouteKey() string
- func (x *RequestContext) GetStage() string
- func (x *RequestContext) GetTime() string
- func (x *RequestContext) GetTimeEpoch() int64
- func (*RequestContext) ProtoMessage()
- func (x *RequestContext) ProtoReflect() protoreflect.Message
- func (x *RequestContext) Reset()
- func (x *RequestContext) String() string
- type UnimplementedManagerServer
- type UnsafeManagerServer
Constants ¶
This section is empty.
Variables ¶
var File_event_event_proto protoreflect.FileDescriptor
var Manager_ServiceDesc = grpc.ServiceDesc{ ServiceName: "event.Manager", HandlerType: (*ManagerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetEvent", Handler: _Manager_GetEvent_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "event/event.proto", }
Manager_ServiceDesc is the grpc.ServiceDesc for Manager service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterManagerServer ¶
func RegisterManagerServer(s grpc.ServiceRegistrar, srv ManagerServer)
Types ¶
type Event ¶
type Event struct { Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` RouteKey string `protobuf:"bytes,2,opt,name=route_key,json=routeKey,proto3" json:"route_key,omitempty"` RawPath string `protobuf:"bytes,3,opt,name=raw_path,json=rawPath,proto3" json:"raw_path,omitempty"` RawQueryString string `protobuf:"bytes,4,opt,name=raw_query_string,json=rawQueryString,proto3" json:"raw_query_string,omitempty"` Headers *Headers `protobuf:"bytes,5,opt,name=headers,proto3" json:"headers,omitempty"` RequestContext *RequestContext `protobuf:"bytes,6,opt,name=request_context,json=requestContext,proto3" json:"request_context,omitempty"` Body string `protobuf:"bytes,7,opt,name=body,proto3" json:"body,omitempty"` IsBase64Encoded bool `protobuf:"varint,8,opt,name=is_base64_encoded,json=isBase64Encoded,proto3" json:"is_base64_encoded,omitempty"` // contains filtered or unexported fields }
func (*Event) Descriptor
deprecated
func (*Event) GetHeaders ¶
func (*Event) GetIsBase64Encoded ¶
func (*Event) GetRawPath ¶
func (*Event) GetRawQueryString ¶
func (*Event) GetRequestContext ¶
func (x *Event) GetRequestContext() *RequestContext
func (*Event) GetRouteKey ¶
func (*Event) GetVersion ¶
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) ProtoReflect ¶
func (x *Event) ProtoReflect() protoreflect.Message
type Headers ¶
type Headers struct { Accept string `protobuf:"bytes,1,opt,name=accept,proto3" json:"accept,omitempty"` AcceptEncoding string `protobuf:"bytes,2,opt,name=accept_encoding,json=acceptEncoding,proto3" json:"accept_encoding,omitempty"` ContentLength string `protobuf:"bytes,3,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"` ContentType string `protobuf:"bytes,4,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"` Host string `protobuf:"bytes,5,opt,name=host,proto3" json:"host,omitempty"` UserAgent string `protobuf:"bytes,6,opt,name=user_agent,json=userAgent,proto3" json:"user_agent,omitempty"` XAmznTraceId string `protobuf:"bytes,7,opt,name=x_amzn_trace_id,json=xAmznTraceId,proto3" json:"x_amzn_trace_id,omitempty"` XForwardedFor string `protobuf:"bytes,8,opt,name=x_forwarded_for,json=xForwardedFor,proto3" json:"x_forwarded_for,omitempty"` XForwardedPort string `protobuf:"bytes,9,opt,name=x_forwarded_port,json=xForwardedPort,proto3" json:"x_forwarded_port,omitempty"` XForwardedProto string `protobuf:"bytes,10,opt,name=x_forwarded_proto,json=xForwardedProto,proto3" json:"x_forwarded_proto,omitempty"` XSlackRequestTimestamp string `` /* 132-byte string literal not displayed */ XSlackSignature string `protobuf:"bytes,12,opt,name=x_slack_signature,json=xSlackSignature,proto3" json:"x_slack_signature,omitempty"` // contains filtered or unexported fields }
func (*Headers) Descriptor
deprecated
func (*Headers) GetAcceptEncoding ¶
func (*Headers) GetContentLength ¶
func (*Headers) GetContentType ¶
func (*Headers) GetUserAgent ¶
func (*Headers) GetXAmznTraceId ¶
func (*Headers) GetXForwardedFor ¶
func (*Headers) GetXForwardedPort ¶
func (*Headers) GetXForwardedProto ¶
func (*Headers) GetXSlackRequestTimestamp ¶
func (*Headers) GetXSlackSignature ¶
func (*Headers) ProtoMessage ¶
func (*Headers) ProtoMessage()
func (*Headers) ProtoReflect ¶
func (x *Headers) ProtoReflect() protoreflect.Message
type Http ¶
type Http struct { Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"` Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` Protocol string `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty"` SourcePp string `protobuf:"bytes,4,opt,name=source_pp,json=sourcePp,proto3" json:"source_pp,omitempty"` UserAgent string `protobuf:"bytes,5,opt,name=user_agent,json=userAgent,proto3" json:"user_agent,omitempty"` // contains filtered or unexported fields }
func (*Http) Descriptor
deprecated
func (*Http) GetProtocol ¶
func (*Http) GetSourcePp ¶
func (*Http) GetUserAgent ¶
func (*Http) ProtoMessage ¶
func (*Http) ProtoMessage()
func (*Http) ProtoReflect ¶
func (x *Http) ProtoReflect() protoreflect.Message
type ManagerClient ¶
type ManagerClient interface {
GetEvent(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Event, error)
}
ManagerClient is the client API for Manager service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.golang.ir/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewManagerClient ¶
func NewManagerClient(cc grpc.ClientConnInterface) ManagerClient
type ManagerServer ¶
type ManagerServer interface { GetEvent(context.Context, *Request) (*Event, error) // contains filtered or unexported methods }
ManagerServer is the server API for Manager service. All implementations must embed UnimplementedManagerServer for forward compatibility
type Request ¶
type Request struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*Request) Descriptor
deprecated
func (*Request) ProtoMessage ¶
func (*Request) ProtoMessage()
func (*Request) ProtoReflect ¶
func (x *Request) ProtoReflect() protoreflect.Message
type RequestContext ¶
type RequestContext struct { AccountId string `protobuf:"bytes,1,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"` ApiId string `protobuf:"bytes,2,opt,name=api_id,json=apiId,proto3" json:"api_id,omitempty"` DomainName string `protobuf:"bytes,3,opt,name=domain_name,json=domainName,proto3" json:"domain_name,omitempty"` DomainPrefix string `protobuf:"bytes,4,opt,name=domain_prefix,json=domainPrefix,proto3" json:"domain_prefix,omitempty"` Http *Http `protobuf:"bytes,5,opt,name=http,proto3" json:"http,omitempty"` RequestId string `protobuf:"bytes,6,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` RouteKey string `protobuf:"bytes,7,opt,name=route_key,json=routeKey,proto3" json:"route_key,omitempty"` Stage string `protobuf:"bytes,8,opt,name=stage,proto3" json:"stage,omitempty"` Time string `protobuf:"bytes,9,opt,name=time,proto3" json:"time,omitempty"` TimeEpoch int64 `protobuf:"varint,10,opt,name=time_epoch,json=timeEpoch,proto3" json:"time_epoch,omitempty"` // contains filtered or unexported fields }
func (*RequestContext) Descriptor
deprecated
func (*RequestContext) Descriptor() ([]byte, []int)
Deprecated: Use RequestContext.ProtoReflect.Descriptor instead.
func (*RequestContext) GetAccountId ¶
func (x *RequestContext) GetAccountId() string
func (*RequestContext) GetApiId ¶
func (x *RequestContext) GetApiId() string
func (*RequestContext) GetDomainName ¶
func (x *RequestContext) GetDomainName() string
func (*RequestContext) GetDomainPrefix ¶
func (x *RequestContext) GetDomainPrefix() string
func (*RequestContext) GetHttp ¶
func (x *RequestContext) GetHttp() *Http
func (*RequestContext) GetRequestId ¶
func (x *RequestContext) GetRequestId() string
func (*RequestContext) GetRouteKey ¶
func (x *RequestContext) GetRouteKey() string
func (*RequestContext) GetStage ¶
func (x *RequestContext) GetStage() string
func (*RequestContext) GetTime ¶
func (x *RequestContext) GetTime() string
func (*RequestContext) GetTimeEpoch ¶
func (x *RequestContext) GetTimeEpoch() int64
func (*RequestContext) ProtoMessage ¶
func (*RequestContext) ProtoMessage()
func (*RequestContext) ProtoReflect ¶
func (x *RequestContext) ProtoReflect() protoreflect.Message
func (*RequestContext) Reset ¶
func (x *RequestContext) Reset()
func (*RequestContext) String ¶
func (x *RequestContext) String() string
type UnimplementedManagerServer ¶
type UnimplementedManagerServer struct { }
UnimplementedManagerServer must be embedded to have forward compatible implementations.
type UnsafeManagerServer ¶
type UnsafeManagerServer interface {
// contains filtered or unexported methods
}
UnsafeManagerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ManagerServer will result in compilation errors.