Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

topic

package

Go to main page

Versions in this module

v0

v0.5.0

Jan 3, 2017

Changes in this version

type Server

+ NatsStreaming ns.NatsStreaming

v0.4.0

Dec 20, 2016

Changes in this version

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

+ func RegisterTopicHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

type DeleteRequest

+ func (m *DeleteRequest) GetId() string

type TopicEntry

+ func (m *TopicEntry) GetId() string

+ func (m *TopicEntry) GetName() string

v0.3.0

Nov 8, 2016

v0.2.2

Oct 25, 2016

v0.2.1

Oct 25, 2016

Changes in this version

+ func RegisterTopicServer(s *grpc.Server, srv TopicServer)

+ type CreateReply struct

+ Topic *TopicEntry

+ func (*CreateReply) Descriptor() ([]byte, []int)

+ func (*CreateReply) ProtoMessage()

+ func (m *CreateReply) GetTopic() *TopicEntry

+ func (m *CreateReply) Reset()

+ func (m *CreateReply) String() string

+ type CreateRequest struct

+ Topic *TopicEntry

+ func (*CreateRequest) Descriptor() ([]byte, []int)

+ func (*CreateRequest) ProtoMessage()

+ func (m *CreateRequest) GetTopic() *TopicEntry

+ func (m *CreateRequest) Reset()

+ func (m *CreateRequest) String() string

+ type DeleteReply struct

+ Topic *TopicEntry

+ func (*DeleteReply) Descriptor() ([]byte, []int)

+ func (*DeleteReply) ProtoMessage()

+ func (m *DeleteReply) GetTopic() *TopicEntry

+ func (m *DeleteReply) Reset()

+ func (m *DeleteReply) String() string

+ type DeleteRequest struct

+ Id string

+ func (*DeleteRequest) Descriptor() ([]byte, []int)

+ func (*DeleteRequest) ProtoMessage()

+ func (m *DeleteRequest) Reset()

+ func (m *DeleteRequest) String() string

+ type ListReply struct

+ Topics []*TopicEntry

+ func (*ListReply) Descriptor() ([]byte, []int)

+ func (*ListReply) ProtoMessage()

+ func (m *ListReply) GetTopics() []*TopicEntry

+ func (m *ListReply) Reset()

+ func (m *ListReply) String() string

+ type ListRequest struct

+ func (*ListRequest) Descriptor() ([]byte, []int)

+ func (*ListRequest) ProtoMessage()

+ func (m *ListRequest) Reset()

+ func (m *ListRequest) String() string

+ type Server struct

+ Nats stan.Conn

+ Store storage.Interface

+ func (s *Server) Create(ctx context.Context, in *CreateRequest) (*CreateReply, error)

+ func (s *Server) Delete(ctx context.Context, in *DeleteRequest) (*DeleteReply, error)

+ func (s *Server) List(ctx context.Context, in *ListRequest) (*ListReply, error)

+ type TopicClient interface

+ Create func(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateReply, error)

+ Delete func(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteReply, error)

+ List func(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListReply, error)

+ func NewTopicClient(cc *grpc.ClientConn) TopicClient

+ type TopicEntry struct

+ Id string

+ Name string

+ func (*TopicEntry) Descriptor() ([]byte, []int)

+ func (*TopicEntry) ProtoMessage()

+ func (m *TopicEntry) Reset()

+ func (m *TopicEntry) String() string

+ type TopicServer interface

+ Create func(context.Context, *CreateRequest) (*CreateReply, error)

+ Delete func(context.Context, *DeleteRequest) (*DeleteReply, error)

+ List func(context.Context, *ListRequest) (*ListReply, error)