connectorv1

package
v1.14.0 Latest Latest
Warning

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

 Go to latest Published: Dec 14, 2022 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_azarc_sdk_connector_v1_connector_proto protoreflect.FileDescriptor
View Source 
var File_azarc_sdk_connector_v1_service_proto protoreflect.FileDescriptor
View Source 
var InboundConnectorService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "sdk.connector.v1.InboundConnectorService",
	HandlerType: (*InboundConnectorServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Forward",
			Handler:    _InboundConnectorService_Forward_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "azarc/sdk/connector/v1/service.proto",
}

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

View Source 
var OutboundConnectorService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "sdk.connector.v1.OutboundConnectorService",
	HandlerType: (*OutboundConnectorServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "HandleOutbound",
			Handler:    _OutboundConnectorService_HandleOutbound_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "azarc/sdk/connector/v1/service.proto",
}

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

Functions

func RegisterInboundConnectorServiceServer 

func RegisterInboundConnectorServiceServer(s grpc.ServiceRegistrar, srv InboundConnectorServiceServer)

func RegisterOutboundConnectorServiceServer 

func RegisterOutboundConnectorServiceServer(s grpc.ServiceRegistrar, srv OutboundConnectorServiceServer)

Types

type ForwardRequest 

type ForwardRequest struct {

	// Body of the message
	Payload *structpb.Struct `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// Message headers
	Headers map[string]string `` /* 155-byte string literal not displayed */
	// User defined name for the message
	MessageName string `protobuf:"bytes,3,opt,name=message_name,json=messageName,proto3" json:"message_name,omitempty"`
	// Connector id that made the request
	ConnectorId string `protobuf:"bytes,4,opt,name=connector_id,json=connectorId,proto3" json:"connector_id,omitempty"`
	// The environment the connector is running in
	Environment string `protobuf:"bytes,5,opt,name=environment,proto3" json:"environment,omitempty"`
	// contains filtered or unexported fields
}

func (*ForwardRequest) Descriptor deprecated 

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

Deprecated: Use ForwardRequest.ProtoReflect.Descriptor instead.

func (*ForwardRequest) GetConnectorId added in v1.13.0 

func (x *ForwardRequest) GetConnectorId() string

func (*ForwardRequest) GetEnvironment added in v1.13.0 

func (x *ForwardRequest) GetEnvironment() string

func (*ForwardRequest) GetHeaders 

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

func (*ForwardRequest) GetMessageName added in v1.13.0 

func (x *ForwardRequest) GetMessageName() string

func (*ForwardRequest) GetPayload added in v1.13.0 

func (x *ForwardRequest) GetPayload() *structpb.Struct

func (*ForwardRequest) ProtoMessage 

func (*ForwardRequest) ProtoMessage()

func (*ForwardRequest) ProtoReflect 

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

func (*ForwardRequest) Reset 

func (x *ForwardRequest) Reset()

func (*ForwardRequest) String 

func (x *ForwardRequest) String() string

type ForwardResponse 

type ForwardResponse struct {
	Payload *structpb.Struct  `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Headers map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ForwardResponse) Descriptor deprecated 

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

Deprecated: Use ForwardResponse.ProtoReflect.Descriptor instead.

func (*ForwardResponse) GetHeaders 

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

func (*ForwardResponse) GetPayload added in v1.13.0 

func (x *ForwardResponse) GetPayload() *structpb.Struct

func (*ForwardResponse) ProtoMessage 

func (*ForwardResponse) ProtoMessage()

func (*ForwardResponse) ProtoReflect 

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

func (*ForwardResponse) Reset 

func (x *ForwardResponse) Reset()

func (*ForwardResponse) String 

func (x *ForwardResponse) String() string

type HandleOutboundRequest 

type HandleOutboundRequest struct {
	Body    *structpb.Struct     `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	Headers map[string]*v1.Value `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*HandleOutboundRequest) Descriptor deprecated 

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

Deprecated: Use HandleOutboundRequest.ProtoReflect.Descriptor instead.

func (*HandleOutboundRequest) GetBody 

func (x *HandleOutboundRequest) GetBody() *structpb.Struct

func (*HandleOutboundRequest) GetHeaders 

func (x *HandleOutboundRequest) GetHeaders() map[string]*v1.Value

func (*HandleOutboundRequest) ProtoMessage 

func (*HandleOutboundRequest) ProtoMessage()

func (*HandleOutboundRequest) ProtoReflect 

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

func (*HandleOutboundRequest) Reset 

func (x *HandleOutboundRequest) Reset()

func (*HandleOutboundRequest) String 

func (x *HandleOutboundRequest) String() string

type HandleOutboundResponse 

type HandleOutboundResponse struct {
	Body    *structpb.Struct     `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	Headers map[string]*v1.Value `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*HandleOutboundResponse) Descriptor deprecated 

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

