proxy

type BinaryMessageWithSender struct {
	Msg    []byte `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	Sender uint32 `protobuf:"varint,2,opt,name=sender,proto3" json:"sender,omitempty"`
	// contains filtered or unexported fields
}

type BinaryNetworkClientRequest struct {

	// Types that are valid to be assigned to Message:
	//
	//	*BinaryNetworkClientRequest_NewEndpoint
	//	*BinaryNetworkClientRequest_SendTo
	//	*BinaryNetworkClientRequest_Broadcast
	Message isBinaryNetworkClientRequest_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

type BinaryNetworkClientRequest_Broadcast struct {
	Broadcast []byte `protobuf:"bytes,3,opt,name=broadcast,proto3,oneof"`
}

type BinaryNetworkClientRequest_NewEndpoint struct {
	NewEndpoint *NewEndpointRequest `protobuf:"bytes,1,opt,name=newEndpoint,proto3,oneof"`
}

type BinaryNetworkClientRequest_SendTo struct {
	SendTo *SendToRequest `protobuf:"bytes,2,opt,name=sendTo,proto3,oneof"`
}

type BinaryNetworkEndpointLimits struct {
	MaxMessageLength          int32   `protobuf:"varint,1,opt,name=max_message_length,json=maxMessageLength,proto3" json:"max_message_length,omitempty"`
	MessagesRatePerOracle     float64 `` /* 130-byte string literal not displayed */
	MessagesCapacityPerOracle int32   `` /* 141-byte string literal not displayed */
	BytesRatePerOracle        float64 `protobuf:"fixed64,4,opt,name=bytes_rate_per_oracle,json=bytesRatePerOracle,proto3" json:"bytes_rate_per_oracle,omitempty"`
	BytesCapacityPerOracle    int32   `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

type BinaryNetworkEndpointProxyClient interface {
	Connect(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[BinaryNetworkClientRequest, BinaryMessageWithSender], error)
}

type BinaryNetworkEndpointProxyServer interface {
	Connect(grpc.BidiStreamingServer[BinaryNetworkClientRequest, BinaryMessageWithSender]) error
	// contains filtered or unexported methods
}

type BinaryNetworkEndpointProxy_ConnectClient = grpc.BidiStreamingClient[BinaryNetworkClientRequest, BinaryMessageWithSender]

type BinaryNetworkEndpointProxy_ConnectServer = grpc.BidiStreamingServer[BinaryNetworkClientRequest, BinaryMessageWithSender]

type BootstrapperInfo struct {
	PeerID string
	Addrs  []string
}

type BootstrapperLocator struct {
	PeerId string   `protobuf:"bytes,1,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	Addrs  []string `protobuf:"bytes,2,rep,name=addrs,proto3" json:"addrs,omitempty"`
	// contains filtered or unexported fields
}

type ClosableBinaryNetworkEndpoint2Factory interface {
	ocr2types.BinaryNetworkEndpoint2Factory
	io.Closer
}

type ClosableBinaryNetworkEndpointFactory interface {
	types.BinaryNetworkEndpointFactory
	io.Closer
}

type ClosablePeerGroupFactory interface {
	PeerGroupFactory
	io.Closer
}

type CloseStreamRequest struct {
	StreamId string `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	// contains filtered or unexported fields
}

type Endpoint2ClientRequest struct {

	// Types that are valid to be assigned to Message:
	//
	//	*Endpoint2ClientRequest_NewEndpoint
	//	*Endpoint2ClientRequest_SendTo
	//	*Endpoint2ClientRequest_Broadcast
	Message isEndpoint2ClientRequest_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

type Endpoint2ClientRequest_Broadcast struct {
	Broadcast *Endpoint2Send `protobuf:"bytes,3,opt,name=broadcast,proto3,oneof"` // to_oracle_id is ignored
}

type Endpoint2ClientRequest_NewEndpoint struct {
	NewEndpoint *NewEndpoint2Request `protobuf:"bytes,1,opt,name=new_endpoint,json=newEndpoint,proto3,oneof"` // must be the first message
}

type Endpoint2ClientRequest_SendTo struct {
	SendTo *Endpoint2Send `protobuf:"bytes,2,opt,name=send_to,json=sendTo,proto3,oneof"`
}

type Endpoint2Config struct {
	Limits                            *BinaryNetworkEndpointLimits `protobuf:"bytes,1,opt,name=limits,proto3" json:"limits,omitempty"`
	OverrideIncomingMessageBufferSize *int32                       `` /* 173-byte string literal not displayed */
	OverrideOutgoingMessageBufferSize *int32                       `` /* 173-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Endpoint2ProxyClient interface {
	// Connect manages the lifetime of a single BinaryNetworkEndpoint2. The first
	// message must be NewEndpoint2Request; afterwards the stream carries
	// SendTo/Broadcast up and received messages down.
	Connect(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[Endpoint2ClientRequest, Endpoint2ServerMessage], error)
}

type Endpoint2ProxyServer interface {
	// Connect manages the lifetime of a single BinaryNetworkEndpoint2. The first
	// message must be NewEndpoint2Request; afterwards the stream carries
	// SendTo/Broadcast up and received messages down.
	Connect(grpc.BidiStreamingServer[Endpoint2ClientRequest, Endpoint2ServerMessage]) error
	// contains filtered or unexported methods
}

type Endpoint2Proxy_ConnectClient = grpc.BidiStreamingClient[Endpoint2ClientRequest, Endpoint2ServerMessage]

type Endpoint2Proxy_ConnectServer = grpc.BidiStreamingServer[Endpoint2ClientRequest, Endpoint2ServerMessage]

type Endpoint2Send struct {
	ToOracleId uint32            `protobuf:"varint,1,opt,name=to_oracle_id,json=toOracleId,proto3" json:"to_oracle_id,omitempty"`
	Msg        *OutboundMessage2 `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

type Endpoint2ServerMessage struct {
	Sender   uint32 `protobuf:"varint,1,opt,name=sender,proto3" json:"sender,omitempty"`
	Payload  []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	Priority uint32 `protobuf:"varint,3,opt,name=priority,proto3" json:"priority,omitempty"` // raw ocr2types.BinaryMessageOutboundPriority value
	// Types that are valid to be assigned to Kind:
	//
	//	*Endpoint2ServerMessage_Plain
	//	*Endpoint2ServerMessage_Request
	//	*Endpoint2ServerMessage_Response
	Kind isEndpoint2ServerMessage_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

type Endpoint2ServerMessage_Plain struct {
	Plain *InboundPlain2 `protobuf:"bytes,4,opt,name=plain,proto3,oneof"`
}

type Endpoint2ServerMessage_Request struct {
	Request *InboundRequest2 `protobuf:"bytes,5,opt,name=request,proto3,oneof"`
}

type Endpoint2ServerMessage_Response struct {
	Response *InboundResponse2 `protobuf:"bytes,6,opt,name=response,proto3,oneof"`
}

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

type InboundRequest2 struct {
	RequestId uint64 `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

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

type NewEndpoint2Request struct {
	ConfigDigest          []byte                 `protobuf:"bytes,1,opt,name=config_digest,json=configDigest,proto3" json:"config_digest,omitempty"`
	PeerIds               []string               `protobuf:"bytes,2,rep,name=peer_ids,json=peerIds,proto3" json:"peer_ids,omitempty"`
	V2Bootstrappers       []*BootstrapperLocator `protobuf:"bytes,3,rep,name=v2_bootstrappers,json=v2Bootstrappers,proto3" json:"v2_bootstrappers,omitempty"`
	DefaultPriorityConfig *Endpoint2Config       `` /* 126-byte string literal not displayed */
	LowPriorityConfig     *Endpoint2Config       `protobuf:"bytes,5,opt,name=low_priority_config,json=lowPriorityConfig,proto3" json:"low_priority_config,omitempty"`
	// contains filtered or unexported fields
}

type NewEndpointRequest struct {
	ConfigDigest     []byte                       `protobuf:"bytes,1,opt,name=config_digest,json=configDigest,proto3" json:"config_digest,omitempty"`
	PeerIds          []string                     `protobuf:"bytes,2,rep,name=peer_ids,json=peerIds,proto3" json:"peer_ids,omitempty"`
	V2Bootstrappers  []*BootstrapperLocator       `protobuf:"bytes,3,rep,name=v2_bootstrappers,json=v2Bootstrappers,proto3" json:"v2_bootstrappers,omitempty"`
	FailureThreshold int32                        `protobuf:"varint,4,opt,name=failure_threshold,json=failureThreshold,proto3" json:"failure_threshold,omitempty"`
	Limits           *BinaryNetworkEndpointLimits `protobuf:"bytes,5,opt,name=limits,proto3" json:"limits,omitempty"`
	// contains filtered or unexported fields
}

type NewPeerGroupRequest struct {
	ConfigDigest    []byte                 `protobuf:"bytes,1,opt,name=config_digest,json=configDigest,proto3" json:"config_digest,omitempty"`
	PeerIds         []string               `protobuf:"bytes,2,rep,name=peer_ids,json=peerIds,proto3" json:"peer_ids,omitempty"`
	V2Bootstrappers []*BootstrapperLocator `protobuf:"bytes,3,rep,name=v2_bootstrappers,json=v2Bootstrappers,proto3" json:"v2_bootstrappers,omitempty"`
	// contains filtered or unexported fields
}

type NewStreamRequest struct {

	// stream_id is a client-assigned handle used to correlate SendTo/Recv/Close
	// for this stream within the group connection.
	StreamId           string             `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	RemotePeerId       string             `protobuf:"bytes,2,opt,name=remote_peer_id,json=remotePeerId,proto3" json:"remote_peer_id,omitempty"`
	StreamName         string             `protobuf:"bytes,3,opt,name=stream_name,json=streamName,proto3" json:"stream_name,omitempty"`
	OutgoingBufferSize int32              `protobuf:"varint,4,opt,name=outgoing_buffer_size,json=outgoingBufferSize,proto3" json:"outgoing_buffer_size,omitempty"`
	IncomingBufferSize int32              `protobuf:"varint,5,opt,name=incoming_buffer_size,json=incomingBufferSize,proto3" json:"incoming_buffer_size,omitempty"`
	MaxMessageLength   int32              `protobuf:"varint,6,opt,name=max_message_length,json=maxMessageLength,proto3" json:"max_message_length,omitempty"`
	MessagesLimit      *TokenBucketParams `protobuf:"bytes,7,opt,name=messages_limit,json=messagesLimit,proto3" json:"messages_limit,omitempty"`
	BytesLimit         *TokenBucketParams `protobuf:"bytes,8,opt,name=bytes_limit,json=bytesLimit,proto3" json:"bytes_limit,omitempty"`
	// contains filtered or unexported fields
}

type OutboundMessage2 struct {
	Payload  []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Priority uint32 `protobuf:"varint,2,opt,name=priority,proto3" json:"priority,omitempty"` // raw ocr2types.BinaryMessageOutboundPriority value
	// Types that are valid to be assigned to Kind:
	//
	//	*OutboundMessage2_Plain
	//	*OutboundMessage2_Request
	//	*OutboundMessage2_Response
	Kind isOutboundMessage2_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

type OutboundMessage2_Plain struct {
	Plain *OutboundPlain2 `protobuf:"bytes,3,opt,name=plain,proto3,oneof"`
}

type OutboundMessage2_Request struct {
	Request *OutboundRequest2 `protobuf:"bytes,4,opt,name=request,proto3,oneof"`
}

type OutboundMessage2_Response struct {
	Response *OutboundResponse2 `protobuf:"bytes,5,opt,name=response,proto3,oneof"`
}

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

type OutboundRequest2 struct {

	// SingleUseSizedLimitedResponsePolicy fields.
	PolicyMaxSize      int64 `protobuf:"varint,1,opt,name=policy_max_size,json=policyMaxSize,proto3" json:"policy_max_size,omitempty"`
	PolicyExpiryUnixMs int64 `protobuf:"varint,2,opt,name=policy_expiry_unix_ms,json=policyExpiryUnixMs,proto3" json:"policy_expiry_unix_ms,omitempty"`
	// contains filtered or unexported fields
}

type OutboundResponse2 struct {

	// Refers to the request_id of the InboundRequest2 being responded to; the
	// server holds the real libocr RequestHandle keyed by this id.
	RequestId uint64 `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

type PeerGroup interface {
	NewStream(remotePeerID string, args StreamArgs) (PeerGroupStream, error)
	Close() error
}

type PeerGroupClientRequest struct {

	// Types that are valid to be assigned to Message:
	//
	//	*PeerGroupClientRequest_NewPeerGroup
	//	*PeerGroupClientRequest_NewStream
	//	*PeerGroupClientRequest_CloseStream
	//	*PeerGroupClientRequest_StreamSend
	Message isPeerGroupClientRequest_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

type PeerGroupClientRequest_CloseStream struct {
	CloseStream *CloseStreamRequest `protobuf:"bytes,3,opt,name=close_stream,json=closeStream,proto3,oneof"`
}

type PeerGroupClientRequest_NewPeerGroup struct {
	NewPeerGroup *NewPeerGroupRequest `protobuf:"bytes,1,opt,name=new_peer_group,json=newPeerGroup,proto3,oneof"` // must be the first message
}

type PeerGroupClientRequest_NewStream struct {
	NewStream *NewStreamRequest `protobuf:"bytes,2,opt,name=new_stream,json=newStream,proto3,oneof"`
}

type PeerGroupClientRequest_StreamSend struct {
	StreamSend *StreamSend `protobuf:"bytes,4,opt,name=stream_send,json=streamSend,proto3,oneof"`
}

type PeerGroupFactory interface {
	NewPeerGroup(configDigest [32]byte, peerIDs []string, bootstrappers []BootstrapperInfo) (PeerGroup, error)
}

type PeerGroupProxyClient interface {
	// Connect manages the lifetime of a single PeerGroup. The first message on
	// the stream must be NewPeerGroup. Streams opened within the group are
	// multiplexed over this one connection; closing the connection closes the
	// group and all of its streams.
	Connect(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[PeerGroupClientRequest, PeerGroupServerMessage], error)
}

type PeerGroupProxyServer interface {
	// Connect manages the lifetime of a single PeerGroup. The first message on
	// the stream must be NewPeerGroup. Streams opened within the group are
	// multiplexed over this one connection; closing the connection closes the
	// group and all of its streams.
	Connect(grpc.BidiStreamingServer[PeerGroupClientRequest, PeerGroupServerMessage]) error
	// contains filtered or unexported methods
}

type PeerGroupProxy_ConnectClient = grpc.BidiStreamingClient[PeerGroupClientRequest, PeerGroupServerMessage]

type PeerGroupProxy_ConnectServer = grpc.BidiStreamingServer[PeerGroupClientRequest, PeerGroupServerMessage]

type PeerGroupServerMessage struct {

	// Types that are valid to be assigned to Message:
	//
	//	*PeerGroupServerMessage_StreamRecv
	Message isPeerGroupServerMessage_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

type PeerGroupServerMessage_StreamRecv struct {
	StreamRecv *StreamRecv `protobuf:"bytes,1,opt,name=stream_recv,json=streamRecv,proto3,oneof"`
}

type PeerGroupStream interface {
	SendMessage(data []byte)
	ReceiveMessages() <-chan []byte
	Close() error
}

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

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

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

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

type RateLimit struct {
	Rate     float64
	Capacity uint32
}

type SendToRequest struct {
	Payload    []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	ToOracleId uint32 `protobuf:"varint,3,opt,name=to_oracle_id,json=toOracleId,proto3" json:"to_oracle_id,omitempty"`
	// contains filtered or unexported fields
}

type StreamArgs struct {
	StreamName         string
	OutgoingBufferSize int
	IncomingBufferSize int
	MaxMessageLength   int
	MessagesLimit      RateLimit
	BytesLimit         RateLimit
}

type StreamRecv struct {
	StreamId string `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Payload  []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

type StreamSend struct {
	StreamId string `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Payload  []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

type TokenBucketParams struct {
	Rate     float64 `protobuf:"fixed64,1,opt,name=rate,proto3" json:"rate,omitempty"`
	Capacity uint32  `protobuf:"varint,2,opt,name=capacity,proto3" json:"capacity,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedBinaryNetworkEndpointProxyServer struct{}

type UnimplementedEndpoint2ProxyServer struct{}

type UnimplementedPeerGroupProxyServer struct{}

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

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

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