interflows

package
v0.0.22 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	HookInterflow_Receive_FullMethodName = "/api.interflows.HookInterflow/Receive"
)
View Source 
const OperationHookInterflowReceive = "/api.interflows.HookInterflow/Receive"

Variables

View Source 
var File_interflows_hook_interflow_proto protoreflect.FileDescriptor
View Source 
var HookInterflow_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.interflows.HookInterflow",
	HandlerType: (*HookInterflowServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Receive",
			Handler:    _HookInterflow_Receive_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "interflows/hook_interflow.proto",
}

HookInterflow_ServiceDesc is the grpc.ServiceDesc for HookInterflow service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterHookInterflowHTTPServer 

func RegisterHookInterflowHTTPServer(s *http.Server, srv HookInterflowHTTPServer)

func RegisterHookInterflowServer 

func RegisterHookInterflowServer(s grpc.ServiceRegistrar, srv HookInterflowServer)

Types

type HookInterflowClient 

type HookInterflowClient interface {
	Receive(ctx context.Context, in *ReceiveRequest, opts ...grpc.CallOption) (*ReceiveResponse, error)
}

HookInterflowClient is the client API for HookInterflow 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 NewHookInterflowClient 

func NewHookInterflowClient(cc grpc.ClientConnInterface) HookInterflowClient

type HookInterflowHTTPClient 

type HookInterflowHTTPClient interface {
	Receive(ctx context.Context, req *ReceiveRequest, opts ...http.CallOption) (rsp *ReceiveResponse, err error)
}

func NewHookInterflowHTTPClient 

func NewHookInterflowHTTPClient(client *http.Client) HookInterflowHTTPClient

type HookInterflowHTTPClientImpl 

type HookInterflowHTTPClientImpl struct {
	// contains filtered or unexported fields
}

func (*HookInterflowHTTPClientImpl) Receive 

func (c *HookInterflowHTTPClientImpl) Receive(ctx context.Context, in *ReceiveRequest, opts ...http.CallOption) (*ReceiveResponse, error)

type HookInterflowHTTPServer 

type HookInterflowHTTPServer interface {
	Receive(context.Context, *ReceiveRequest) (*ReceiveResponse, error)
}

type HookInterflowServer 

type HookInterflowServer interface {
	Receive(context.Context, *ReceiveRequest) (*ReceiveResponse, error)
	// contains filtered or unexported methods
}

HookInterflowServer is the server API for HookInterflow service. All implementations must embed UnimplementedHookInterflowServer for forward compatibility

type ReceiveRequest 

type ReceiveRequest struct {
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ReceiveRequest) Descriptor deprecated 

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

Deprecated: Use ReceiveRequest.ProtoReflect.Descriptor instead.

func (*ReceiveRequest) GetTopic 

func (x *ReceiveRequest) GetTopic() string

func (*ReceiveRequest) GetValue 

func (x *ReceiveRequest) GetValue() []byte

func (*ReceiveRequest) ProtoMessage 

func (*ReceiveRequest) ProtoMessage()

func (*ReceiveRequest) ProtoReflect 

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

func (*ReceiveRequest) Reset 

func (x *ReceiveRequest) Reset()

func (*ReceiveRequest) String 

func (x *ReceiveRequest) String() string

func (*ReceiveRequest) Validate 

func (m *ReceiveRequest) Validate() error

Validate checks the field values on ReceiveRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ReceiveRequest) ValidateAll 

func (m *ReceiveRequest) ValidateAll() error

ValidateAll checks the field values on ReceiveRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ReceiveRequestMultiError, or nil if none found.

type ReceiveRequestMultiError 

type ReceiveRequestMultiError []error

ReceiveRequestMultiError is an error wrapping multiple validation errors returned by ReceiveRequest.ValidateAll() if the designated constraints aren't met.

func (ReceiveRequestMultiError) AllErrors 

func (m ReceiveRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ReceiveRequestMultiError) Error 