Deprecated: Use HandleOutboundResponse.ProtoReflect.Descriptor instead.

func (*HandleOutboundResponse) GetBody 

func (x *HandleOutboundResponse) GetBody() *structpb.Struct

func (*HandleOutboundResponse) GetHeaders 

func (x *HandleOutboundResponse) GetHeaders() map[string]*v1.Value

func (*HandleOutboundResponse) ProtoMessage 

func (*HandleOutboundResponse) ProtoMessage()

func (*HandleOutboundResponse) ProtoReflect 

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

func (*HandleOutboundResponse) Reset 

func (x *HandleOutboundResponse) Reset()

func (*HandleOutboundResponse) String 

func (x *HandleOutboundResponse) String() string

type InboundConnectorServiceClient 

type InboundConnectorServiceClient interface {
	Forward(ctx context.Context, in *ForwardRequest, opts ...grpc.CallOption) (*ForwardResponse, error)
}

InboundConnectorServiceClient is the client API for InboundConnectorService 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 NewInboundConnectorServiceClient 

func NewInboundConnectorServiceClient(cc grpc.ClientConnInterface) InboundConnectorServiceClient

type InboundConnectorServiceServer 

type InboundConnectorServiceServer interface {
	Forward(context.Context, *ForwardRequest) (*ForwardResponse, error)
}

InboundConnectorServiceServer is the server API for InboundConnectorService service. All implementations should embed UnimplementedInboundConnectorServiceServer for forward compatibility

type InboundMessageConfiguration 

