event

package
v0.0.0-...-108c009 Latest Latest
Warning

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

 Go to latest Published: Apr 24, 2024 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_event_event_proto protoreflect.FileDescriptor
View Source 
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) Descriptor() ([]byte, []int)

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetBody 

func (x *Event) GetBody() string

func (*Event) GetHeaders 

func (x *Event) GetHeaders() *Headers

func (*Event) GetIsBase64Encoded 

func (x *Event) GetIsBase64Encoded() bool

func (*Event) GetRawPath 

func (x *Event) GetRawPath() string

func (*Event) GetRawQueryString 

func (x *Event) GetRawQueryString() string

func (*Event) GetRequestContext 

func (x *Event) GetRequestContext() *RequestContext

func (*Event) GetRouteKey 

func (x *Event) GetRouteKey() string

func (*Event) GetVersion 

func (x *Event) GetVersion() string

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

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

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Headers.ProtoReflect.Descriptor instead.

func (*Headers) GetAccept 

func (x *Headers) GetAccept() string

func (*Headers) GetAcceptEncoding 

func (x *Headers) GetAcceptEncoding() string

func (*Headers) GetContentLength 

func (x *Headers) GetContentLength() string

func (*Headers) GetContentType 

func (x *Headers) GetContentType() string

func (*Headers) GetHost 

func (x *Headers) GetHost() string

func (*Headers) GetUserAgent 

func (x *Headers) GetUserAgent() string

func (*Headers) GetXAmznTraceId 

func (x *Headers) GetXAmznTraceId() string

func (*Headers) GetXForwardedFor 

func (x *Headers) GetXForwardedFor() string

func (*Headers) GetXForwardedPort 

func (x *Headers) GetXForwardedPort() string

func (*Headers) GetXForwardedProto 

func (x *Headers) GetXForwardedProto() string

func (*Headers) GetXSlackRequestTimestamp 

func (x *Headers) GetXSlackRequestTimestamp() string

func (*Headers) GetXSlackSignature 

func (x *Headers) GetXSlackSignature() string

func (*Headers) ProtoMessage 

func (*Headers) ProtoMessage()

func (*Headers) ProtoReflect 

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

func (*Headers) Reset 

func (x *Headers) Reset()

func (*Headers) String 

func (x *Headers) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Http.ProtoReflect.Descriptor instead.

func (*Http) GetMethod 

func (x *Http) GetMethod() string

func (*Http) GetPath 

func (x *Http) GetPath() string

func (*Http) GetProtocol 

func (x *Http) GetProtocol() string

func (*Http) GetSourcePp 

func (x *Http) GetSourcePp() string

func (*Http) GetUserAgent 

func (x *Http) GetUserAgent() string

func (*Http) ProtoMessage 

func (*Http) ProtoMessage()

func (*Http) ProtoReflect 

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

func (*Http) Reset 

func (x *Http) Reset()

func (*Http) String 

func (x *Http) String() string

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.go.dev/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) Descriptor() ([]byte, []int)

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetId 

func (x *Request) GetId() int64

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) ProtoReflect 

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

func (*Request) Reset 

func (x *Request) Reset()

func (*Request) String 

func (x *Request) String() string

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.

func (UnimplementedManagerServer) GetEvent 

func (UnimplementedManagerServer) GetEvent(context.Context, *Request) (*Event, error)

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.

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.