func (m ReceiveRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ReceiveRequestValidationError 

type ReceiveRequestValidationError struct {
	// contains filtered or unexported fields
}

ReceiveRequestValidationError is the validation error returned by ReceiveRequest.Validate if the designated constraints aren't met.

func (ReceiveRequestValidationError) Cause 

func (e ReceiveRequestValidationError) Cause() error

Cause function returns cause value.

func (ReceiveRequestValidationError) Error 

func (e ReceiveRequestValidationError) Error() string

Error satisfies the builtin error interface

func (ReceiveRequestValidationError) ErrorName 

func (e ReceiveRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ReceiveRequestValidationError) Field 

func (e ReceiveRequestValidationError) Field() string

Field function returns field value.

func (ReceiveRequestValidationError) Key 

func (e ReceiveRequestValidationError) Key() bool

Key function returns key value.

func (ReceiveRequestValidationError) Reason 

func (e ReceiveRequestValidationError) Reason() string

Reason function returns reason value.

type ReceiveResponse 

type ReceiveResponse struct {
	Code    uint32 `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 (*ReceiveResponse) Descriptor deprecated 

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

Deprecated: Use ReceiveResponse.ProtoReflect.Descriptor instead.

func (*ReceiveResponse) GetCode 

func (x *ReceiveResponse) GetCode() uint32

func (*ReceiveResponse) GetMessage 

func (x *ReceiveResponse) GetMessage() string

func (*ReceiveResponse) ProtoMessage 

func (*ReceiveResponse) ProtoMessage()

func (*ReceiveResponse) ProtoReflect 

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

func (*ReceiveResponse) Reset 

func (x *ReceiveResponse) Reset()

func (*ReceiveResponse) String 

func (x *ReceiveResponse) String() string

func (*ReceiveResponse) Validate 

func (m *ReceiveResponse) Validate() error

Validate checks the field values on ReceiveResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ReceiveResponse) ValidateAll 

func (m *ReceiveResponse) ValidateAll() error

ValidateAll checks the field values on ReceiveResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ReceiveResponseMultiError, or nil if none found.

type ReceiveResponseMultiError 

type ReceiveResponseMultiError []error

ReceiveResponseMultiError is an error wrapping multiple validation errors returned by ReceiveResponse.ValidateAll() if the designated constraints aren't met.

func (ReceiveResponseMultiError) AllErrors 

func (m ReceiveResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ReceiveResponseMultiError) Error 

func (m ReceiveResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ReceiveResponseValidationError 

type ReceiveResponseValidationError struct {
	// contains filtered or unexported fields
}

ReceiveResponseValidationError is the validation error returned by ReceiveResponse.Validate if the designated constraints aren't met.

func (ReceiveResponseValidationError) Cause 

func (e ReceiveResponseValidationError) Cause() error

Cause function returns cause value.

func (ReceiveResponseValidationError) Error 

func (e ReceiveResponseValidationError) Error() string

Error satisfies the builtin error interface

func (ReceiveResponseValidationError) ErrorName 

func (e ReceiveResponseValidationError) ErrorName() string

ErrorName returns error name.

func (ReceiveResponseValidationError) Field 

func (e ReceiveResponseValidationError) Field() string

Field function returns field value.

func (ReceiveResponseValidationError) Key 

func (e ReceiveResponseValidationError) Key() bool

Key function returns key value.

func (ReceiveResponseValidationError) Reason 

func (e ReceiveResponseValidationError) Reason() string

Reason function returns reason value.

type UnimplementedHookInterflowServer 

type UnimplementedHookInterflowServer struct {
}

UnimplementedHookInterflowServer must be embedded to have forward compatible implementations.

func (UnimplementedHookInterflowServer) Receive 

func (UnimplementedHookInterflowServer) Receive(context.Context, *ReceiveRequest) (*ReceiveResponse, error)

type UnsafeHookInterflowServer 

type UnsafeHookInterflowServer interface {
	// contains filtered or unexported methods
}

UnsafeHookInterflowServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to HookInterflowServer 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.