introproto

package
v0.0.0-...-05bc493 Latest Latest
Warning

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

 Go to latest Published: Sep 20, 2023 License: MIT Imports: 13 Imported by: 0

Documentation

Overview

Package introproto is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterPublisherHandler 

func RegisterPublisherHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterPublisherHandler registers the http handlers for service Publisher to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterPublisherHandlerClient 

func RegisterPublisherHandlerClient(ctx context.Context, mux *runtime.ServeMux, client PublisherClient) error

RegisterPublisherHandlerClient registers the http handlers for service Publisher to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "PublisherClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "PublisherClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "PublisherClient" to call the correct interceptors.

func RegisterPublisherHandlerFromEndpoint 

func RegisterPublisherHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterPublisherHandlerFromEndpoint is same as RegisterPublisherHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterPublisherServer 

func RegisterPublisherServer(s *grpc.Server, srv PublisherServer)

Types

type AllMessageFilterStats 

type AllMessageFilterStats struct {
	Filters              []*MessageFilterWithStat `protobuf:"bytes,1,rep,name=Filters,proto3" json:"Filters,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

AllMessageFilterStats map of MessageFilterWithStat per message type.

func (*AllMessageFilterStats) Descriptor 

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

func (*AllMessageFilterStats) GetFilters 

func (m *AllMessageFilterStats) GetFilters() []*MessageFilterWithStat

func (*AllMessageFilterStats) ProtoMessage 

func (*AllMessageFilterStats) ProtoMessage()

func (*AllMessageFilterStats) Reset 

func (m *AllMessageFilterStats) Reset()

func (*AllMessageFilterStats) String 

func (m *AllMessageFilterStats) String() string

func (*AllMessageFilterStats) XXX_DiscardUnknown 

func (m *AllMessageFilterStats) XXX_DiscardUnknown()

func (*AllMessageFilterStats) XXX_Marshal 

func (m *AllMessageFilterStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AllMessageFilterStats) XXX_Merge 

func (m *AllMessageFilterStats) XXX_Merge(src proto.Message)

func (*AllMessageFilterStats) XXX_Size 

func (m *AllMessageFilterStats) XXX_Size() int

func (*AllMessageFilterStats) XXX_Unmarshal 

func (m *AllMessageFilterStats) XXX_Unmarshal(b []byte) error

type AllMessageStatByType 

type AllMessageStatByType struct {
	Counters             []*MessageStatByType `protobuf:"bytes,1,rep,name=Counters,proto3" json:"Counters,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

AllMessageStatByType is a list of counters per message type.

func (*AllMessageStatByType) Descriptor 

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

func (*AllMessageStatByType) GetCounters 

func (m *AllMessageStatByType) GetCounters() []*MessageStatByType

func (*AllMessageStatByType) ProtoMessage 

func (*AllMessageStatByType) ProtoMessage()

func (*AllMessageStatByType) Reset 

func (m *AllMessageStatByType) Reset()

func (*AllMessageStatByType) String 

func (m *AllMessageStatByType) String() string

func (*AllMessageStatByType) XXX_DiscardUnknown 

func (m *AllMessageStatByType) XXX_DiscardUnknown()

func (*AllMessageStatByType) XXX_Marshal 

func (m *AllMessageStatByType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AllMessageStatByType) XXX_Merge 

func (m *AllMessageStatByType) XXX_Merge(src proto.Message)

func (*AllMessageStatByType) XXX_Size 

func (m *AllMessageStatByType) XXX_Size() int

func (*AllMessageStatByType) XXX_Unmarshal 

func (m *AllMessageStatByType) XXX_Unmarshal(b []byte) error

type EmptyArgs 

type EmptyArgs struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

EmptyArgs is just a stub for grpc methods without arguments.

func (*EmptyArgs) Descriptor 

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

func (*EmptyArgs) ProtoMessage 

func (*EmptyArgs) ProtoMessage()

func (*EmptyArgs) Reset 

func (m *EmptyArgs) Reset()

func (*EmptyArgs) String 

func (m *EmptyArgs) String() string

func (*EmptyArgs) XXX_DiscardUnknown 

func (m *EmptyArgs) XXX_DiscardUnknown()

func (*EmptyArgs) XXX_Marshal 

func (m *EmptyArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EmptyArgs) XXX_Merge 

func (m *EmptyArgs) XXX_Merge(src proto.Message)

func (*EmptyArgs) XXX_Size 

func (m *EmptyArgs) XXX_Size() int

func (*EmptyArgs) XXX_Unmarshal 

func (m *EmptyArgs) XXX_Unmarshal(b []byte) error

type MessageFilterByType 

type MessageFilterByType struct {
	Name                 string   `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Enable               bool     `protobuf:"varint,2,opt,name=Enable,proto3" json:"Enable,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

MessageFilterByType represents filter state for message type.

func (*MessageFilterByType) Descriptor 

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

func (*MessageFilterByType) GetEnable 

func (m *MessageFilterByType) GetEnable() bool

func (*MessageFilterByType) GetName 

func (m *MessageFilterByType) GetName() string

func (*MessageFilterByType) ProtoMessage 

func (*MessageFilterByType) ProtoMessage()

func (*MessageFilterByType) Reset 

func (m *MessageFilterByType) Reset()

func (*MessageFilterByType) String 

func (m *MessageFilterByType) String() string

func (*MessageFilterByType) XXX_DiscardUnknown 

func (m *MessageFilterByType) XXX_DiscardUnknown()

func (*MessageFilterByType) XXX_Marshal 

func (m *MessageFilterByType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MessageFilterByType) XXX_Merge 

func (m *MessageFilterByType) XXX_Merge(src proto.Message)

func (*MessageFilterByType) XXX_Size 

func (m *MessageFilterByType) XXX_Size() int

func (*MessageFilterByType) XXX_Unmarshal 

func (m *MessageFilterByType) XXX_Unmarshal(b []byte) error

type MessageFilterWithStat 

type MessageFilterWithStat struct {
	Name                 string   `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Enable               bool     `protobuf:"varint,2,opt,name=Enable,proto3" json:"Enable,omitempty"`
	Filtered             int64    `protobuf:"varint,3,opt,name=Filtered,proto3" json:"Filtered,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

MessageFilterWithStat represents filter state and count of filtered messages.

func (*MessageFilterWithStat) Descriptor 

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

func (*MessageFilterWithStat) GetEnable 

func (m *MessageFilterWithStat) GetEnable() bool

func (*MessageFilterWithStat) GetFiltered 

func (m *MessageFilterWithStat) GetFiltered() int64

func (*MessageFilterWithStat) GetName 

func (m *MessageFilterWithStat) GetName() string

func (*MessageFilterWithStat) ProtoMessage 

func (*MessageFilterWithStat) ProtoMessage()

func (*MessageFilterWithStat) Reset 

func (m *MessageFilterWithStat) Reset()

func (*MessageFilterWithStat) String 

func (m *MessageFilterWithStat) String() string

func (*MessageFilterWithStat) XXX_DiscardUnknown 

func (m *MessageFilterWithStat) XXX_DiscardUnknown()

func (*MessageFilterWithStat) XXX_Marshal 

func (m *MessageFilterWithStat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MessageFilterWithStat) XXX_Merge 

func (m *MessageFilterWithStat) XXX_Merge(src proto.Message)

func (*MessageFilterWithStat) XXX_Size 

func (m *MessageFilterWithStat) XXX_Size() int

func (*MessageFilterWithStat) XXX_Unmarshal 

func (m *MessageFilterWithStat) XXX_Unmarshal(b []byte) error

type MessageStatByType 

type MessageStatByType struct {
	Name                 string   `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Count                int64    `protobuf:"varint,2,opt,name=Count,proto3" json:"Count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

MessageStatByType is a counter for message type.

func (*MessageStatByType) Descriptor 

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

func (*MessageStatByType) GetCount 

func (m *MessageStatByType) GetCount() int64

func (*MessageStatByType) GetName 

func (m *MessageStatByType) GetName() string

func (*MessageStatByType) ProtoMessage 

func (*MessageStatByType) ProtoMessage()

func (*MessageStatByType) Reset 

func (m *MessageStatByType) Reset()

func (*MessageStatByType) String 

func (m *MessageStatByType) String() string

func (*MessageStatByType) XXX_DiscardUnknown 

func (m *MessageStatByType) XXX_DiscardUnknown()

func (*MessageStatByType) XXX_Marshal 

func (m *MessageStatByType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MessageStatByType) XXX_Merge 

func (m *MessageStatByType) XXX_Merge(src proto.Message)

func (*MessageStatByType) XXX_Size 

func (m *MessageStatByType) XXX_Size() int

func (*MessageStatByType) XXX_Unmarshal 

func (m *MessageStatByType) XXX_Unmarshal(b []byte) error

type PublisherClient 

type PublisherClient interface {
	// SetMessagesFilter enables/disables messages publishing by type.
	SetMessagesFilter(ctx context.Context, in *MessageFilterByType, opts ...grpc.CallOption) (*MessageFilterByType, error)
	// GetMessagesFilters returns map with filter state for every message type.
	GetMessagesFilters(ctx context.Context, in *EmptyArgs, opts ...grpc.CallOption) (*AllMessageFilterStats, error)
	// GetMessagesStat returns statistic for published messages by type.
	GetMessagesStat(ctx context.Context, in *EmptyArgs, opts ...grpc.CallOption) (*AllMessageStatByType, error)
}

PublisherClient is the client API for Publisher service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPublisherClient 

func NewPublisherClient(cc *grpc.ClientConn) PublisherClient

type PublisherServer 

type PublisherServer interface {
	// SetMessagesFilter enables/disables messages publishing by type.
	SetMessagesFilter(context.Context, *MessageFilterByType) (*MessageFilterByType, error)
	// GetMessagesFilters returns map with filter state for every message type.
	GetMessagesFilters(context.Context, *EmptyArgs) (*AllMessageFilterStats, error)
	// GetMessagesStat returns statistic for published messages by type.
	GetMessagesStat(context.Context, *EmptyArgs) (*AllMessageStatByType, error)
}

PublisherServer is the server API for Publisher service.

type UnimplementedPublisherServer 

type UnimplementedPublisherServer struct {
}

UnimplementedPublisherServer can be embedded to have forward compatible implementations.

func (*UnimplementedPublisherServer) GetMessagesFilters 

func (*UnimplementedPublisherServer) GetMessagesFilters(ctx context.Context, req *EmptyArgs) (*AllMessageFilterStats, error)

func (*UnimplementedPublisherServer) GetMessagesStat 

func (*UnimplementedPublisherServer) GetMessagesStat(ctx context.Context, req *EmptyArgs) (*AllMessageStatByType, error)

func (*UnimplementedPublisherServer) SetMessagesFilter 

func (*UnimplementedPublisherServer) SetMessagesFilter(ctx context.Context, req *MessageFilterByType) (*MessageFilterByType, error)

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.