type InboundMessageConfiguration struct {

	// The json configuration data as filled in by the user and pre-processed by the agent
	Data *structpb.Struct `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

Wraps the configuration of an inbound message

func (*InboundMessageConfiguration) Descriptor deprecated 

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

Deprecated: Use InboundMessageConfiguration.ProtoReflect.Descriptor instead.

func (*InboundMessageConfiguration) GetData 

func (x *InboundMessageConfiguration) GetData() *structpb.Struct

func (*InboundMessageConfiguration) ProtoMessage 

func (*InboundMessageConfiguration) ProtoMessage()

func (*InboundMessageConfiguration) ProtoReflect 

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

func (*InboundMessageConfiguration) Reset 

func (x *InboundMessageConfiguration) Reset()

func (*InboundMessageConfiguration) String 

func (x *InboundMessageConfiguration) String() string

type InboundMessageDescriptor 

type InboundMessageDescriptor struct {

	// Message ID
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// User defined name for the message
	MessageName string `protobuf:"bytes,2,opt,name=message_name,json=messageName,proto3" json:"message_name,omitempty"`
	// Connector id that made the request
	ConnectorId string `protobuf:"bytes,3,opt,name=connector_id,json=connectorId,proto3" json:"connector_id,omitempty"`
	// The environment the connector is running in
	Environment string `protobuf:"bytes,4,opt,name=environment,proto3" json:"environment,omitempty"`
	// Message configuration
	Config *InboundMessageConfiguration `protobuf:"bytes,5,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

Describes a single inbound message type

func (*InboundMessageDescriptor) Descriptor deprecated 

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

Deprecated: Use InboundMessageDescriptor.ProtoReflect.Descriptor instead.

func (*InboundMessageDescriptor) GetConfig 

func (x *InboundMessageDescriptor) GetConfig() *InboundMessageConfiguration

func (*InboundMessageDescriptor) GetConnectorId added in v1.13.0 

func (x *InboundMessageDescriptor) GetConnectorId() string

func (*InboundMessageDescriptor) GetEnvironment added in v1.13.0 

func (x *InboundMessageDescriptor) GetEnvironment() string

func (*InboundMessageDescriptor) GetId 

func (x *InboundMessageDescriptor) GetId() string

func (*InboundMessageDescriptor) GetMessageName 

func (x *InboundMessageDescriptor) GetMessageName() string

func (*InboundMessageDescriptor) ProtoMessage 

func (*InboundMessageDescriptor) ProtoMessage()

func (*InboundMessageDescriptor) ProtoReflect 

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

func (*InboundMessageDescriptor) Reset 

func (x *InboundMessageDescriptor) Reset()

func (*InboundMessageDescriptor) String 

func (x *InboundMessageDescriptor) String() string

type MessageDescriptors 

type MessageDescriptors struct {

	// Inbound message types
	Outbound *OutboundMessageDescriptor `protobuf:"bytes,1,opt,name=outbound,proto3" json:"outbound,omitempty"`
	// Outbound message types
	Inbound *InboundMessageDescriptor `protobuf:"bytes,2,opt,name=inbound,proto3" json:"inbound,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageDescriptors) Descriptor deprecated 

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

Deprecated: Use MessageDescriptors.ProtoReflect.Descriptor instead.

func (*MessageDescriptors) GetInbound 

func (x *MessageDescriptors) GetInbound() *InboundMessageDescriptor

func (*MessageDescriptors) GetOutbound 

func (x *MessageDescriptors) GetOutbound() *OutboundMessageDescriptor

func (*MessageDescriptors) ProtoMessage 

func (*MessageDescriptors) ProtoMessage()

func (*MessageDescriptors) ProtoReflect 

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

func (*MessageDescriptors) Reset 

func (x *MessageDescriptors) Reset()

func (*MessageDescriptors) String 

func (x *MessageDescriptors) String() string

type OutboundConnectorServiceClient 

type OutboundConnectorServiceClient interface {
	HandleOutbound(ctx context.Context, in *HandleOutboundRequest, opts ...grpc.CallOption) (*HandleOutboundResponse, error)
}

OutboundConnectorServiceClient is the client API for OutboundConnectorService 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 NewOutboundConnectorServiceClient 

func NewOutboundConnectorServiceClient(cc grpc.ClientConnInterface) OutboundConnectorServiceClient

type OutboundConnectorServiceServer 

type OutboundConnectorServiceServer interface {
	HandleOutbound(context.Context, *HandleOutboundRequest) (*HandleOutboundResponse, error)
}

OutboundConnectorServiceServer is the server API for OutboundConnectorService service. All implementations should embed UnimplementedOutboundConnectorServiceServer for forward compatibility

type OutboundMessageConfiguration 

type OutboundMessageConfiguration struct {

	// The json configuration data as filled in by the user and pre-processed by the agent
	Data *structpb.Struct `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*OutboundMessageConfiguration) Descriptor deprecated 

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

Deprecated: Use OutboundMessageConfiguration.ProtoReflect.Descriptor instead.

func (*OutboundMessageConfiguration) GetData 

func (x *OutboundMessageConfiguration) GetData() *structpb.Struct

func (*OutboundMessageConfiguration) ProtoMessage 

func (*OutboundMessageConfiguration) ProtoMessage()

func (*OutboundMessageConfiguration) ProtoReflect 

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

func (*OutboundMessageConfiguration) Reset 

func (x *OutboundMessageConfiguration) Reset()

func (*OutboundMessageConfiguration) String 

func (x *OutboundMessageConfiguration) String() string

type OutboundMessageDescriptor 

type OutboundMessageDescriptor struct {

	// User defined name for the message
	MessageName string `protobuf:"bytes,1,opt,name=message_name,json=messageName,proto3" json:"message_name,omitempty"`
	// Correlation ID from the process making the request
	CorrelationId string `protobuf:"bytes,2,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	// Transaction ID from the process making the request
	TransactionId string `protobuf:"bytes,3,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	// Message configuration
	Config *InboundMessageConfiguration `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*OutboundMessageDescriptor) Descriptor deprecated 

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

Deprecated: Use OutboundMessageDescriptor.ProtoReflect.Descriptor instead.

func (*OutboundMessageDescriptor) GetConfig 

func (x *OutboundMessageDescriptor) GetConfig() *InboundMessageConfiguration

func (*OutboundMessageDescriptor) GetCorrelationId 

func (x *OutboundMessageDescriptor) GetCorrelationId() string

func (*OutboundMessageDescriptor) GetMessageName 

func (x *OutboundMessageDescriptor) GetMessageName() string

func (*OutboundMessageDescriptor) GetTransactionId 

func (x *OutboundMessageDescriptor) GetTransactionId() string

func (*OutboundMessageDescriptor) ProtoMessage 

func (*OutboundMessageDescriptor) ProtoMessage()

func (*OutboundMessageDescriptor) ProtoReflect 

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

func (*OutboundMessageDescriptor) Reset 

func (x *OutboundMessageDescriptor) Reset()

func (*OutboundMessageDescriptor) String 

func (x *OutboundMessageDescriptor) String() string

type UnimplementedInboundConnectorServiceServer 

type UnimplementedInboundConnectorServiceServer struct {
}

UnimplementedInboundConnectorServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedInboundConnectorServiceServer) Forward 

func (UnimplementedInboundConnectorServiceServer) Forward(context.Context, *ForwardRequest) (*ForwardResponse, error)

type UnimplementedOutboundConnectorServiceServer 

type UnimplementedOutboundConnectorServiceServer struct {
}

UnimplementedOutboundConnectorServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedOutboundConnectorServiceServer) HandleOutbound 

func (UnimplementedOutboundConnectorServiceServer) HandleOutbound(context.Context, *HandleOutboundRequest) (*HandleOutboundResponse, error)

type UnsafeInboundConnectorServiceServer 

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

UnsafeInboundConnectorServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to InboundConnectorServiceServer will result in compilation errors.

type UnsafeOutboundConnectorServiceServer 

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

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